Interface | Description |
---|---|
SerializableTimestampAssigner<T> |
A
TimestampAssigner that is also Serializable . |
TimestampAssigner<T> |
A
TimestampAssigner assigns event time timestamps to elements. |
TimestampAssignerSupplier<T> |
A supplier for
TimestampAssigners . |
TimestampAssignerSupplier.Context |
Additional information available to
TimestampAssignerSupplier.createTimestampAssigner(Context) . |
WatermarkGenerator<T> |
The
WatermarkGenerator generates watermarks either based on events or periodically (in a
fixed interval). |
WatermarkGeneratorSupplier<T> |
A supplier for
WatermarkGenerators . |
WatermarkGeneratorSupplier.Context |
Additional information available to
WatermarkGeneratorSupplier.createWatermarkGenerator(Context) . |
WatermarkOutput |
An output for watermarks.
|
WatermarkOutputMultiplexer.WatermarkUpdateListener |
A callback for propagating changes to split based watermarks.
|
WatermarkStrategy<T> |
The WatermarkStrategy defines how to generate
Watermark s in the stream sources. |
Class | Description |
---|---|
AscendingTimestampsWatermarks<T> |
A watermark generator that assumes monotonically ascending timestamps within the stream split and
periodically generates watermarks based on that assumption.
|
BoundedOutOfOrdernessWatermarks<T> |
A WatermarkGenerator for situations where records are out of order, but you can place an upper
bound on how far the events are out of order.
|
IndexedCombinedWatermarkStatus |
Represents combined value and status of a watermark for a set number of input partial watermarks.
|
IngestionTimeAssigner<T> |
A timestamp assigner that assigns timestamps based on the machine's wall clock.
|
NoWatermarksGenerator<E> |
An implementation of a
WatermarkGenerator that generates no Watermarks. |
RecordTimestampAssigner<E> |
A
TimestampAssigner that forwards the already-assigned timestamp. |
TimestampAssignerSupplier.SupplierFromSerializableTimestampAssigner<T> |
We need an actual class.
|
Watermark |
Watermarks are the progress indicators in the data streams.
|
WatermarkAlignmentParams |
Configuration parameters for watermark alignment.
|
WatermarkOutputMultiplexer |
A
WatermarkOutputMultiplexer combines the watermark (and idleness) updates of multiple
partitions/shards/splits into one combined watermark update and forwards it to an underlying
WatermarkOutput . |
WatermarksWithIdleness<T> |
A WatermarkGenerator that adds idleness detection to another WatermarkGenerator.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.