Interface | Description |
---|---|
TimestampsAndWatermarks<T> |
Basic interface for the timestamp extraction and watermark generation logic for the
SourceReader . |
Class | Description |
---|---|
BatchTimestampsAndWatermarks<T> |
An implementation of
TimestampsAndWatermarks to be used during batch execution of a
program. |
SourceOutputWithWatermarks<T> |
Implementation of the SourceOutput.
|
StreamingTimestampsAndWatermarks<T> |
An implementation of timestamp extraction and watermark generation logic for streaming sources.
|
TimestampsAndWatermarksContext |
A simple implementation of a context that is both
TimestampAssignerSupplier.Context and
WatermarkGeneratorSupplier.Context . |
WatermarkToDataOutput |
An adapter that exposes a
WatermarkOutput based on a PushingAsyncDataInput.DataOutput . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.