public static class WatermarkPushDownSpec.DefaultWatermarkGeneratorSupplier extends Object implements WatermarkGeneratorSupplier<RowData>
GeneratedWatermarkGenerator
that is used to create WatermarkGenerator
. The WatermarkPushDownSpec.DefaultWatermarkGeneratorSupplier
uses the WatermarkGeneratorSupplier.Context
to init the generated watermark generator.Modifier and Type | Class and Description |
---|---|
static class |
WatermarkPushDownSpec.DefaultWatermarkGeneratorSupplier.DefaultWatermarkGenerator
Wrapper of the code-generated
WatermarkGenerator . |
WatermarkGeneratorSupplier.Context
Constructor and Description |
---|
DefaultWatermarkGeneratorSupplier(Configuration configuration,
GeneratedWatermarkGenerator generatedWatermarkGenerator) |
Modifier and Type | Method and Description |
---|---|
WatermarkGenerator<RowData> |
createWatermarkGenerator(WatermarkGeneratorSupplier.Context context)
Instantiates a
WatermarkGenerator . |
public DefaultWatermarkGeneratorSupplier(Configuration configuration, GeneratedWatermarkGenerator generatedWatermarkGenerator)
public WatermarkGenerator<RowData> createWatermarkGenerator(WatermarkGeneratorSupplier.Context context)
WatermarkGeneratorSupplier
WatermarkGenerator
.createWatermarkGenerator
in interface WatermarkGeneratorSupplier<RowData>
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.