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 <T extends StateObject> |
StateAssignmentOperation.reDistributePartitionableStates(List<OperatorState> oldOperatorStates,
int newParallelism,
List<OperatorIDPair> newOperatorIDs,
java.util.function.Function<OperatorSubtaskState,StateObjectCollection<T>> extractHandle,
OperatorStateRepartitioner<T> stateRepartitioner) |
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,
Set<ExecutionJobVertex> tasks,
Map<OperatorID,OperatorState> operatorStates,
boolean allowNonRestoredState) |
Modifier and Type | Method and Description |
---|---|
protected OperatorState |
MetadataV3Serializer.deserializeOperatorState(DataInputStream dis,
MetadataV2V3SerializerBase.DeserializationContext context) |
protected OperatorState |
MetadataV2Serializer.deserializeOperatorState(DataInputStream dis,
MetadataV2V3SerializerBase.DeserializationContext context) |
protected abstract OperatorState |
MetadataV2V3SerializerBase.deserializeOperatorState(DataInputStream dis,
MetadataV2V3SerializerBase.DeserializationContext context) |
Modifier and Type | Method and Description |
---|---|
Collection<OperatorState> |
CheckpointMetadata.getOperatorStates() |
Modifier and Type | Method and Description |
---|---|
protected void |
MetadataV3Serializer.serializeOperatorState(OperatorState operatorState,
DataOutputStream dos) |
protected void |
MetadataV2Serializer.serializeOperatorState(OperatorState operatorState,
DataOutputStream dos) |
protected abstract void |
MetadataV2V3SerializerBase.serializeOperatorState(OperatorState operatorState,
DataOutputStream dos) |
Constructor and Description |
---|
CheckpointMetadata(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,
Configuration configuration,
StateReaderOperator<?,K,N,OUT> operator)
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<CheckpointMetadata> 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–2021 The Apache Software Foundation. All rights reserved.