Modifier and Type | Method and Description |
---|---|
OperatorStateBackend |
RocksDBStateBackend.createOperatorStateBackend(Environment env,
String operatorIdentifier,
Collection<OperatorStateHandle> stateHandles,
CloseableRegistry cancelStreamRegistry) |
Modifier and Type | Field and Description |
---|---|
static OperatorStateRepartitioner<OperatorStateHandle> |
RoundRobinOperatorStateRepartitioner.INSTANCE |
Modifier and Type | Method and Description |
---|---|
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<OperatorStateHandle> |
PrioritizedOperatorSubtaskState.getJobManagerRawOperatorState()
Returns the raw operator state from the job manager, which represents the ground truth about
what this state should represent.
|
StateObjectCollection<OperatorStateHandle> |
OperatorSubtaskState.getManagedOperatorState()
Returns a handle to the managed operator state.
|
ChainedStateHandle<OperatorStateHandle> |
SubtaskState.getManagedOperatorState() |
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<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.
|
StateObjectCollection<OperatorStateHandle> |
OperatorSubtaskState.getRawOperatorState()
Returns a handle to the raw operator state.
|
ChainedStateHandle<OperatorStateHandle> |
SubtaskState.getRawOperatorState() |
List<List<OperatorStateHandle>> |
RoundRobinOperatorStateRepartitioner.repartitionState(List<List<OperatorStateHandle>> previousParallelSubtaskStates,
int oldParallelism,
int newParallelism) |
Constructor and Description |
---|
OperatorSubtaskState(OperatorStateHandle managedOperatorState,
OperatorStateHandle rawOperatorState,
KeyedStateHandle managedKeyedState,
KeyedStateHandle rawKeyedState,
StateObjectCollection<InputChannelStateHandle> inputChannelState,
StateObjectCollection<ResultSubpartitionStateHandle> resultSubpartitionState)
For convenience because the size of the collections is typically 0 or 1.
|
Modifier and Type | Method and Description |
---|---|
static OperatorStateHandle |
MetadataV3Serializer.deserializeOperatorStateHandleUtil(DataInputStream dis) |
Modifier and Type | Method and Description |
---|---|
static void |
MetadataV3Serializer.serializeOperatorStateHandleUtil(OperatorStateHandle stateHandle,
DataOutputStream dos) |
Modifier and Type | Class and Description |
---|---|
class |
OperatorStreamStateHandle
State handle for partitionable operator state.
|
Modifier and Type | Field and Description |
---|---|
protected RunnableFuture<SnapshotResult<OperatorStateHandle>> |
StateSnapshotContextSynchronousImpl.operatorStateCheckpointClosingFuture |
protected Collection<OperatorStateHandle> |
DefaultOperatorStateBackendBuilder.restoreStateHandles
State handles for restore.
|
Modifier and Type | Method and Description |
---|---|
RunnableFuture<SnapshotResult<OperatorStateHandle>> |
StateSnapshotContextSynchronousImpl.getOperatorStateStreamFuture() |
RunnableFuture<SnapshotResult<OperatorStateHandle>> |
DefaultOperatorStateBackend.snapshot(long checkpointId,
long timestamp,
CheckpointStreamFactory streamFactory,
CheckpointOptions checkpointOptions) |
Modifier and Type | Method and Description |
---|---|
abstract OperatorStateBackend |
AbstractStateBackend.createOperatorStateBackend(Environment env,
String operatorIdentifier,
Collection<OperatorStateHandle> stateHandles,
CloseableRegistry cancelStreamRegistry) |
OperatorStateBackend |
StateBackend.createOperatorStateBackend(Environment env,
String operatorIdentifier,
Collection<OperatorStateHandle> stateHandles,
CloseableRegistry cancelStreamRegistry)
Creates a new
OperatorStateBackend that can be used for storing operator state. |
Modifier and Type | Method and Description |
---|---|
OperatorStateBackend |
FsStateBackend.createOperatorStateBackend(Environment env,
String operatorIdentifier,
Collection<OperatorStateHandle> stateHandles,
CloseableRegistry cancelStreamRegistry) |
Modifier and Type | Method and Description |
---|---|
OperatorStateBackend |
MemoryStateBackend.createOperatorStateBackend(Environment env,
String operatorIdentifier,
Collection<OperatorStateHandle> stateHandles,
CloseableRegistry cancelStreamRegistry) |
Modifier and Type | Method and Description |
---|---|
List<StateObjectCollection<OperatorStateHandle>> |
OperatorStateInputSplit.getPrioritizedManagedOperatorState() |
Constructor and Description |
---|
OperatorStateInputSplit(StateObjectCollection<OperatorStateHandle> managedOperatorState,
int splitNum) |
Modifier and Type | Method and Description |
---|---|
RunnableFuture<SnapshotResult<OperatorStateHandle>> |
OperatorSnapshotFutures.getOperatorStateManagedFuture() |
RunnableFuture<SnapshotResult<OperatorStateHandle>> |
OperatorSnapshotFutures.getOperatorStateRawFuture() |
Modifier and Type | Method and Description |
---|---|
protected CloseableIterable<StatePartitionStreamProvider> |
StreamTaskStateInitializerImpl.rawOperatorStateInputs(Iterator<StateObjectCollection<OperatorStateHandle>> restoreStateAlternatives) |
void |
OperatorSnapshotFutures.setOperatorStateManagedFuture(RunnableFuture<SnapshotResult<OperatorStateHandle>> operatorStateManagedFuture) |
void |
OperatorSnapshotFutures.setOperatorStateRawFuture(RunnableFuture<SnapshotResult<OperatorStateHandle>> operatorStateRawFuture) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.