Package | Description |
---|---|
org.apache.flink.kubernetes.highavailability | |
org.apache.flink.runtime.persistence |
Modifier and Type | Method and Description |
---|---|
StringResourceVersion |
KubernetesStateHandleStore.exists(String key)
Returns the resource version of the ConfigMap.
|
Modifier and Type | Method and Description |
---|---|
void |
KubernetesStateHandleStore.replace(String key,
StringResourceVersion resourceVersion,
T state)
Replaces a state handle in ConfigMap and discards the old state handle.
|
Modifier and Type | Method and Description |
---|---|
static StringResourceVersion |
StringResourceVersion.notExisting() |
static StringResourceVersion |
StringResourceVersion.valueOf(String value) |
Modifier and Type | Method and Description |
---|---|
int |
StringResourceVersion.compareTo(StringResourceVersion other) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.