public static interface ZooKeeperStateHandleStore.RemoveCallback<T extends Serializable>
Modifier and Type | Method and Description |
---|---|
void |
apply(RetrievableStateHandle<T> value)
Callback method.
|
void apply(@Nullable RetrievableStateHandle<T> value) throws FlinkException
RetrievableStateHandle
could not be retrieved
from ZooKeeper.value
- RetrievableStateHandle retrieved from ZooKeeper, null if it was not retrievableFlinkException
- If the callback failedCopyright © 2014–2018 The Apache Software Foundation. All rights reserved.