org.apache.flink.api.common.eventtime

Interface WatermarkGeneratorSupplier<T>

All Superinterfaces:

Serializable

All Known Subinterfaces:

WatermarkStrategy<T>

All Known Implementing Classes:

AssignerWithPeriodicWatermarksAdapter.Strategy, AssignerWithPunctuatedWatermarksAdapter.Strategy, GeneratedWatermarkGeneratorSupplier

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@PublicEvolving
 @FunctionalInterface
public interface WatermarkGeneratorSupplier<T>
extends Serializable

A supplier for WatermarkGenerators. The supplier pattern is used to avoid having to make WatermarkGenerator Serializable for use in API methods.

This interface is Serializable because the supplier may be shipped to workers during distributed execution.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	WatermarkGeneratorSupplier.Context Additional information available to createWatermarkGenerator(Context).

Method Summary

Modifier and Type	Method and Description
WatermarkGenerator<T>	createWatermarkGenerator(WatermarkGeneratorSupplier.Context context) Instantiates a WatermarkGenerator.

Method Detail

createWatermarkGenerator

WatermarkGenerator<T> createWatermarkGenerator(WatermarkGeneratorSupplier.Context context)

Instantiates a WatermarkGenerator.