@Internal public final class OperatorStateInputSplit extends Object implements InputSplit
Constructor and Description |
---|
OperatorStateInputSplit(StateObjectCollection<OperatorStateHandle> managedOperatorState,
int splitNum) |
Modifier and Type | Method and Description |
---|---|
List<StateObjectCollection<OperatorStateHandle>> |
getPrioritizedManagedOperatorState() |
int |
getSplitNumber()
Returns the number of this input split.
|
public OperatorStateInputSplit(StateObjectCollection<OperatorStateHandle> managedOperatorState, int splitNum)
public int getSplitNumber()
InputSplit
getSplitNumber
in interface InputSplit
@Nonnull public List<StateObjectCollection<OperatorStateHandle>> getPrioritizedManagedOperatorState()
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.