Modifier and Type | Method and Description |
---|---|
Map<OperatorID,OperatorState> |
PendingCheckpoint.getOperatorStates() |
Map<OperatorID,OperatorState> |
CompletedCheckpoint.getOperatorStates() |
Modifier and Type | Method and Description |
---|---|
static List<KeyedStateHandle> |
StateAssignmentOperation.getManagedKeyedStateHandles(OperatorState operatorState,
KeyGroupRange subtaskKeyGroupRange)
Collect
managedKeyedStateHandles which have intersection with given
KeyGroupRange from operatorState |
static List<KeyedStateHandle> |
StateAssignmentOperation.getRawKeyedStateHandles(OperatorState operatorState,
KeyGroupRange subtaskKeyGroupRange)
|
Modifier and Type | Method and Description |
---|---|
void |
StateAssignmentOperation.checkParallelismPreconditions(List<OperatorState> operatorStates,
ExecutionJobVertex executionJobVertex) |
static void |
StateAssignmentOperation.reDistributePartitionableStates(List<OperatorState> oldOperatorStates,
int newParallelism,
List<OperatorID> newOperatorIDs,
Map<OperatorInstanceID,List<OperatorStateHandle>> newManagedOperatorStates,
Map<OperatorInstanceID,List<OperatorStateHandle>> newRawOperatorStates) |
Constructor and Description |
---|
CompletedCheckpoint(JobID job,
long checkpointID,
long timestamp,
long completionTimestamp,
Map<OperatorID,OperatorState> operatorStates,
Collection<MasterState> masterHookStates,
CheckpointProperties props,
CompletedCheckpointStorageLocation storageLocation) |
StateAssignmentOperation(long restoreCheckpointId,
Map<JobVertexID,ExecutionJobVertex> tasks,
Map<OperatorID,OperatorState> operatorStates,
boolean allowNonRestoredState) |
Modifier and Type | Method and Description |
---|---|
Collection<OperatorState> |
SavepointV2.getOperatorStates() |
Collection<OperatorState> |
SavepointV1.getOperatorStates() |
Collection<OperatorState> |
Savepoint.getOperatorStates()
Returns the snapshotted operator states.
|
Constructor and Description |
---|
SavepointV2(long checkpointId,
Collection<OperatorState> operatorStates,
Collection<MasterState> masterStates) |
Constructor and Description |
---|
BroadcastStateInputFormat(OperatorState operatorState,
MapStateDescriptor<K,V> descriptor)
Creates an input format for reading broadcast state from an operator in a savepoint.
|
KeyedStateInputFormat(OperatorState operatorState,
StateBackend stateBackend,
TypeInformation<K> keyType,
KeyedStateReaderFunction<K,OUT> userFunction)
Creates an input format for reading partitioned state from an operator in a savepoint.
|
ListStateInputFormat(OperatorState operatorState,
ListStateDescriptor<OT> descriptor)
Creates an input format for reading list state from an operator in a savepoint.
|
UnionStateInputFormat(OperatorState operatorState,
ListStateDescriptor<OT> descriptor)
Creates an input format for reading union state from an operator in a savepoint.
|
Modifier and Type | Method and Description |
---|---|
void |
MergeOperatorStates.reduce(Iterable<OperatorState> values,
Collector<Savepoint> out) |
void |
OperatorSubtaskStateReducer.reduce(Iterable<TaggedOperatorSubtaskState> values,
Collector<OperatorState> out) |
Modifier and Type | Method and Description |
---|---|
OperatorState |
SavepointMetadata.getOperatorState(String uid) |
Modifier and Type | Method and Description |
---|---|
List<OperatorState> |
SavepointMetadata.getExistingOperators() |
Constructor and Description |
---|
SavepointMetadata(int maxParallelism,
Collection<MasterState> masterStates,
Collection<OperatorState> initialStates) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.