Modifier and Type | Class and Description |
---|---|
class |
RocksDBStateBackend
A
StateBackend that stores its state in RocksDB . |
Modifier and Type | Method and Description |
---|---|
AbstractStateBackend |
RocksDBStateBackendFactory.createFromConfig(Configuration config) |
Constructor and Description |
---|
RocksDBStateBackend(AbstractStateBackend checkpointStreamBackend)
Creates a new
RocksDBStateBackend that uses the given state backend to store its
checkpoint data streams. |
Modifier and Type | Interface and Description |
---|---|
interface |
StateBackendFactory<T extends AbstractStateBackend>
A factory to create a specific state backend.
|
Modifier and Type | Method and Description |
---|---|
AbstractStateBackend |
StateBackendFactory.createFromConfig(Configuration config)
Creates the state backend, optionally using the given configuration.
|
Modifier and Type | Class and Description |
---|---|
class |
FsStateBackend
The file state backend is a state backend that stores the state of streaming jobs in a file system.
|
Modifier and Type | Class and Description |
---|---|
class |
AsyncFsStateBackend
The file state backend is a state backend that stores the state of streaming jobs in a file system.
|
Modifier and Type | Class and Description |
---|---|
class |
MemoryStateBackend
A
AbstractStateBackend that stores all its data and checkpoints in memory and has no
capabilities to spill to disk. |
Modifier and Type | Class and Description |
---|---|
class |
AsyncMemoryStateBackend
A
AbstractStateBackend that stores all its data and checkpoints in memory and has no
capabilities to spill to disk. |
Modifier and Type | Method and Description |
---|---|
AbstractStateBackend |
StreamExecutionEnvironment.getStateBackend()
Returns the state backend that defines how to store and checkpoint state.
|
Modifier and Type | Method and Description |
---|---|
StreamExecutionEnvironment |
StreamExecutionEnvironment.setStateBackend(AbstractStateBackend backend)
Sets the state backend that describes how to store and checkpoint operator state.
|
Modifier and Type | Method and Description |
---|---|
AbstractStateBackend |
StreamGraph.getStateBackend() |
AbstractStateBackend |
StreamConfig.getStateBackend(ClassLoader cl) |
Modifier and Type | Method and Description |
---|---|
void |
StreamGraph.setStateBackend(AbstractStateBackend backend) |
void |
StreamConfig.setStateBackend(AbstractStateBackend backend) |
Modifier and Type | Method and Description |
---|---|
AbstractStateBackend |
StreamExecutionEnvironment.getStateBackend()
Returns the state backend that defines how to store and checkpoint state.
|
Modifier and Type | Method and Description |
---|---|
StreamExecutionEnvironment |
StreamExecutionEnvironment.setStateBackend(AbstractStateBackend backend)
Sets the state backend that describes how to store and checkpoint operator state.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.