Modifier and Type | Method and Description |
---|---|
static <T extends StateObject> |
StateObjectCollection.empty() |
static <T extends StateObject> |
StateObjectCollection.emptyIfNull(StateObjectCollection<T> collection) |
StateObjectCollection<InputChannelStateHandle> |
OperatorSubtaskState.getInputChannelState() |
StateObjectCollection<KeyedStateHandle> |
PrioritizedOperatorSubtaskState.getJobManagerManagedKeyedState()
Returns the managed keyed state from the job manager, which represents the ground truth about
what this state should represent.
|
StateObjectCollection<OperatorStateHandle> |
PrioritizedOperatorSubtaskState.getJobManagerManagedOperatorState()
Returns the managed operator state from the job manager, which represents the ground truth
about what this state should represent.
|
StateObjectCollection<KeyedStateHandle> |
PrioritizedOperatorSubtaskState.getJobManagerRawKeyedState()
Returns the raw keyed state from the job manager, which represents the ground truth about
what this state should represent.
|
StateObjectCollection<OperatorStateHandle> |
PrioritizedOperatorSubtaskState.getJobManagerRawOperatorState()
Returns the raw operator state from the job manager, which represents the ground truth about
what this state should represent.
|
StateObjectCollection<KeyedStateHandle> |
OperatorSubtaskState.getManagedKeyedState() |
StateObjectCollection<OperatorStateHandle> |
OperatorSubtaskState.getManagedOperatorState() |
StateObjectCollection<InputChannelStateHandle> |
PrioritizedOperatorSubtaskState.getPrioritizedInputChannelState() |
StateObjectCollection<ResultSubpartitionStateHandle> |
PrioritizedOperatorSubtaskState.getPrioritizedResultSubpartitionState() |
StateObjectCollection<KeyedStateHandle> |
OperatorSubtaskState.getRawKeyedState() |
StateObjectCollection<OperatorStateHandle> |
OperatorSubtaskState.getRawOperatorState() |
StateObjectCollection<ResultSubpartitionStateHandle> |
OperatorSubtaskState.getResultSubpartitionState() |
static <T extends StateObject> |
StateObjectCollection.singleton(T stateObject) |
static <T extends StateObject> |
StateObjectCollection.singletonOrEmpty(T stateObject) |
Modifier and Type | Method and Description |
---|---|
List<StateObjectCollection<KeyedStateHandle>> |
PrioritizedOperatorSubtaskState.getPrioritizedManagedKeyedState()
Returns an immutable list with all alternative snapshots to restore the managed keyed state,
in the order in which we should attempt to restore.
|
List<StateObjectCollection<OperatorStateHandle>> |
PrioritizedOperatorSubtaskState.getPrioritizedManagedOperatorState()
Returns an immutable list with all alternative snapshots to restore the managed operator
state, in the order in which we should attempt to restore.
|
List<StateObjectCollection<KeyedStateHandle>> |
PrioritizedOperatorSubtaskState.getPrioritizedRawKeyedState()
Returns an immutable list with all alternative snapshots to restore the raw keyed state, in
the order in which we should attempt to restore.
|
List<StateObjectCollection<OperatorStateHandle>> |
PrioritizedOperatorSubtaskState.getPrioritizedRawOperatorState()
Returns an immutable list with all alternative snapshots to restore the raw operator state,
in the order in which we should attempt to restore.
|
Modifier and Type | Method and Description |
---|---|
static <T extends StateObject> |
StateAssignmentOperation.reDistributePartitionableStates(Map<OperatorID,OperatorState> oldOperatorStates,
int newParallelism,
Function<OperatorSubtaskState,StateObjectCollection<T>> extractHandle,
OperatorStateRepartitioner<T> stateRepartitioner,
Map<OperatorInstanceID,List<T>> result) |
Modifier and Type | Method and Description |
---|---|
static Stream<StreamStateHandle> |
AbstractChannelStateHandle.collectUniqueDelegates(Stream<StateObjectCollection<? extends AbstractChannelStateHandle<?>>> collections) |
Modifier and Type | Method and Description |
---|---|
StateObjectCollection<OperatorStateHandle> |
OperatorStateInputSplit.getPrioritizedManagedOperatorState() |
Constructor and Description |
---|
OperatorStateInputSplit(StateObjectCollection<OperatorStateHandle> managedOperatorState,
int splitNum) |
Modifier and Type | Method and Description |
---|---|
Future<SnapshotResult<StateObjectCollection<InputChannelStateHandle>>> |
OperatorSnapshotFutures.getInputChannelStateFuture() |
Future<SnapshotResult<StateObjectCollection<ResultSubpartitionStateHandle>>> |
OperatorSnapshotFutures.getResultSubpartitionStateFuture() |
Modifier and Type | Method and Description |
---|---|
protected CloseableIterable<KeyGroupStatePartitionStreamProvider> |
StreamTaskStateInitializerImpl.rawKeyedStateInputs(Iterator<StateObjectCollection<KeyedStateHandle>> restoreStateAlternatives,
StateObject.StateObjectSizeStatsCollector statsCollector) |
protected CloseableIterable<StatePartitionStreamProvider> |
StreamTaskStateInitializerImpl.rawOperatorStateInputs(Iterator<StateObjectCollection<OperatorStateHandle>> restoreStateAlternatives,
StateObject.StateObjectSizeStatsCollector statsCollector) |
void |
OperatorSnapshotFutures.setInputChannelStateFuture(Future<SnapshotResult<StateObjectCollection<InputChannelStateHandle>>> inputChannelStateFuture) |
void |
OperatorSnapshotFutures.setResultSubpartitionStateFuture(Future<SnapshotResult<StateObjectCollection<ResultSubpartitionStateHandle>>> resultSubpartitionStateFuture) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.