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 | |
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 |
---|---|
KeyedStateHandle |
SubtaskState.getManagedKeyedState() |
KeyedStateHandle |
SubtaskState.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 . |
Collection<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 |
Collection<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(Collection<OperatorStateHandle> managedOperatorState,
Collection<OperatorStateHandle> rawOperatorState,
Collection<KeyedStateHandle> managedKeyedState,
Collection<KeyedStateHandle> rawKeyedState) |
OperatorSubtaskState(Collection<OperatorStateHandle> managedOperatorState,
Collection<OperatorStateHandle> rawOperatorState,
Collection<KeyedStateHandle> managedKeyedState,
Collection<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 |
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.
|
Modifier and Type | Method and Description |
---|---|
RunnableFuture<KeyedStateHandle> |
StateSnapshotContextSynchronousImpl.getKeyedStateStreamFuture() |
Constructor and Description |
---|
StateInitializationContextImpl(boolean restored,
OperatorStateStore operatorStateStore,
KeyedStateStore keyedStateStore,
Collection<KeyedStateHandle> keyedStateHandles,
Collection<OperatorStateHandle> operatorStateHandles,
CloseableRegistry closableRegistry) |
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,
Collection<KeyedStateHandle> managedKeyedState,
Collection<KeyedStateHandle> rawKeyedState,
Collection<OperatorStateHandle> managedOperatorState,
Collection<OperatorStateHandle> rawOperatorState) |
OperatorStateHandles(int operatorChainIndex,
Collection<KeyedStateHandle> managedKeyedState,
Collection<KeyedStateHandle> rawKeyedState,
Collection<OperatorStateHandle> managedOperatorState,
Collection<OperatorStateHandle> rawOperatorState) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.