org.apache.paimon.flink.source

Class OnEventWatermarkStrategy

java.lang.Object

org.apache.paimon.flink.source.OnEventWatermarkStrategy

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.eventtime.TimestampAssignerSupplier<org.apache.flink.table.data.RowData>, org.apache.flink.api.common.eventtime.WatermarkGeneratorSupplier<org.apache.flink.table.data.RowData>, org.apache.flink.api.common.eventtime.WatermarkStrategy<org.apache.flink.table.data.RowData>

public class OnEventWatermarkStrategy
extends Object
implements org.apache.flink.api.common.eventtime.WatermarkStrategy<org.apache.flink.table.data.RowData>

Paimon WatermarkStrategy to emit watermark on event.

See Also:

Serialized Form

Nested Class Summary

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

org.apache.flink.api.common.eventtime.TimestampAssignerSupplier.Context, org.apache.flink.api.common.eventtime.TimestampAssignerSupplier.SupplierFromSerializableTimestampAssigner<T>

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

org.apache.flink.api.common.eventtime.WatermarkGeneratorSupplier.Context

Constructor Summary

Constructors

Constructor and Description
OnEventWatermarkStrategy(org.apache.flink.api.common.eventtime.WatermarkStrategy<org.apache.flink.table.data.RowData> strategy)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.api.common.eventtime.WatermarkGenerator<org.apache.flink.table.data.RowData>	createWatermarkGenerator(org.apache.flink.api.common.eventtime.WatermarkGeneratorSupplier.Context context)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.api.common.eventtime.WatermarkStrategy

createTimestampAssigner, forBoundedOutOfOrderness, forGenerator, forMonotonousTimestamps, getAlignmentParameters, noWatermarks, withIdleness, withTimestampAssigner, withTimestampAssigner, withWatermarkAlignment, withWatermarkAlignment

Methods inherited from interface org.apache.flink.api.common.eventtime.TimestampAssignerSupplier

of

Constructor Detail

OnEventWatermarkStrategy

public OnEventWatermarkStrategy(org.apache.flink.api.common.eventtime.WatermarkStrategy<org.apache.flink.table.data.RowData> strategy)

Method Detail

createWatermarkGenerator

public org.apache.flink.api.common.eventtime.WatermarkGenerator<org.apache.flink.table.data.RowData> createWatermarkGenerator(org.apache.flink.api.common.eventtime.WatermarkGeneratorSupplier.Context context)

Specified by:

createWatermarkGenerator in interface org.apache.flink.api.common.eventtime.WatermarkGeneratorSupplier<org.apache.flink.table.data.RowData>

Specified by:

createWatermarkGenerator in interface org.apache.flink.api.common.eventtime.WatermarkStrategy<org.apache.flink.table.data.RowData>