Package | Description |
---|---|
org.apache.flink.contrib.streaming.state | |
org.apache.flink.runtime.checkpoint | |
org.apache.flink.runtime.checkpoint.savepoint | |
org.apache.flink.runtime.state | |
org.apache.flink.runtime.state.heap |
This package contains the classes for key/value state backends that store the state
on the JVM heap as objects.
|
org.apache.flink.streaming.api.operators |
Modifier and Type | Method and Description |
---|---|
RunnableFuture<SnapshotResult<KeyedStateHandle>> |
RocksDBKeyedStateBackend.snapshot(long checkpointId,
long timestamp,
CheckpointStreamFactory streamFactory,
CheckpointOptions checkpointOptions)
Triggers an asynchronous snapshot of the keyed state backend from RocksDB.
|
Modifier and Type | Method and Description |
---|---|
void |
RocksDBKeyedStateBackend.restore(Collection<KeyedStateHandle> restoreState) |
Modifier and Type | Method and Description |
---|---|
KeyedStateHandle |
SubtaskState.getManagedKeyedState() |
KeyedStateHandle |
SubtaskState.getRawKeyedState() |
Modifier and Type | Method and Description |
---|---|
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<KeyedStateHandle> |
PrioritizedOperatorSubtaskState.getJobManagerRawKeyedState()
Returns the raw keyed state from the job manager, which represents the ground truth about what this state
should represent.
|
static List<KeyedStateHandle> |
StateAssignmentOperation.getKeyedStateHandles(Collection<? extends KeyedStateHandle> keyedStateHandles,
KeyGroupRange subtaskKeyGroupRange)
Determine the subset of
KeyGroupsStateHandles with correct
key group index for the given subtask KeyGroupRange . |
StateObjectCollection<KeyedStateHandle> |
OperatorSubtaskState.getManagedKeyedState()
Returns a handle to the managed keyed state.
|
static List<KeyedStateHandle> |
StateAssignmentOperation.getManagedKeyedStateHandles(OperatorState operatorState,
KeyGroupRange subtaskKeyGroupRange)
Collect
managedKeyedStateHandles which have intersection with given
KeyGroupRange from operatorState |
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<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.
|
StateObjectCollection<KeyedStateHandle> |
OperatorSubtaskState.getRawKeyedState()
Returns a handle to the raw keyed state.
|
static List<KeyedStateHandle> |
StateAssignmentOperation.getRawKeyedStateHandles(OperatorState operatorState,
KeyGroupRange subtaskKeyGroupRange)
|
Constructor and Description |
---|
OperatorSubtaskState(OperatorStateHandle managedOperatorState,
OperatorStateHandle rawOperatorState,
KeyedStateHandle managedKeyedState,
KeyedStateHandle rawKeyedState)
For convenience because the size of the collections is typically 0 or 1.
|
SubtaskState(ChainedStateHandle<OperatorStateHandle> managedOperatorState,
ChainedStateHandle<OperatorStateHandle> rawOperatorState,
KeyedStateHandle managedKeyedState,
KeyedStateHandle rawKeyedState) |
Constructor and Description |
---|
OperatorSubtaskState(StateObjectCollection<OperatorStateHandle> managedOperatorState,
StateObjectCollection<OperatorStateHandle> rawOperatorState,
StateObjectCollection<KeyedStateHandle> managedKeyedState,
StateObjectCollection<KeyedStateHandle> rawKeyedState) |
OperatorSubtaskState(StateObjectCollection<OperatorStateHandle> managedOperatorState,
StateObjectCollection<OperatorStateHandle> rawOperatorState,
StateObjectCollection<KeyedStateHandle> managedKeyedState,
StateObjectCollection<KeyedStateHandle> rawKeyedState) |
Modifier and Type | Method and Description |
---|---|
static KeyedStateHandle |
SavepointV1Serializer.deserializeKeyedStateHandle(DataInputStream dis) |
Modifier and Type | Method and Description |
---|---|
static void |
SavepointV1Serializer.serializeKeyedStateHandle(KeyedStateHandle stateHandle,
DataOutputStream dos) |
Modifier and Type | Class and Description |
---|---|
class |
DirectoryKeyedStateHandle
This class is a keyed state handle based on a directory.
|
class |
IncrementalKeyedStateHandle
The handle to states of an incremental snapshot.
|
class |
IncrementalLocalKeyedStateHandle
State handle for local copies of
IncrementalKeyedStateHandle . |
class |
KeyGroupsStateHandle
A handle to the partitioned stream operator state after it has been checkpointed.
|
Modifier and Type | Method and Description |
---|---|
KeyedStateHandle |
IncrementalKeyedStateHandle.getIntersection(KeyGroupRange keyGroupRange) |
KeyedStateHandle |
KeyedStateHandle.getIntersection(KeyGroupRange keyGroupRange)
Returns a state over a range that is the intersection between this
handle's key-group range and the provided key-group range.
|
KeyedStateHandle |
DirectoryKeyedStateHandle.getIntersection(KeyGroupRange otherKeyGroupRange) |
Modifier and Type | Method and Description |
---|---|
RunnableFuture<SnapshotResult<KeyedStateHandle>> |
StateSnapshotContextSynchronousImpl.getKeyedStateStreamFuture() |
static SnapshotResult<KeyedStateHandle> |
CheckpointStreamWithResultProvider.toKeyedStateHandleSnapshotResult(SnapshotResult<StreamStateHandle> snapshotResult,
KeyGroupRangeOffsets keyGroupRangeOffsets)
Helper method that takes a
SnapshotResult and a KeyGroupRangeOffsets and
creates a SnapshotResult by combining the key groups offsets with all the
present stream state handles. |
Modifier and Type | Method and Description |
---|---|
RunnableFuture<SnapshotResult<KeyedStateHandle>> |
HeapKeyedStateBackend.snapshot(long checkpointId,
long timestamp,
CheckpointStreamFactory streamFactory,
CheckpointOptions checkpointOptions) |
Modifier and Type | Method and Description |
---|---|
void |
HeapKeyedStateBackend.restore(Collection<KeyedStateHandle> restoredState) |
Modifier and Type | Method and Description |
---|---|
RunnableFuture<SnapshotResult<KeyedStateHandle>> |
OperatorSnapshotFutures.getKeyedStateManagedFuture() |
RunnableFuture<SnapshotResult<KeyedStateHandle>> |
OperatorSnapshotFutures.getKeyedStateRawFuture() |
Modifier and Type | Method and Description |
---|---|
protected CloseableIterable<KeyGroupStatePartitionStreamProvider> |
StreamTaskStateInitializerImpl.rawKeyedStateInputs(Iterator<StateObjectCollection<KeyedStateHandle>> restoreStateAlternatives) |
void |
OperatorSnapshotFutures.setKeyedStateManagedFuture(RunnableFuture<SnapshotResult<KeyedStateHandle>> keyedStateManagedFuture) |
void |
OperatorSnapshotFutures.setKeyedStateRawFuture(RunnableFuture<SnapshotResult<KeyedStateHandle>> keyedStateRawFuture) |
Constructor and Description |
---|
OperatorSnapshotFutures(RunnableFuture<SnapshotResult<KeyedStateHandle>> keyedStateManagedFuture,
RunnableFuture<SnapshotResult<KeyedStateHandle>> keyedStateRawFuture,
RunnableFuture<SnapshotResult<OperatorStateHandle>> operatorStateManagedFuture,
RunnableFuture<SnapshotResult<OperatorStateHandle>> operatorStateRawFuture) |
OperatorSnapshotFutures(RunnableFuture<SnapshotResult<KeyedStateHandle>> keyedStateManagedFuture,
RunnableFuture<SnapshotResult<KeyedStateHandle>> keyedStateRawFuture,
RunnableFuture<SnapshotResult<OperatorStateHandle>> operatorStateManagedFuture,
RunnableFuture<SnapshotResult<OperatorStateHandle>> operatorStateRawFuture) |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.