Package | Description |
---|---|
org.apache.flink.runtime.state.filesystem |
Modifier and Type | Method and Description |
---|---|
FsStateBackend |
FsStateBackendFactory.createFromConfig(Configuration config) |
Constructor and Description |
---|
AbstractFsState(FsStateBackend backend,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<SV> stateSerializer,
SD stateDesc) |
AbstractFsState(FsStateBackend backend,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<SV> stateSerializer,
SD stateDesc,
HashMap<N,Map<K,SV>> state) |
FsFoldingState(FsStateBackend backend,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
FoldingStateDescriptor<T,ACC> stateDesc)
Creates a new and empty partitioned state.
|
FsFoldingState(FsStateBackend backend,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
FoldingStateDescriptor<T,ACC> stateDesc,
HashMap<N,Map<K,ACC>> state)
Creates a new key/value state with the given state contents.
|
FsListState(FsStateBackend backend,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
ListStateDescriptor<V> stateDesc)
Creates a new and empty partitioned state.
|
FsListState(FsStateBackend backend,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
ListStateDescriptor<V> stateDesc,
HashMap<N,Map<K,ArrayList<V>>> state)
Creates a new key/value state with the given state contents.
|
FsReducingState(FsStateBackend backend,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
ReducingStateDescriptor<V> stateDesc)
Creates a new and empty partitioned state.
|
FsReducingState(FsStateBackend backend,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
ReducingStateDescriptor<V> stateDesc,
HashMap<N,Map<K,V>> state)
Creates a new key/value state with the given state contents.
|
FsValueState(FsStateBackend backend,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
ValueStateDescriptor<V> stateDesc)
Creates a new and empty key/value state.
|
FsValueState(FsStateBackend backend,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
ValueStateDescriptor<V> stateDesc,
HashMap<N,Map<K,V>> state)
Creates a new key/value state with the given state contents.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.