Interface | Description |
---|---|
TimestampsAndWatermarks<T> |
Basic interface for the timestamp extraction and watermark generation logic for the
SourceReader . |
Class | Description |
---|---|
NoOpTimestampsAndWatermarks<T> |
An implementation of
TimestampsAndWatermarks where all watermarking/event-time operations
are no-ops. |
ProgressiveTimestampsAndWatermarks<T> |
An implementation of
TimestampsAndWatermarks that does periodic watermark emission and
keeps track of watermarks on a per-split basis. |
SourceOutputWithWatermarks<T> |
Implementation of the SourceOutput.
|
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–2022 The Apache Software Foundation. All rights reserved.