OperatorSubtaskStateReducer (Flink : Libraries : State processor API 1.18.1-cp1 API)

java.lang.Object
- org.apache.flink.api.common.functions.AbstractRichFunction
- - org.apache.flink.api.common.functions.RichGroupReduceFunction<TaggedOperatorSubtaskState,org.apache.flink.runtime.checkpoint.OperatorState>
  - - org.apache.flink.state.api.output.OperatorSubtaskStateReducer

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.GroupReduceFunction<TaggedOperatorSubtaskState,org.apache.flink.runtime.checkpoint.OperatorState>, org.apache.flink.api.common.functions.RichFunction
```
@Internal
public class OperatorSubtaskStateReducer
extends org.apache.flink.api.common.functions.RichGroupReduceFunction<TaggedOperatorSubtaskState,org.apache.flink.runtime.checkpoint.OperatorState>
```
A reducer that aggregates all OperatorSubtaskState's for a particular operator into a single OperatorState.

See Also:

Serialized Form

Constructor Summary

Constructors
Constructor Description

OperatorSubtaskStateReducer(org.apache.flink.runtime.jobgraph.OperatorID operatorID, int maxParallelism)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`open(org.apache.flink.configuration.Configuration parameters)`
`void`	`reduce(Iterable<TaggedOperatorSubtaskState> values, org.apache.flink.util.Collector<org.apache.flink.runtime.checkpoint.OperatorState> out)`

Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction
close, getIterationRuntimeContext, getRuntimeContext, setRuntimeContext

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - OperatorSubtaskStateReducer
```
public OperatorSubtaskStateReducer(org.apache.flink.runtime.jobgraph.OperatorID operatorID,
                                   int maxParallelism)
```
- Method Detail
  - open
```
public void open(org.apache.flink.configuration.Configuration parameters)
          throws Exception
```
    Specified by:
    
    open in interface org.apache.flink.api.common.functions.RichFunction
    
    Overrides:
    
    open in class org.apache.flink.api.common.functions.AbstractRichFunction
    
    Throws:
    
    Exception
  - reduce
```
public void reduce(Iterable<TaggedOperatorSubtaskState> values,
                   org.apache.flink.util.Collector<org.apache.flink.runtime.checkpoint.OperatorState> out)
```
    Specified by:
    
    reduce in interface org.apache.flink.api.common.functions.GroupReduceFunction<TaggedOperatorSubtaskState,org.apache.flink.runtime.checkpoint.OperatorState>
    
    Specified by:
    
    reduce in class org.apache.flink.api.common.functions.RichGroupReduceFunction<TaggedOperatorSubtaskState,org.apache.flink.runtime.checkpoint.OperatorState>