Package | Description |
---|---|
org.apache.flink.runtime.state | |
org.apache.flink.runtime.zookeeper | |
org.apache.flink.runtime.zookeeper.filesystem |
Modifier and Type | Class and Description |
---|---|
class |
RetrievableStreamStateHandle<T extends Serializable>
Wrapper around a
StreamStateHandle to make the referenced state object retrievable trough a simple get call. |
Modifier and Type | Method and Description |
---|---|
RetrievableStateHandle<T> |
ZooKeeperStateHandleStore.add(String pathInZooKeeper,
T state)
Creates a state handle and stores it in ZooKeeper with create mode
CreateMode.PERSISTENT . |
RetrievableStateHandle<T> |
ZooKeeperStateHandleStore.add(String pathInZooKeeper,
T state,
org.apache.zookeeper.CreateMode createMode)
Creates a state handle and stores it in ZooKeeper.
|
RetrievableStateHandle<T> |
ZooKeeperStateHandleStore.get(String pathInZooKeeper)
Gets a state handle from ZooKeeper.
|
RetrievableStateHandle<T> |
RetrievableStateStorageHelper.store(T state)
Stores the given state and returns a state handle to it.
|
Modifier and Type | Method and Description |
---|---|
List<Tuple2<RetrievableStateHandle<T>,String>> |
ZooKeeperStateHandleStore.getAll()
Gets all available state handles from ZooKeeper.
|
List<Tuple2<RetrievableStateHandle<T>,String>> |
ZooKeeperStateHandleStore.getAllSortedByName()
Gets all available state handles from ZooKeeper sorted by name (ascending).
|
Modifier and Type | Method and Description |
---|---|
RetrievableStateHandle<T> |
FileSystemStateStorageHelper.store(T state) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.