Package | Description |
---|---|
org.apache.flink.state.api |
Modifier and Type | Method and Description |
---|---|
OneInputOperatorTransformation<T> |
OneInputOperatorTransformation.assignTimestamps(TimestampAssigner<T> assigner)
Deprecated.
Assigns an event time timestamp to each record.
|
OneInputOperatorTransformation<T> |
OneInputOperatorTransformation.assignTimestamps(Timestamper<T> timestamper)
Deprecated.
Assigns an event time timestamp to each record.
|
static <T> OneInputOperatorTransformation<T> |
OperatorTransformation.bootstrapWith(DataSet<T> dataSet)
Deprecated.
use
OperatorTransformation.bootstrapWith(DataStream) to bootstrap a savepoint using the data
stream api under batch execution. |
OneInputOperatorTransformation<T> |
OneInputOperatorTransformation.setMaxParallelism(int maxParallelism)
Deprecated.
Sets the maximum parallelism of this operator.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.