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 | Class and Description |
---|---|
class |
TimestampsAndWatermarksContext
A simple implementation of a context that is both
TimestampAssignerSupplier.Context and
WatermarkGeneratorSupplier.Context . |
Modifier and Type | Method and Description |
---|---|
TimestampAssigner<T> |
AssignerWithPunctuatedWatermarksAdapter.Strategy.createTimestampAssigner(TimestampAssignerSupplier.Context context) |
TimestampAssigner<T> |
AssignerWithPeriodicWatermarksAdapter.Strategy.createTimestampAssigner(TimestampAssignerSupplier.Context context) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.