Package | Description |
---|---|
org.apache.flink.contrib.streaming.state | |
org.apache.flink.runtime.state | |
org.apache.flink.runtime.state.filesystem | |
org.apache.flink.runtime.state.memory | |
org.apache.flink.streaming.api.environment | |
org.apache.flink.streaming.api.graph | |
org.apache.flink.streaming.api.operators | |
org.apache.flink.streaming.api.scala | |
org.apache.flink.streaming.runtime.tasks |
This package contains classes that realize streaming tasks.
|
Modifier and Type | Class and Description |
---|---|
class |
DbStateBackend
AbstractStateBackend for storing checkpoints in JDBC supporting databases. |
class |
RocksDBStateBackend
A
StateBackend that stores its state in RocksDB . |
Constructor and Description |
---|
DbStateBackend(DbBackendConfig backendConfig,
AbstractStateBackend backend)
Create a new
DbStateBackend using the provided
DbBackendConfig configuration and a different backend for storing
non-partitioned state snapshots. |
RocksDBStateBackend(String checkpointDataUri,
AbstractStateBackend nonPartitionedStateBackend) |
RocksDBStateBackend(URI checkpointDataUri,
AbstractStateBackend nonPartitionedStateBackend) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractHeapState<K,N,SV,S extends State,SD extends StateDescriptor<S,?>,Backend extends AbstractStateBackend>
Base class for partitioned
ListState implementations that are backed by a regular
heap hash map. |
class |
AsynchronousKvStateSnapshot<K,N,S extends State,SD extends StateDescriptor<S,?>,Backend extends AbstractStateBackend>
KvStateSnapshot that asynchronously materializes the state that it represents. |
class |
GenericFoldingState<K,N,T,ACC,Backend extends AbstractStateBackend,W extends ValueState<ACC> & KvState<K,N,ValueState<ACC>,ValueStateDescriptor<ACC>,Backend>>
Generic implementation of
FoldingState based on a wrapped ValueState . |
class |
GenericListState<K,N,T,Backend extends AbstractStateBackend,W extends ValueState<ArrayList<T>> & KvState<K,N,ValueState<ArrayList<T>>,ValueStateDescriptor<ArrayList<T>>,Backend>>
Generic implementation of
ListState based on a wrapped ValueState . |
class |
GenericReducingState<K,N,T,Backend extends AbstractStateBackend,W extends ValueState<T> & KvState<K,N,ValueState<T>,ValueStateDescriptor<T>,Backend>>
Generic implementation of
ReducingState based on a wrapped ValueState . |
interface |
KvState<K,N,S extends State,SD extends StateDescriptor<S,?>,Backend extends AbstractStateBackend>
Key/Value state implementation for user-defined state.
|
interface |
KvStateSnapshot<K,N,S extends State,SD extends StateDescriptor<S,?>,Backend extends AbstractStateBackend>
This class represents a snapshot of the
KvState , taken for a checkpoint. |
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 |
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 |
AbstractStreamOperator.getStateBackend() |
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 |
StreamTask.createStateBackend(String operatorIdentifier,
TypeSerializer<?> keySerializer) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.