OneInputOperatorTransformation<T> |
OneInputOperatorTransformation.assignTimestamps(Timestamper<T> timestamper) |
Deprecated.
Assigns an event time timestamp to each record.
|
OneInputOperatorTransformation<T> |
OneInputOperatorTransformation.assignTimestamps(org.apache.flink.streaming.api.functions.TimestampAssigner<T> assigner) |
Deprecated.
Assigns an event time timestamp to each record.
|
static <T> OneInputOperatorTransformation<T> |
OperatorTransformation.bootstrapWith(org.apache.flink.api.java.DataSet<T> dataSet) |
Deprecated.
|
static <T> OneInputOperatorTransformation<T> |
OperatorTransformation.bootstrapWith(org.apache.flink.api.java.DataSet<T> dataSet,
long checkpointId) |
Deprecated.
|
OneInputOperatorTransformation<T> |
OneInputOperatorTransformation.setMaxParallelism(int maxParallelism) |
Deprecated.
Sets the maximum parallelism of this operator.
|