TimestampAssignerSupplier (Flink : 2.0-SNAPSHOT API)

All Superinterfaces:

Serializable

All Known Subinterfaces:

WatermarkStrategy<T>, WatermarkStrategyWithPeriodicWatermarks<T>, WatermarkStrategyWithPunctuatedWatermarks<T>

All Known Implementing Classes:

AscendingTimestampExtractor, BoundedOutOfOrdernessTimestampExtractor, PeriodicWatermarkAssignerWrapper, PunctuatedWatermarkStrategyWrapper, 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

All Methods Static Methods Instance Methods Abstract Methods
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)