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

Class KeyGroupRangeInputSplit

java.lang.Object

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

All Implemented Interfaces:

Serializable, InputSplit, PrioritizedOperatorSubtaskStateInputSplit

@Internal
public final class KeyGroupRangeInputSplit
extends Object
implements PrioritizedOperatorSubtaskStateInputSplit

An input split representing a key-group range from a savepoint.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
KeyGroupRangeInputSplit(List<KeyedStateHandle> managedKeyedState, List<KeyedStateHandle> rawKeyedState, int numKeyGroups, int split)

Method Summary

Modifier and Type	Method and Description
int	getNumKeyGroups()
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

KeyGroupRangeInputSplit

public KeyGroupRangeInputSplit(List<KeyedStateHandle> managedKeyedState,
                               List<KeyedStateHandle> rawKeyedState,
                               int numKeyGroups,
                               int split)

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

getPrioritizedOperatorSubtaskState

public PrioritizedOperatorSubtaskState getPrioritizedOperatorSubtaskState()

Specified by:

getPrioritizedOperatorSubtaskState in interface PrioritizedOperatorSubtaskStateInputSplit

getNumKeyGroups

public int getNumKeyGroups()