Package | Description |
---|---|
org.apache.flink.runtime.persistence | |
org.apache.flink.runtime.zookeeper |
Modifier and Type | Method and Description |
---|---|
static IntegerResourceVersion |
IntegerResourceVersion.notExisting() |
static IntegerResourceVersion |
IntegerResourceVersion.valueOf(int value)
Create a
IntegerResourceVersion with given integer value. |
Modifier and Type | Method and Description |
---|---|
int |
IntegerResourceVersion.compareTo(IntegerResourceVersion other) |
Modifier and Type | Method and Description |
---|---|
IntegerResourceVersion |
ZooKeeperStateHandleStore.exists(String pathInZooKeeper)
Returns the version of the node if it exists or
-1 if it doesn't. |
Modifier and Type | Method and Description |
---|---|
void |
ZooKeeperStateHandleStore.replace(String pathInZooKeeper,
IntegerResourceVersion expectedVersion,
T state)
Replaces a state handle in ZooKeeper and discards the old state handle.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.