Uses of Class
org.apache.flink.state.api.OneInputStateTransformation
-
Packages that use OneInputStateTransformation Package Description org.apache.flink.state.api -
-
Uses of OneInputStateTransformation in org.apache.flink.state.api
Methods in org.apache.flink.state.api that return OneInputStateTransformation Modifier and Type Method Description static <T> OneInputStateTransformation<T>OperatorTransformation. bootstrapWith(org.apache.flink.streaming.api.datastream.DataStream<T> stream)Create a newOneInputStateTransformationfrom aDataStream.static <T> OneInputStateTransformation<T>OperatorTransformation. bootstrapWith(org.apache.flink.streaming.api.datastream.DataStream<T> stream, long checkpointId)Create a newOneInputStateTransformationfrom aDataStream.OneInputStateTransformation<T>OneInputStateTransformation. setMaxParallelism(int maxParallelism)Sets the maximum parallelism of this operator.
-