org.apache.flink.table.runtime.generated

Class GeneratedWatermarkGeneratorSupplier

java.lang.Object

org.apache.flink.table.runtime.generated.GeneratedWatermarkGeneratorSupplier

All Implemented Interfaces:

Serializable, WatermarkGeneratorSupplier<RowData>

@Internal
public class GeneratedWatermarkGeneratorSupplier
extends Object
implements WatermarkGeneratorSupplier<RowData>

Wrapper of the GeneratedWatermarkGenerator that is used to create WatermarkGenerator. The GeneratedWatermarkGeneratorSupplier uses the Context to init the generated watermark generator.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	GeneratedWatermarkGeneratorSupplier.DefaultWatermarkGenerator Wrapper of the code-generated WatermarkGenerator.

Nested classes/interfaces inherited from interface org.apache.flink.api.common.eventtime.WatermarkGeneratorSupplier

WatermarkGeneratorSupplier.Context

Constructor Summary

Constructors

Constructor and Description
GeneratedWatermarkGeneratorSupplier(GeneratedWatermarkGenerator generatedWatermarkGenerator)

Method Summary

Modifier and Type	Method and Description
WatermarkGenerator<RowData>	createWatermarkGenerator(WatermarkGeneratorSupplier.Context context) Instantiates a WatermarkGenerator.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GeneratedWatermarkGeneratorSupplier

public GeneratedWatermarkGeneratorSupplier(GeneratedWatermarkGenerator generatedWatermarkGenerator)

Method Detail

createWatermarkGenerator

public WatermarkGenerator<RowData> createWatermarkGenerator(WatermarkGeneratorSupplier.Context context)

Description copied from interface: WatermarkGeneratorSupplier

Instantiates a WatermarkGenerator.

Specified by:

createWatermarkGenerator in interface WatermarkGeneratorSupplier<RowData>