Package | Description |
---|---|
org.apache.flink.contrib.streaming.state | |
org.apache.flink.migration | |
org.apache.flink.migration.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 | |
org.apache.flink.streaming.runtime.tasks |
This package contains classes that realize streaming tasks.
|
Modifier and Type | Method and Description |
---|---|
RunnableFuture<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 |
---|---|
static boolean |
MigrationUtil.isOldSavepointKeyedState(Collection<KeyedStateHandle> keyedStateHandles) |
Modifier and Type | Class and Description |
---|---|
class |
MigrationKeyGroupStateHandle
Deprecated.
Internal class for savepoint backwards compatibility. Don't use for other purposes.
|
Modifier and Type | Method and Description |
---|---|
KeyedStateHandle |
SubtaskState.getManagedKeyedState() |
KeyedStateHandle |
OperatorSubtaskState.getManagedKeyedState() |
KeyedStateHandle |
SubtaskState.getRawKeyedState() |
KeyedStateHandle |
OperatorSubtaskState.getRawKeyedState() |
Modifier and Type | Method and Description |
---|---|
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 . |
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 |
---|---|
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 . |
Constructor and Description |
---|
OperatorSubtaskState(StreamStateHandle legacyOperatorState,
OperatorStateHandle managedOperatorState,
OperatorStateHandle rawOperatorState,
KeyedStateHandle managedKeyedState,
KeyedStateHandle rawKeyedState) |
SubtaskState(ChainedStateHandle<StreamStateHandle> legacyOperatorState,
ChainedStateHandle<OperatorStateHandle> managedOperatorState,
ChainedStateHandle<OperatorStateHandle> rawOperatorState,
KeyedStateHandle managedKeyedState,
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 |
IncrementalKeyedStateHandle
The handle to states of an incremental snapshot.
|
class |
KeyGroupsStateHandle
A handle to the partitioned stream operator state after it has been checkpointed.
|
Modifier and Type | Method and Description |
---|---|
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 |
IncrementalKeyedStateHandle.getIntersection(KeyGroupRange keyGroupRange) |
Modifier and Type | Method and Description |
---|---|
RunnableFuture<KeyedStateHandle> |
StateSnapshotContextSynchronousImpl.getKeyedStateStreamFuture() |
Collection<KeyedStateHandle> |
TaskStateHandles.getManagedKeyedState() |
Collection<KeyedStateHandle> |
TaskStateHandles.getRawKeyedState() |
Constructor and Description |
---|
StateInitializationContextImpl(boolean restored,
OperatorStateStore operatorStateStore,
KeyedStateStore keyedStateStore,
Collection<KeyedStateHandle> keyedStateHandles,
Collection<OperatorStateHandle> operatorStateHandles,
CloseableRegistry closableRegistry) |
TaskStateHandles(ChainedStateHandle<StreamStateHandle> legacyOperatorState,
List<Collection<OperatorStateHandle>> managedOperatorState,
List<Collection<OperatorStateHandle>> rawOperatorState,
Collection<KeyedStateHandle> managedKeyedState,
Collection<KeyedStateHandle> rawKeyedState) |
TaskStateHandles(ChainedStateHandle<StreamStateHandle> legacyOperatorState,
List<Collection<OperatorStateHandle>> managedOperatorState,
List<Collection<OperatorStateHandle>> rawOperatorState,
Collection<KeyedStateHandle> managedKeyedState,
Collection<KeyedStateHandle> rawKeyedState) |
Modifier and Type | Method and Description |
---|---|
RunnableFuture<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<KeyedStateHandle> |
OperatorSnapshotResult.getKeyedStateManagedFuture() |
RunnableFuture<KeyedStateHandle> |
OperatorSnapshotResult.getKeyedStateRawFuture() |
Modifier and Type | Method and Description |
---|---|
void |
OperatorSnapshotResult.setKeyedStateManagedFuture(RunnableFuture<KeyedStateHandle> keyedStateManagedFuture) |
void |
OperatorSnapshotResult.setKeyedStateRawFuture(RunnableFuture<KeyedStateHandle> keyedStateRawFuture) |
Constructor and Description |
---|
OperatorSnapshotResult(RunnableFuture<KeyedStateHandle> keyedStateManagedFuture,
RunnableFuture<KeyedStateHandle> keyedStateRawFuture,
RunnableFuture<OperatorStateHandle> operatorStateManagedFuture,
RunnableFuture<OperatorStateHandle> operatorStateRawFuture) |
OperatorSnapshotResult(RunnableFuture<KeyedStateHandle> keyedStateManagedFuture,
RunnableFuture<KeyedStateHandle> keyedStateRawFuture,
RunnableFuture<OperatorStateHandle> operatorStateManagedFuture,
RunnableFuture<OperatorStateHandle> operatorStateRawFuture) |
Modifier and Type | Method and Description |
---|---|
Collection<KeyedStateHandle> |
OperatorStateHandles.getManagedKeyedState() |
Collection<KeyedStateHandle> |
OperatorStateHandles.getRawKeyedState() |
Constructor and Description |
---|
OperatorStateHandles(int operatorChainIndex,
StreamStateHandle legacyOperatorState,
Collection<KeyedStateHandle> managedKeyedState,
Collection<KeyedStateHandle> rawKeyedState,
Collection<OperatorStateHandle> managedOperatorState,
Collection<OperatorStateHandle> rawOperatorState) |
OperatorStateHandles(int operatorChainIndex,
StreamStateHandle legacyOperatorState,
Collection<KeyedStateHandle> managedKeyedState,
Collection<KeyedStateHandle> rawKeyedState,
Collection<OperatorStateHandle> managedOperatorState,
Collection<OperatorStateHandle> rawOperatorState) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.