public class OnEventWatermarkStrategy extends Object implements org.apache.flink.api.common.eventtime.WatermarkStrategy<org.apache.flink.table.data.RowData>
WatermarkStrategy
to emit watermark on event.Constructor and Description |
---|
OnEventWatermarkStrategy(org.apache.flink.api.common.eventtime.WatermarkStrategy<org.apache.flink.table.data.RowData> strategy) |
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) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
createTimestampAssigner, forBoundedOutOfOrderness, forGenerator, forMonotonousTimestamps, getAlignmentParameters, noWatermarks, withIdleness, withTimestampAssigner, withTimestampAssigner, withWatermarkAlignment, withWatermarkAlignment
public OnEventWatermarkStrategy(org.apache.flink.api.common.eventtime.WatermarkStrategy<org.apache.flink.table.data.RowData> strategy)
public org.apache.flink.api.common.eventtime.WatermarkGenerator<org.apache.flink.table.data.RowData> createWatermarkGenerator(org.apache.flink.api.common.eventtime.WatermarkGeneratorSupplier.Context context)
createWatermarkGenerator
in interface org.apache.flink.api.common.eventtime.WatermarkGeneratorSupplier<org.apache.flink.table.data.RowData>
createWatermarkGenerator
in interface org.apache.flink.api.common.eventtime.WatermarkStrategy<org.apache.flink.table.data.RowData>
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.