Package org.apache.flink.table.runtime.operators.wmassigners

Class PunctuatedWatermarkAssignerWrapper

  • All Implemented Interfaces:
    Serializable, org.apache.flink.api.common.eventtime.TimestampAssigner<org.apache.flink.table.data.RowData>, 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>, org.apache.flink.streaming.runtime.operators.util.WatermarkStrategyWithPunctuatedWatermarks<org.apache.flink.table.data.RowData>
    @Internal
public class PunctuatedWatermarkAssignerWrapper
extends Object
implements org.apache.flink.streaming.runtime.operators.util.WatermarkStrategyWithPunctuatedWatermarks<org.apache.flink.table.data.RowData>
    Generates periodic watermarks based on a PunctuatedWatermarkAssigner.
    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 extends Object>

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

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

    • Field Summary

      • Fields inherited from interface org.apache.flink.api.common.eventtime.TimestampAssigner

        NO_TIMESTAMP

    • Constructor Summary

      Constructors 
      Constructor Description
      PunctuatedWatermarkAssignerWrapper​(org.apache.flink.table.sources.wmstrategies.PunctuatedWatermarkAssigner assigner, int timeFieldIdx, org.apache.flink.table.types.DataType sourceType)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      org.apache.flink.streaming.api.watermark.Watermark checkAndGetNextWatermark​(org.apache.flink.table.data.RowData row, long extractedTimestamp)  
      long extractTimestamp​(org.apache.flink.table.data.RowData element, long recordTimestamp)  

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

        getAlignmentParameters, withIdleness, withTimestampAssigner, withTimestampAssigner, withWatermarkAlignment, withWatermarkAlignment

      • Methods inherited from interface org.apache.flink.streaming.runtime.operators.util.WatermarkStrategyWithPunctuatedWatermarks

        createTimestampAssigner, createWatermarkGenerator

    • Constructor Detail

      • PunctuatedWatermarkAssignerWrapper

        public PunctuatedWatermarkAssignerWrapper​(org.apache.flink.table.sources.wmstrategies.PunctuatedWatermarkAssigner assigner,
                                          int timeFieldIdx,
                                          org.apache.flink.table.types.DataType sourceType)
        Parameters:
        timeFieldIdx - the index of the rowtime attribute.
        assigner - the watermark assigner.
        sourceType - the type of source

    • Method Detail

      • checkAndGetNextWatermark

        @Nullable
public org.apache.flink.streaming.api.watermark.Watermark checkAndGetNextWatermark​(org.apache.flink.table.data.RowData row,
                                                                                   long extractedTimestamp)
        Specified by:
        checkAndGetNextWatermark in interface org.apache.flink.streaming.runtime.operators.util.WatermarkStrategyWithPunctuatedWatermarks<org.apache.flink.table.data.RowData>

      • extractTimestamp

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