Package org.apache.flink.api.common.eventtime

Interface TimestampAssignerSupplier<T>

All Superinterfaces:

Serializable

All Known Subinterfaces:

WatermarkStrategy<T>

All Known Implementing Classes:

TimestampAssignerSupplier.SupplierFromSerializableTimestampAssigner

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 TimestampAssignerSupplier<T>
extends Serializable

A supplier for TimestampAssigners. The supplier pattern is used to avoid having to make TimestampAssigner 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	Description
static interface	TimestampAssignerSupplier.Context	Additional information available to createTimestampAssigner(Context).
static class	TimestampAssignerSupplier.SupplierFromSerializableTimestampAssigner<T>	We need an actual class.

Method Summary

Modifier and Type	Method	Description
TimestampAssigner<T>	createTimestampAssigner(TimestampAssignerSupplier.Context context)	Instantiates a TimestampAssigner.
static <T> TimestampAssignerSupplier<T>	of(SerializableTimestampAssigner<T> assigner)

Method Detail

createTimestampAssigner

TimestampAssigner<T> createTimestampAssigner(TimestampAssignerSupplier.Context context)

Instantiates a TimestampAssigner.

of

static <T> TimestampAssignerSupplier<T> of(SerializableTimestampAssigner<T> assigner)