org.apache.paimon.flink.action.cdc.watermark

Class CdcWatermarkStrategy

java.lang.Object

org.apache.paimon.flink.action.cdc.watermark.CdcWatermarkStrategy

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.eventtime.TimestampAssignerSupplier<CdcSourceRecord>, org.apache.flink.api.common.eventtime.WatermarkGeneratorSupplier<CdcSourceRecord>, org.apache.flink.api.common.eventtime.WatermarkStrategy<CdcSourceRecord>

public class CdcWatermarkStrategy
extends Object
implements org.apache.flink.api.common.eventtime.WatermarkStrategy<CdcSourceRecord>

Watermark strategy for CDC sources, generating watermarks based on timestamps extracted from records.

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
CdcWatermarkStrategy(CdcTimestampExtractor extractor)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.api.common.eventtime.WatermarkGenerator<CdcSourceRecord>	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

CdcWatermarkStrategy

public CdcWatermarkStrategy(CdcTimestampExtractor extractor)

Method Detail

createWatermarkGenerator

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

Specified by:

createWatermarkGenerator in interface org.apache.flink.api.common.eventtime.WatermarkGeneratorSupplier<CdcSourceRecord>

Specified by:

createWatermarkGenerator in interface org.apache.flink.api.common.eventtime.WatermarkStrategy<CdcSourceRecord>