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.addAndLock(String pathInZooKeeper,
T state)
Creates a state handle, stores it in ZooKeeper and locks it.
|
RetrievableStateHandle<T> |
ZooKeeperStateHandleStore.getAndLock(String pathInZooKeeper)
Gets the
RetrievableStateHandle stored in the given ZooKeeper node and locks it. |
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.getAllAndLock()
Gets all available state handles from ZooKeeper and locks the respective state nodes.
|
List<Tuple2<RetrievableStateHandle<T>,String>> |
ZooKeeperStateHandleStore.getAllSortedByNameAndLock()
Gets all available state handles from ZooKeeper sorted by name (ascending) and locks the
respective state nodes.
|
Modifier and Type | Method and Description |
---|---|
RetrievableStateHandle<T> |
FileSystemStateStorageHelper.store(T state) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.