Package | Description |
---|---|
org.apache.flink.contrib.streaming.state | |
org.apache.flink.runtime.state | |
org.apache.flink.runtime.state.filesystem | |
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.runtime.state.memory | |
org.apache.flink.streaming.runtime.tasks |
This package contains classes that realize streaming tasks.
|
Modifier and Type | Method and Description |
---|---|
CheckpointStreamFactory |
RocksDBStateBackend.createSavepointStreamFactory(JobID jobId,
String operatorIdentifier,
String targetLocation) |
CheckpointStreamFactory |
RocksDBStateBackend.createStreamFactory(JobID jobId,
String operatorIdentifier) |
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 |
---|---|
CheckpointStreamFactory |
StateBackend.createSavepointStreamFactory(JobID jobId,
String operatorIdentifier,
String targetLocation)
Creates a
CheckpointStreamFactory that can be used to create streams
that should end up in a savepoint. |
abstract CheckpointStreamFactory |
AbstractStateBackend.createSavepointStreamFactory(JobID jobId,
String operatorIdentifier,
String targetLocation) |
CheckpointStreamFactory |
StateBackend.createStreamFactory(JobID jobId,
String operatorIdentifier)
Creates a
CheckpointStreamFactory that can be used to create streams
that should end up in a checkpoint. |
abstract CheckpointStreamFactory |
AbstractStateBackend.createStreamFactory(JobID jobId,
String operatorIdentifier) |
Modifier and Type | Method and Description |
---|---|
RunnableFuture<OperatorStateHandle> |
DefaultOperatorStateBackend.snapshot(long checkpointId,
long timestamp,
CheckpointStreamFactory streamFactory,
CheckpointOptions checkpointOptions) |
RunnableFuture<S> |
Snapshotable.snapshot(long checkpointId,
long timestamp,
CheckpointStreamFactory streamFactory,
CheckpointOptions checkpointOptions)
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. |
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 . |
class |
FsSavepointStreamFactory
A
CheckpointStreamFactory that produces streams that write to a
FileSystem . |
Modifier and Type | Method and Description |
---|---|
CheckpointStreamFactory |
FsStateBackend.createSavepointStreamFactory(JobID jobId,
String operatorIdentifier,
String targetLocation) |
CheckpointStreamFactory |
FsStateBackend.createStreamFactory(JobID jobId,
String operatorIdentifier) |
Modifier and Type | Method and Description |
---|---|
RunnableFuture<KeyedStateHandle> |
HeapKeyedStateBackend.snapshot(long checkpointId,
long timestamp,
CheckpointStreamFactory streamFactory,
CheckpointOptions checkpointOptions) |
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.createSavepointStreamFactory(JobID jobId,
String operatorIdentifier,
String targetLocation) |
CheckpointStreamFactory |
MemoryStateBackend.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. |
CheckpointStreamFactory |
StreamTask.createSavepointStreamFactory(StreamOperator<?> operator,
String targetLocation) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.