Class OperatorStateInputSplit
- java.lang.Object
-
- org.apache.flink.state.api.input.splits.OperatorStateInputSplit
-
- All Implemented Interfaces:
Serializable
,InputSplit
,PrioritizedOperatorSubtaskStateInputSplit
@Internal public final class OperatorStateInputSplit extends Object implements PrioritizedOperatorSubtaskStateInputSplit
An input split containing state handles for operator state.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description OperatorStateInputSplit(StateObjectCollection<OperatorStateHandle> managedOperatorState, int splitNum)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description StateObjectCollection<OperatorStateHandle>
getPrioritizedManagedOperatorState()
PrioritizedOperatorSubtaskState
getPrioritizedOperatorSubtaskState()
int
getSplitNumber()
Returns the number of this input split.
-
-
-
Constructor Detail
-
OperatorStateInputSplit
public OperatorStateInputSplit(StateObjectCollection<OperatorStateHandle> managedOperatorState, int splitNum)
-
-
Method Detail
-
getSplitNumber
public int getSplitNumber()
Description copied from interface:InputSplit
Returns the number of this input split.- Specified by:
getSplitNumber
in interfaceInputSplit
- Returns:
- the number of this input split
-
getPrioritizedManagedOperatorState
@Nonnull public StateObjectCollection<OperatorStateHandle> getPrioritizedManagedOperatorState()
-
getPrioritizedOperatorSubtaskState
public PrioritizedOperatorSubtaskState getPrioritizedOperatorSubtaskState()
- Specified by:
getPrioritizedOperatorSubtaskState
in interfacePrioritizedOperatorSubtaskStateInputSplit
-
-