IN
- Type of the input to the partition@Deprecated @Internal public class BoundedOneInputStreamTaskRunner<IN> extends RichMapPartitionFunction<IN,TaggedOperatorSubtaskState>
RichMapPartitionFunction
that serves as the runtime for a BoundedStreamTask
.
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 OperatorSubtaskState
from the snapshot of the bounded task.
Constructor and Description |
---|
BoundedOneInputStreamTaskRunner(StreamConfig streamConfig,
int maxParallelism,
Timestamper<IN> timestamper)
Deprecated.
Create a new
BoundedOneInputStreamTaskRunner . |
Modifier and Type | Method and Description |
---|---|
void |
mapPartition(Iterable<IN> values,
Collector<TaggedOperatorSubtaskState> out)
Deprecated.
A user-implemented function that modifies or transforms an incoming object.
|
void |
open(Configuration parameters)
Deprecated.
Initialization method for the function.
|
close, getIterationRuntimeContext, getRuntimeContext, setRuntimeContext
public BoundedOneInputStreamTaskRunner(StreamConfig streamConfig, int maxParallelism, Timestamper<IN> timestamper)
BoundedOneInputStreamTaskRunner
.streamConfig
- The internal configuration for the task.maxParallelism
- The max parallelism of the operator.public void open(Configuration parameters) throws Exception
RichFunction
The configuration object passed to the function can be used for configuration and initialization. The configuration contains all parameters that were configured on the function in the program composition.
public class MyFilter extends RichFilterFunction<String> {
private String searchString;
public void open(Configuration parameters) {
this.searchString = parameters.getString("foo");
}
public boolean filter(String value) {
return value.equals(searchString);
}
}
By default, this method does nothing.
open
in interface RichFunction
open
in class AbstractRichFunction
parameters
- The configuration containing the parameters attached to the contract.Exception
- Implementations may forward exceptions, which are caught by the runtime.
When the runtime catches an exception, it aborts the task and lets the fail-over logic
decide whether to retry the task execution.Configuration
public void mapPartition(Iterable<IN> values, Collector<TaggedOperatorSubtaskState> out) throws Exception
MapPartitionFunction
mapPartition
in interface MapPartitionFunction<IN,TaggedOperatorSubtaskState>
mapPartition
in class RichMapPartitionFunction<IN,TaggedOperatorSubtaskState>
values
- All records for the mapperout
- The collector to hand results to.Exception
- This method may throw exceptions. Throwing an exception will cause the
operation to fail and may trigger recovery.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.