Package | Description |
---|---|
org.apache.flink.contrib.streaming.state | |
org.apache.flink.runtime.state | |
org.apache.flink.runtime.state.filesystem | |
org.apache.flink.runtime.state.filesystem.async | |
org.apache.flink.runtime.state.heap | |
org.apache.flink.runtime.state.heap.async | |
org.apache.flink.runtime.state.memory | |
org.apache.flink.runtime.state.memory.async | |
org.apache.flink.streaming.runtime.tasks |
This package contains classes that realize streaming tasks.
|
Modifier and Type | Method and Description |
---|---|
CheckpointStreamFactory |
RocksDBStateBackend.createStreamFactory(JobID jobId,
String operatorIdentifier) |
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 |
---|---|
abstract CheckpointStreamFactory |
AbstractStateBackend.createStreamFactory(JobID jobId,
String operatorIdentifier)
Creates a
CheckpointStreamFactory that can be used to create streams
that should end up in a checkpoint. |
Modifier and Type | Method and Description |
---|---|
RunnableFuture<S> |
Snapshotable.snapshot(long checkpointId,
long timestamp,
CheckpointStreamFactory streamFactory)
Operation that writes a snapshot into a stream that is provided by the given
CheckpointStreamFactory and
returns a @RunnableFuture that gives a state handle to the snapshot. |
RunnableFuture<OperatorStateHandle> |
DefaultOperatorStateBackend.snapshot(long checkpointId,
long timestamp,
CheckpointStreamFactory streamFactory) |
Constructor and Description |
---|
StateSnapshotContextSynchronousImpl(long checkpointId,
long checkpointTimestamp,
CheckpointStreamFactory streamFactory,
KeyGroupRange keyGroupRange,
CloseableRegistry closableRegistry) |
Modifier and Type | Class and Description |
---|---|
class |
FsCheckpointStreamFactory
CheckpointStreamFactory that produces streams that
write to a FileSystem . |
Modifier and Type | Method and Description |
---|---|
CheckpointStreamFactory |
FsStateBackend.createStreamFactory(JobID jobId,
String operatorIdentifier) |
Modifier and Type | Method and Description |
---|---|
CheckpointStreamFactory |
AsyncFsStateBackend.createStreamFactory(JobID jobId,
String operatorIdentifier) |
Modifier and Type | Method and Description |
---|---|
RunnableFuture<KeyGroupsStateHandle> |
HeapKeyedStateBackend.snapshot(long checkpointId,
long timestamp,
CheckpointStreamFactory streamFactory) |
Modifier and Type | Method and Description |
---|---|
RunnableFuture<KeyGroupsStateHandle> |
AsyncHeapKeyedStateBackend.snapshot(long checkpointId,
long timestamp,
CheckpointStreamFactory streamFactory) |
Modifier and Type | Class and Description |
---|---|
class |
MemCheckpointStreamFactory
CheckpointStreamFactory that produces streams that write to in-memory byte arrays. |
Modifier and Type | Method and Description |
---|---|
CheckpointStreamFactory |
MemoryStateBackend.createStreamFactory(JobID jobId,
String operatorIdentifier) |
Modifier and Type | Method and Description |
---|---|
CheckpointStreamFactory |
AsyncMemoryStateBackend.createStreamFactory(JobID jobId,
String operatorIdentifier) |
Modifier and Type | Method and Description |
---|---|
CheckpointStreamFactory |
StreamTask.createCheckpointStreamFactory(StreamOperator<?> operator)
This is only visible because
GenericWriteAheadSink uses the
checkpoint stream factory to write write-ahead logs. |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.