static OperatorSubtaskState |
StateAssignmentOperation.operatorSubtaskStateFrom(OperatorInstanceID instanceID,
Map<OperatorInstanceID,List<OperatorStateHandle>> subManagedOperatorState,
Map<OperatorInstanceID,List<OperatorStateHandle>> subRawOperatorState,
Map<OperatorInstanceID,List<KeyedStateHandle>> subManagedKeyedState,
Map<OperatorInstanceID,List<KeyedStateHandle>> subRawKeyedState) |
static OperatorSubtaskState |
StateAssignmentOperation.operatorSubtaskStateFrom(OperatorInstanceID instanceID,
Map<OperatorInstanceID,List<OperatorStateHandle>> subManagedOperatorState,
Map<OperatorInstanceID,List<OperatorStateHandle>> subRawOperatorState,
Map<OperatorInstanceID,List<KeyedStateHandle>> subManagedKeyedState,
Map<OperatorInstanceID,List<KeyedStateHandle>> subRawKeyedState) |
static OperatorSubtaskState |
StateAssignmentOperation.operatorSubtaskStateFrom(OperatorInstanceID instanceID,
Map<OperatorInstanceID,List<OperatorStateHandle>> subManagedOperatorState,
Map<OperatorInstanceID,List<OperatorStateHandle>> subRawOperatorState,
Map<OperatorInstanceID,List<KeyedStateHandle>> subManagedKeyedState,
Map<OperatorInstanceID,List<KeyedStateHandle>> subRawKeyedState) |
static OperatorSubtaskState |
StateAssignmentOperation.operatorSubtaskStateFrom(OperatorInstanceID instanceID,
Map<OperatorInstanceID,List<OperatorStateHandle>> subManagedOperatorState,
Map<OperatorInstanceID,List<OperatorStateHandle>> subRawOperatorState,
Map<OperatorInstanceID,List<KeyedStateHandle>> subManagedKeyedState,
Map<OperatorInstanceID,List<KeyedStateHandle>> subRawKeyedState) |
static void |
StateAssignmentOperation.reDistributePartitionableStates(List<OperatorState> oldOperatorStates,
int newParallelism,
List<OperatorID> newOperatorIDs,
Map<OperatorInstanceID,List<OperatorStateHandle>> newManagedOperatorStates,
Map<OperatorInstanceID,List<OperatorStateHandle>> newRawOperatorStates) |
static void |
StateAssignmentOperation.reDistributePartitionableStates(List<OperatorState> oldOperatorStates,
int newParallelism,
List<OperatorID> newOperatorIDs,
Map<OperatorInstanceID,List<OperatorStateHandle>> newManagedOperatorStates,
Map<OperatorInstanceID,List<OperatorStateHandle>> newRawOperatorStates) |