public class CdcWatermarkStrategy extends Object implements org.apache.flink.api.common.eventtime.WatermarkStrategy<CdcSourceRecord>
Constructor and Description |
---|
CdcWatermarkStrategy(CdcTimestampExtractor extractor) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.api.common.eventtime.WatermarkGenerator<CdcSourceRecord> |
createWatermarkGenerator(org.apache.flink.api.common.eventtime.WatermarkGeneratorSupplier.Context context) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
createTimestampAssigner, forBoundedOutOfOrderness, forGenerator, forMonotonousTimestamps, getAlignmentParameters, noWatermarks, withIdleness, withTimestampAssigner, withTimestampAssigner, withWatermarkAlignment, withWatermarkAlignment
public CdcWatermarkStrategy(CdcTimestampExtractor extractor)
public org.apache.flink.api.common.eventtime.WatermarkGenerator<CdcSourceRecord> createWatermarkGenerator(org.apache.flink.api.common.eventtime.WatermarkGeneratorSupplier.Context context)
createWatermarkGenerator
in interface org.apache.flink.api.common.eventtime.WatermarkGeneratorSupplier<CdcSourceRecord>
createWatermarkGenerator
in interface org.apache.flink.api.common.eventtime.WatermarkStrategy<CdcSourceRecord>
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.