Modifier and Type | Class and Description |
---|---|
class |
RocksDBStateBackend
A State Backend that stores its state in
RocksDB . |
Constructor and Description |
---|
RocksDBStateBackend(AbstractStateBackend checkpointStreamBackend)
Creates a new
RocksDBStateBackend that uses the given state backend to store its
checkpoint data streams. |
RocksDBStateBackend(AbstractStateBackend checkpointStreamBackend,
boolean enableIncrementalCheckpointing)
Creates a new
RocksDBStateBackend that uses the given state backend to store its
checkpoint data streams. |
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 |
MemoryStateBackend
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–2018 The Apache Software Foundation. All rights reserved.