Modifier and Type | Method and Description |
---|---|
RetrievableStateHandle<T> |
KubernetesStateHandleStore.addAndLock(String key,
T state)
Creates a state handle, stores it in ConfigMap.
|
RetrievableStateHandle<T> |
KubernetesStateHandleStore.getAndLock(String key)
Gets the
RetrievableStateHandle stored in the given ConfigMap. |
Modifier and Type | Method and Description |
---|---|
List<Tuple2<RetrievableStateHandle<T>,String>> |
KubernetesStateHandleStore.getAllAndLock()
Gets all available state handles from Kubernetes.
|
Modifier and Type | Method and Description |
---|---|
RetrievableStateHandle<T> |
StateHandleStore.addAndLock(String name,
T state)
Persist the state to distributed storage(e.g.
|
RetrievableStateHandle<T> |
StateHandleStore.getAndLock(String name)
Gets the
RetrievableStateHandle stored with the given name. |
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>> |
StateHandleStore.getAllAndLock()
Gets all available state handles from the storage.
|
Modifier and Type | Method and Description |
---|---|
RetrievableStateHandle<T> |
FileSystemStateStorageHelper.store(T state) |
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. |
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.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.