Modifier and Type | Method and Description |
---|---|
RunnableFuture<KeyGroupsStateHandle> |
RocksDBKeyedStateBackend.snapshot(long checkpointId,
long timestamp,
CheckpointStreamFactory streamFactory)
Triggers an asynchronous snapshot of the keyed state backend from RocksDB.
|
Modifier and Type | Method and Description |
---|---|
void |
RocksDBKeyedStateBackend.restore(Collection<KeyGroupsStateHandle> restoreState) |
Modifier and Type | Method and Description |
---|---|
static boolean |
MigrationUtil.isOldSavepointKeyedState(Collection<KeyGroupsStateHandle> keyGroupsStateHandles) |
Modifier and Type | Method and Description |
---|---|
static KeyGroupsStateHandle |
SavepointV0Serializer.convertKeyedBackendState(HashMap<String,KvStateSnapshot<?,?,?,?>> oldKeyedState,
int parallelInstanceIdx,
long checkpointID)
This is public so that we can use it when restoring a legacy snapshot
in
AbstractStreamOperatorTestHarness . |
Modifier and Type | Class and Description |
---|---|
class |
MigrationKeyGroupStateHandle
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
KeyGroupsStateHandle |
SubtaskState.getManagedKeyedState() |
KeyGroupsStateHandle |
SubtaskState.getRawKeyedState() |
Modifier and Type | Method and Description |
---|---|
static List<KeyGroupsStateHandle> |
StateAssignmentOperation.getKeyGroupsStateHandles(Collection<KeyGroupsStateHandle> allKeyGroupsHandles,
KeyGroupRange subtaskKeyGroupIds)
Determine the subset of
KeyGroupsStateHandles with correct
key group index for the given subtask KeyGroupRange . |
Modifier and Type | Method and Description |
---|---|
static List<KeyGroupsStateHandle> |
StateAssignmentOperation.getKeyGroupsStateHandles(Collection<KeyGroupsStateHandle> allKeyGroupsHandles,
KeyGroupRange subtaskKeyGroupIds)
Determine the subset of
KeyGroupsStateHandles with correct
key group index for the given subtask KeyGroupRange . |
Constructor and Description |
---|
SubtaskState(ChainedStateHandle<StreamStateHandle> legacyOperatorState,
ChainedStateHandle<OperatorStateHandle> managedOperatorState,
ChainedStateHandle<OperatorStateHandle> rawOperatorState,
KeyGroupsStateHandle managedKeyedState,
KeyGroupsStateHandle rawKeyedState) |
Modifier and Type | Method and Description |
---|---|
static KeyGroupsStateHandle |
SavepointV1Serializer.deserializeKeyGroupStateHandle(DataInputStream dis) |
Modifier and Type | Method and Description |
---|---|
static void |
SavepointV1Serializer.serializeKeyGroupStateHandle(KeyGroupsStateHandle stateHandle,
DataOutputStream dos) |
Modifier and Type | Method and Description |
---|---|
KeyGroupsStateHandle |
KeyGroupsStateHandle.getKeyGroupIntersection(KeyGroupRange keyGroupRange) |
Modifier and Type | Method and Description |
---|---|
RunnableFuture<KeyGroupsStateHandle> |
StateSnapshotContextSynchronousImpl.getKeyedStateStreamFuture() |
Collection<KeyGroupsStateHandle> |
StateInitializationContextImpl.getKeyGroupsStateHandles() |
Collection<KeyGroupsStateHandle> |
TaskStateHandles.getManagedKeyedState() |
Collection<KeyGroupsStateHandle> |
TaskStateHandles.getRawKeyedState() |
Constructor and Description |
---|
StateInitializationContextImpl(boolean restored,
OperatorStateStore operatorStateStore,
KeyedStateStore keyedStateStore,
Collection<KeyGroupsStateHandle> keyGroupsStateHandles,
Collection<OperatorStateHandle> operatorStateHandles,
CloseableRegistry closableRegistry) |
TaskStateHandles(ChainedStateHandle<StreamStateHandle> legacyOperatorState,
List<Collection<OperatorStateHandle>> managedOperatorState,
List<Collection<OperatorStateHandle>> rawOperatorState,
Collection<KeyGroupsStateHandle> managedKeyedState,
Collection<KeyGroupsStateHandle> rawKeyedState) |
TaskStateHandles(ChainedStateHandle<StreamStateHandle> legacyOperatorState,
List<Collection<OperatorStateHandle>> managedOperatorState,
List<Collection<OperatorStateHandle>> rawOperatorState,
Collection<KeyGroupsStateHandle> managedKeyedState,
Collection<KeyGroupsStateHandle> rawKeyedState) |
Modifier and Type | Method and Description |
---|---|
RunnableFuture<KeyGroupsStateHandle> |
HeapKeyedStateBackend.snapshot(long checkpointId,
long timestamp,
CheckpointStreamFactory streamFactory) |
Modifier and Type | Method and Description |
---|---|
void |
HeapKeyedStateBackend.restore(Collection<KeyGroupsStateHandle> restoredState) |
Modifier and Type | Method and Description |
---|---|
RunnableFuture<KeyGroupsStateHandle> |
AsyncHeapKeyedStateBackend.snapshot(long checkpointId,
long timestamp,
CheckpointStreamFactory streamFactory) |
Modifier and Type | Method and Description |
---|---|
void |
AsyncHeapKeyedStateBackend.restore(Collection<KeyGroupsStateHandle> restoredState) |
Modifier and Type | Method and Description |
---|---|
RunnableFuture<KeyGroupsStateHandle> |
OperatorSnapshotResult.getKeyedStateManagedFuture() |
RunnableFuture<KeyGroupsStateHandle> |
OperatorSnapshotResult.getKeyedStateRawFuture() |
Modifier and Type | Method and Description |
---|---|
void |
OperatorSnapshotResult.setKeyedStateManagedFuture(RunnableFuture<KeyGroupsStateHandle> keyedStateManagedFuture) |
void |
OperatorSnapshotResult.setKeyedStateRawFuture(RunnableFuture<KeyGroupsStateHandle> keyedStateRawFuture) |
Constructor and Description |
---|
OperatorSnapshotResult(RunnableFuture<KeyGroupsStateHandle> keyedStateManagedFuture,
RunnableFuture<KeyGroupsStateHandle> keyedStateRawFuture,
RunnableFuture<OperatorStateHandle> operatorStateManagedFuture,
RunnableFuture<OperatorStateHandle> operatorStateRawFuture) |
OperatorSnapshotResult(RunnableFuture<KeyGroupsStateHandle> keyedStateManagedFuture,
RunnableFuture<KeyGroupsStateHandle> keyedStateRawFuture,
RunnableFuture<OperatorStateHandle> operatorStateManagedFuture,
RunnableFuture<OperatorStateHandle> operatorStateRawFuture) |
Modifier and Type | Method and Description |
---|---|
Collection<KeyGroupsStateHandle> |
OperatorStateHandles.getManagedKeyedState() |
Collection<KeyGroupsStateHandle> |
OperatorStateHandles.getRawKeyedState() |
Constructor and Description |
---|
OperatorStateHandles(int operatorChainIndex,
StreamStateHandle legacyOperatorState,
Collection<KeyGroupsStateHandle> managedKeyedState,
Collection<KeyGroupsStateHandle> rawKeyedState,
Collection<OperatorStateHandle> managedOperatorState,
Collection<OperatorStateHandle> rawOperatorState) |
OperatorStateHandles(int operatorChainIndex,
StreamStateHandle legacyOperatorState,
Collection<KeyGroupsStateHandle> managedKeyedState,
Collection<KeyGroupsStateHandle> rawKeyedState,
Collection<OperatorStateHandle> managedOperatorState,
Collection<OperatorStateHandle> rawOperatorState) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.