Package | Description |
---|---|
org.apache.flink.kubernetes.highavailability | |
org.apache.flink.runtime.persistence | |
org.apache.flink.runtime.zookeeper |
Modifier and Type | Method and Description |
---|---|
RetrievableStateHandle<T> |
KubernetesStateHandleStore.addAndLock(String key,
T state)
Creates a state handle, stores it in ConfigMap.
|
Modifier and Type | Method and Description |
---|---|
RetrievableStateHandle<T> |
StateHandleStore.addAndLock(String name,
T state)
Persist the state to distributed storage(e.g.
|
void |
StateHandleStore.replace(String name,
R resourceVersion,
T state)
Replaces a state handle in the distributed coordination system and discards the old state
handle.
|
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.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.