Modifier and Type | Interface and Description |
---|---|
interface |
SerializableTimestampAssigner<T>
A
TimestampAssigner that is also Serializable . |
Modifier and Type | Class and Description |
---|---|
class |
IngestionTimeAssigner<T>
A timestamp assigner that assigns timestamps based on the machine's wall clock.
|
class |
RecordTimestampAssigner<E>
A
TimestampAssigner that forwards the already-assigned timestamp. |
Modifier and Type | Method and Description |
---|---|
TimestampAssigner<T> |
TimestampAssignerSupplier.createTimestampAssigner(TimestampAssignerSupplier.Context context)
Instantiates a
TimestampAssigner . |
TimestampAssigner<T> |
TimestampAssignerSupplier.SupplierFromSerializableTimestampAssigner.createTimestampAssigner(TimestampAssignerSupplier.Context context) |
default TimestampAssigner<T> |
WatermarkStrategy.createTimestampAssigner(TimestampAssignerSupplier.Context context)
Instantiates a
TimestampAssigner for assigning timestamps according to this strategy. |
Modifier and Type | Interface and Description |
---|---|
interface |
AssignerWithPeriodicWatermarks<T>
Deprecated.
|
interface |
AssignerWithPunctuatedWatermarks<T>
Deprecated.
|
interface |
TimestampAssigner<T>
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
IngestionTimeExtractor<T>
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
CustomTimestampAssigner<T>
TimestampAssigner which extracts timestamp from the second field of the input element.
|
Modifier and Type | Class and Description |
---|---|
class |
AscendingTimestampExtractor<T>
Deprecated.
|
class |
BoundedOutOfOrdernessTimestampExtractor<T>
This is a
AssignerWithPeriodicWatermarks used to emit Watermarks that lag behind the
element with the maximum timestamp (in event time) seen so far by a fixed amount of time,
t_late . |
Modifier and Type | Method and Description |
---|---|
static <E> SourceOutputWithWatermarks<E> |
SourceOutputWithWatermarks.createWithSeparateOutputs(PushingAsyncDataInput.DataOutput<E> recordsOutput,
WatermarkOutput onEventWatermarkOutput,
WatermarkOutput periodicWatermarkOutput,
TimestampAssigner<E> timestampAssigner,
WatermarkGenerator<E> watermarkGenerator)
Creates a new SourceOutputWithWatermarks that emits records to the given DataOutput and
watermarks to the different WatermarkOutputs.
|
Constructor and Description |
---|
NoOpTimestampsAndWatermarks(TimestampAssigner<T> timestamps)
Creates a new
NoOpTimestampsAndWatermarks with the given TimestampAssigner. |
ProgressiveTimestampsAndWatermarks(TimestampAssigner<T> timestampAssigner,
WatermarkGeneratorSupplier<T> watermarksFactory,
WatermarkGeneratorSupplier.Context watermarksContext,
ProcessingTimeService timeService,
java.time.Duration periodicWatermarkInterval) |
SourceOutputWithWatermarks(PushingAsyncDataInput.DataOutput<T> recordsOutput,
WatermarkOutput onEventWatermarkOutput,
WatermarkOutput periodicWatermarkOutput,
TimestampAssigner<T> timestampAssigner,
WatermarkGenerator<T> watermarkGenerator)
Creates a new SourceOutputWithWatermarks that emits records to the given DataOutput and
watermarks to the (possibly different) WatermarkOutput.
|
Constructor and Description |
---|
KafkaTopicPartitionStateWithWatermarkGenerator(KafkaTopicPartition partition,
KPH kafkaPartitionHandle,
TimestampAssigner<T> timestampAssigner,
WatermarkGenerator<T> watermarkGenerator,
WatermarkOutput immediateOutput,
WatermarkOutput deferredOutput) |
Modifier and Type | Class and Description |
---|---|
class |
CustomWatermarkExtractor
A custom
AssignerWithPeriodicWatermarks , that simply assumes that the input stream
records are strictly ascending. |
Modifier and Type | Method and Description |
---|---|
TimestampAssigner<T> |
AssignerWithPeriodicWatermarksAdapter.Strategy.createTimestampAssigner(TimestampAssignerSupplier.Context context) |
TimestampAssigner<T> |
AssignerWithPunctuatedWatermarksAdapter.Strategy.createTimestampAssigner(TimestampAssignerSupplier.Context context) |
Modifier and Type | Class and Description |
---|---|
class |
PeriodicWatermarkAssignerWrapper
Generates periodic watermarks based on a
PeriodicWatermarkAssigner . |
class |
PunctuatedWatermarkAssignerWrapper
Generates periodic watermarks based on a
PunctuatedWatermarkAssigner . |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.