Class MergeOperatorStates
- java.lang.Object
-
- org.apache.flink.state.api.output.MergeOperatorStates
-
- All Implemented Interfaces:
Serializable,org.apache.flink.api.common.functions.Function,org.apache.flink.api.common.functions.GroupReduceFunction<org.apache.flink.runtime.checkpoint.OperatorState,org.apache.flink.runtime.checkpoint.metadata.CheckpointMetadata>
@Internal public class MergeOperatorStates extends Object implements org.apache.flink.api.common.functions.GroupReduceFunction<org.apache.flink.runtime.checkpoint.OperatorState,org.apache.flink.runtime.checkpoint.metadata.CheckpointMetadata>
A reducer that aggregates multipleOperatorState's into a singleCheckpointMetadata.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description MergeOperatorStates(long checkpointId, Collection<org.apache.flink.runtime.checkpoint.MasterState> masterStates)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidreduce(Iterable<org.apache.flink.runtime.checkpoint.OperatorState> values, org.apache.flink.util.Collector<org.apache.flink.runtime.checkpoint.metadata.CheckpointMetadata> out)
-
-
-
Constructor Detail
-
MergeOperatorStates
public MergeOperatorStates(long checkpointId, Collection<org.apache.flink.runtime.checkpoint.MasterState> masterStates)
-
-
Method Detail
-
reduce
public void reduce(Iterable<org.apache.flink.runtime.checkpoint.OperatorState> values, org.apache.flink.util.Collector<org.apache.flink.runtime.checkpoint.metadata.CheckpointMetadata> out)
- Specified by:
reducein interfaceorg.apache.flink.api.common.functions.GroupReduceFunction<org.apache.flink.runtime.checkpoint.OperatorState,org.apache.flink.runtime.checkpoint.metadata.CheckpointMetadata>
-
-