Class BoundedOneInputStreamTaskRunner<IN>
- java.lang.Object
-
- org.apache.flink.api.common.functions.AbstractRichFunction
-
- org.apache.flink.api.common.functions.RichMapPartitionFunction<IN,TaggedOperatorSubtaskState>
-
- org.apache.flink.state.api.output.BoundedOneInputStreamTaskRunner<IN>
-
- Type Parameters:
IN- Type of the input to the partition
- All Implemented Interfaces:
Serializable,org.apache.flink.api.common.functions.Function,org.apache.flink.api.common.functions.MapPartitionFunction<IN,TaggedOperatorSubtaskState>,org.apache.flink.api.common.functions.RichFunction
@Deprecated @Internal public class BoundedOneInputStreamTaskRunner<IN> extends org.apache.flink.api.common.functions.RichMapPartitionFunction<IN,TaggedOperatorSubtaskState>
Deprecated.ARichMapPartitionFunctionthat serves as the runtime for aBoundedStreamTask.The task is executed processing the data in a particular partition instead of the pulling from the network stack. After all data has been processed the runner will output the
OperatorSubtaskStatefrom the snapshot of the bounded task.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description BoundedOneInputStreamTaskRunner(org.apache.flink.streaming.api.graph.StreamConfig streamConfig, int maxParallelism, Timestamper<IN> timestamper)Deprecated.Create a newBoundedOneInputStreamTaskRunner.
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description voidmapPartition(Iterable<IN> values, org.apache.flink.util.Collector<TaggedOperatorSubtaskState> out)Deprecated.voidopen(org.apache.flink.configuration.Configuration parameters)Deprecated.
-
-
-
Constructor Detail
-
BoundedOneInputStreamTaskRunner
public BoundedOneInputStreamTaskRunner(org.apache.flink.streaming.api.graph.StreamConfig streamConfig, int maxParallelism, Timestamper<IN> timestamper)Deprecated.Create a newBoundedOneInputStreamTaskRunner.- Parameters:
streamConfig- The internal configuration for the task.maxParallelism- The max parallelism of the operator.
-
-
Method Detail
-
open
public void open(org.apache.flink.configuration.Configuration parameters) throws ExceptionDeprecated.- Specified by:
openin interfaceorg.apache.flink.api.common.functions.RichFunction- Overrides:
openin classorg.apache.flink.api.common.functions.AbstractRichFunction- Throws:
Exception
-
mapPartition
public void mapPartition(Iterable<IN> values, org.apache.flink.util.Collector<TaggedOperatorSubtaskState> out) throws Exception
Deprecated.- Specified by:
mapPartitionin interfaceorg.apache.flink.api.common.functions.MapPartitionFunction<IN,TaggedOperatorSubtaskState>- Specified by:
mapPartitionin classorg.apache.flink.api.common.functions.RichMapPartitionFunction<IN,TaggedOperatorSubtaskState>- Throws:
Exception
-
-