Package | Description |
---|---|
org.apache.flink.contrib.streaming.state | |
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 |
---|---|
SnapshotResult<StreamStateHandle> |
CheckpointStreamWithResultProvider.closeAndFinalizeCheckpointStreamResult()
Closes the stream ans returns a snapshot result with the stream handle(s).
|
SnapshotResult<StreamStateHandle> |
CheckpointStreamWithResultProvider.PrimaryStreamOnly.closeAndFinalizeCheckpointStreamResult() |
SnapshotResult<StreamStateHandle> |
CheckpointStreamWithResultProvider.PrimaryAndSecondaryStream.closeAndFinalizeCheckpointStreamResult() |
static <T extends StateObject> |
SnapshotResult.empty() |
static <T extends StateObject> |
SnapshotResult.of(T jobManagerState) |
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. |
static <T extends StateObject> |
SnapshotResult.withLocalState(T jobManagerState,
T localState) |
Modifier and Type | Method and Description |
---|---|
RunnableFuture<SnapshotResult<KeyedStateHandle>> |
StateSnapshotContextSynchronousImpl.getKeyedStateStreamFuture() |
RunnableFuture<SnapshotResult<OperatorStateHandle>> |
StateSnapshotContextSynchronousImpl.getOperatorStateStreamFuture() |
RunnableFuture<SnapshotResult<OperatorStateHandle>> |
DefaultOperatorStateBackend.snapshot(long checkpointId,
long timestamp,
CheckpointStreamFactory streamFactory,
CheckpointOptions checkpointOptions) |
Modifier and Type | Method and Description |
---|---|
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 |
---|---|
RunnableFuture<SnapshotResult<KeyedStateHandle>> |
OperatorSnapshotFutures.getKeyedStateManagedFuture() |
RunnableFuture<SnapshotResult<KeyedStateHandle>> |
OperatorSnapshotFutures.getKeyedStateRawFuture() |
RunnableFuture<SnapshotResult<OperatorStateHandle>> |
OperatorSnapshotFutures.getOperatorStateManagedFuture() |
RunnableFuture<SnapshotResult<OperatorStateHandle>> |
OperatorSnapshotFutures.getOperatorStateRawFuture() |
Modifier and Type | Method and Description |
---|---|
void |
OperatorSnapshotFutures.setKeyedStateManagedFuture(RunnableFuture<SnapshotResult<KeyedStateHandle>> keyedStateManagedFuture) |
void |
OperatorSnapshotFutures.setKeyedStateRawFuture(RunnableFuture<SnapshotResult<KeyedStateHandle>> keyedStateRawFuture) |
void |
OperatorSnapshotFutures.setOperatorStateManagedFuture(RunnableFuture<SnapshotResult<OperatorStateHandle>> operatorStateManagedFuture) |
void |
OperatorSnapshotFutures.setOperatorStateRawFuture(RunnableFuture<SnapshotResult<OperatorStateHandle>> operatorStateRawFuture) |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.