org.apache.flink.streaming.runtime.operators.util

Class AssignerWithPunctuatedWatermarksAdapter.Strategy<T>

java.lang.Object

org.apache.flink.streaming.runtime.operators.util.AssignerWithPunctuatedWatermarksAdapter.Strategy<T>

All Implemented Interfaces:

Serializable, TimestampAssignerSupplier<T>, WatermarkGeneratorSupplier<T>, WatermarkStrategy<T>

Enclosing class:

AssignerWithPunctuatedWatermarksAdapter<T>

public static final class AssignerWithPunctuatedWatermarksAdapter.Strategy<T>
extends Object
implements WatermarkStrategy<T>

A WatermarkStrategy that returns an AssignerWithPunctuatedWatermarks wrapped as a WatermarkGenerator.

See Also:

Serialized Form

Nested Class Summary

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

TimestampAssignerSupplier.Context, TimestampAssignerSupplier.SupplierFromSerializableTimestampAssigner<T>

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

WatermarkGeneratorSupplier.Context

Constructor Summary

Constructors

Constructor and Description
Strategy(AssignerWithPunctuatedWatermarks<T> wms)

Method Summary

Modifier and Type	Method and Description
TimestampAssigner<T>	createTimestampAssigner(TimestampAssignerSupplier.Context context) Instantiates a TimestampAssigner for assigning timestamps according to this strategy.
WatermarkGenerator<T>	createWatermarkGenerator(WatermarkGeneratorSupplier.Context context) Instantiates a WatermarkGenerator that generates watermarks according to this strategy.

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

forBoundedOutOfOrderness, forGenerator, forMonotonousTimestamps, getAlignmentParameters, noWatermarks, withIdleness, withTimestampAssigner, withTimestampAssigner, withWatermarkAlignment, withWatermarkAlignment

Methods inherited from interface org.apache.flink.api.common.eventtime.TimestampAssignerSupplier

of

Constructor Detail

Strategy

public Strategy(AssignerWithPunctuatedWatermarks<T> wms)

Method Detail

createTimestampAssigner

public TimestampAssigner<T> createTimestampAssigner(TimestampAssignerSupplier.Context context)

Description copied from interface: WatermarkStrategy

Instantiates a TimestampAssigner for assigning timestamps according to this strategy.

Specified by:

createTimestampAssigner in interface TimestampAssignerSupplier<T>

Specified by:

createTimestampAssigner in interface WatermarkStrategy<T>

createWatermarkGenerator

public WatermarkGenerator<T> createWatermarkGenerator(WatermarkGeneratorSupplier.Context context)

Description copied from interface: WatermarkStrategy

Instantiates a WatermarkGenerator that generates watermarks according to this strategy.

Specified by:

createWatermarkGenerator in interface WatermarkGeneratorSupplier<T>

Specified by:

createWatermarkGenerator in interface WatermarkStrategy<T>