Modifier and Type | Method and Description |
---|---|
WatermarkGenerator<T> |
WatermarkGeneratorSupplier.createWatermarkGenerator(WatermarkGeneratorSupplier.Context context)
Instantiates a
WatermarkGenerator . |
WatermarkGenerator<T> |
WatermarkStrategy.createWatermarkGenerator(WatermarkGeneratorSupplier.Context context)
Instantiates a WatermarkGenerator that generates watermarks 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 |
---|---|
WatermarkGenerator<T> |
AssignerWithPeriodicWatermarksAdapter.Strategy.createWatermarkGenerator(WatermarkGeneratorSupplier.Context context) |
WatermarkGenerator<T> |
AssignerWithPunctuatedWatermarksAdapter.Strategy.createWatermarkGenerator(WatermarkGeneratorSupplier.Context context) |
Modifier and Type | Method and Description |
---|---|
WatermarkGenerator<RowData> |
GeneratedWatermarkGeneratorSupplier.createWatermarkGenerator(WatermarkGeneratorSupplier.Context context) |
Constructor and Description |
---|
WatermarkGeneratorCodeGeneratorFunctionContextWrapper(WatermarkGeneratorSupplier.Context context) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.