Uses of Interface
org.apache.flink.state.api.functions.Timestamper
-
Packages that use Timestamper Package Description org.apache.flink.state.api org.apache.flink.state.api.output -
-
Uses of Timestamper in org.apache.flink.state.api
Methods in org.apache.flink.state.api with parameters of type Timestamper Modifier and Type Method Description OneInputOperatorTransformation<T>OneInputOperatorTransformation. assignTimestamps(Timestamper<T> timestamper)Deprecated.Assigns an event time timestamp to each record. -
Uses of Timestamper in org.apache.flink.state.api.output
Classes in org.apache.flink.state.api.output that implement Timestamper Modifier and Type Class Description classTimestampAssignerWrapper<T>Deprecated.Constructors in org.apache.flink.state.api.output with parameters of type Timestamper Constructor Description BoundedOneInputStreamTaskRunner(org.apache.flink.streaming.api.graph.StreamConfig streamConfig, int maxParallelism, Timestamper<IN> timestamper)Deprecated.Create a newBoundedOneInputStreamTaskRunner.
-