org.apache.flink.state.api.input.splits

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 and Description
OperatorStateInputSplit(StateObjectCollection<OperatorStateHandle> managedOperatorState, int splitNum)

Method Summary

Modifier and Type	Method and Description
StateObjectCollection<OperatorStateHandle>	getPrioritizedManagedOperatorState()
PrioritizedOperatorSubtaskState	getPrioritizedOperatorSubtaskState()
int	getSplitNumber() Returns the number of this input split.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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 interface InputSplit

Returns:

the number of this input split

getPrioritizedManagedOperatorState

@Nonnull
public StateObjectCollection<OperatorStateHandle> getPrioritizedManagedOperatorState()

getPrioritizedOperatorSubtaskState

public PrioritizedOperatorSubtaskState getPrioritizedOperatorSubtaskState()

Specified by:

getPrioritizedOperatorSubtaskState in interface PrioritizedOperatorSubtaskStateInputSplit