Class TimestampAssignerSupplier.SupplierFromSerializableTimestampAssigner<T>
- java.lang.Object
-
- org.apache.flink.api.common.eventtime.TimestampAssignerSupplier.SupplierFromSerializableTimestampAssigner<T>
-
- All Implemented Interfaces:
Serializable
,TimestampAssignerSupplier<T>
- Enclosing interface:
- TimestampAssignerSupplier<T>
public static class TimestampAssignerSupplier.SupplierFromSerializableTimestampAssigner<T> extends Object implements TimestampAssignerSupplier<T>
We need an actual class. Implementing this as a lambda inTimestampAssignerSupplier.of(SerializableTimestampAssigner)
would not allow theClosureCleaner
to "reach" into theSerializableTimestampAssigner
.- 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>
-
-
Constructor Summary
Constructors Constructor Description SupplierFromSerializableTimestampAssigner(SerializableTimestampAssigner<T> assigner)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description TimestampAssigner<T>
createTimestampAssigner(TimestampAssignerSupplier.Context context)
Instantiates aTimestampAssigner
.
-
-
-
Constructor Detail
-
SupplierFromSerializableTimestampAssigner
public SupplierFromSerializableTimestampAssigner(SerializableTimestampAssigner<T> assigner)
-
-
Method Detail
-
createTimestampAssigner
public TimestampAssigner<T> createTimestampAssigner(TimestampAssignerSupplier.Context context)
Description copied from interface:TimestampAssignerSupplier
Instantiates aTimestampAssigner
.- Specified by:
createTimestampAssigner
in interfaceTimestampAssignerSupplier<T>
-
-