Uses of Interface
org.apache.flink.api.common.eventtime.TimestampAssigner
-
Packages that use TimestampAssigner Package Description org.apache.flink.api.common.eventtime -
-
Uses of TimestampAssigner in org.apache.flink.api.common.eventtime
Subinterfaces of TimestampAssigner in org.apache.flink.api.common.eventtime Modifier and Type Interface Description interfaceSerializableTimestampAssigner<T>ATimestampAssignerthat is alsoSerializable.Classes in org.apache.flink.api.common.eventtime that implement TimestampAssigner Modifier and Type Class Description classIngestionTimeAssigner<T>A timestamp assigner that assigns timestamps based on the machine's wall clock.classRecordTimestampAssigner<E>ATimestampAssignerthat forwards the already-assigned timestamp.Methods in org.apache.flink.api.common.eventtime that return TimestampAssigner Modifier and Type Method Description TimestampAssigner<T>TimestampAssignerSupplier. createTimestampAssigner(TimestampAssignerSupplier.Context context)Instantiates aTimestampAssigner.TimestampAssigner<T>TimestampAssignerSupplier.SupplierFromSerializableTimestampAssigner. createTimestampAssigner(TimestampAssignerSupplier.Context context)default TimestampAssigner<T>WatermarkStrategy. createTimestampAssigner(TimestampAssignerSupplier.Context context)Instantiates aTimestampAssignerfor assigning timestamps according to this strategy.
-