Class PeriodicWatermarkAssignerWrapper

  • All Implemented Interfaces:
    Serializable, org.apache.flink.api.common.eventtime.TimestampAssigner<org.apache.flink.table.data.RowData>, org.apache.flink.api.common.functions.Function, org.apache.flink.streaming.api.functions.AssignerWithPeriodicWatermarks<org.apache.flink.table.data.RowData>, org.apache.flink.streaming.api.functions.TimestampAssigner<org.apache.flink.table.data.RowData>

    @Internal
    public class PeriodicWatermarkAssignerWrapper
    extends Object
    implements org.apache.flink.streaming.api.functions.AssignerWithPeriodicWatermarks<org.apache.flink.table.data.RowData>
    Generates periodic watermarks based on a PeriodicWatermarkAssigner.
    See Also:
    Serialized Form
    • Constructor Detail

      • PeriodicWatermarkAssignerWrapper

        public PeriodicWatermarkAssignerWrapper​(org.apache.flink.table.sources.wmstrategies.PeriodicWatermarkAssigner assigner,
                                                int timeFieldIdx)
        Parameters:
        timeFieldIdx - the index of the rowtime attribute.
        assigner - the watermark assigner.
    • Method Detail

      • getCurrentWatermark

        @Nullable
        public org.apache.flink.streaming.api.watermark.Watermark getCurrentWatermark()
        Specified by:
        getCurrentWatermark in interface org.apache.flink.streaming.api.functions.AssignerWithPeriodicWatermarks<org.apache.flink.table.data.RowData>
      • extractTimestamp

        public long extractTimestamp​(org.apache.flink.table.data.RowData row,
                                     long recordTimestamp)
        Specified by:
        extractTimestamp in interface org.apache.flink.api.common.eventtime.TimestampAssigner<org.apache.flink.table.data.RowData>
        Specified by:
        extractTimestamp in interface org.apache.flink.streaming.api.functions.TimestampAssigner<org.apache.flink.table.data.RowData>