Class ReadOnlyZKClient.ZKTask<T>
java.lang.Object
org.apache.hadoop.hbase.zookeeper.ReadOnlyZKClient.Task
org.apache.hadoop.hbase.zookeeper.ReadOnlyZKClient.ZKTask<T>
- All Implemented Interfaces:
Comparable<Delayed>
,Delayed
- Enclosing class:
- ReadOnlyZKClient
-
Field Summary
Modifier and TypeFieldDescriptionprivate final CompletableFuture<T>
private final String
protected final String
private int
Fields inherited from class org.apache.hadoop.hbase.zookeeper.ReadOnlyZKClient.Task
time
-
Constructor Summary
ModifierConstructorDescriptionprotected
ZKTask
(String path, CompletableFuture<T> future, String operationType) -
Method Summary
Modifier and TypeMethodDescriptionvoid
void
boolean
delay
(long intervalMs, int maxRetries) protected abstract void
doExec
(org.apache.zookeeper.ZooKeeper zk) final void
exec
(org.apache.zookeeper.ZooKeeper zk) boolean
needZk()
protected final void
onComplete
(org.apache.zookeeper.ZooKeeper zk, int rc, T ret, boolean errorIfNoNode) Methods inherited from class org.apache.hadoop.hbase.zookeeper.ReadOnlyZKClient.Task
compareTo, getDelay
-
Field Details
-
path
-
future
-
operationType
-
retries
-
-
Constructor Details
-
ZKTask
-
-
Method Details
-
onComplete
protected final void onComplete(org.apache.zookeeper.ZooKeeper zk, int rc, T ret, boolean errorIfNoNode) -
needZk
- Overrides:
needZk
in classReadOnlyZKClient.Task
-
doExec
-
exec
- Overrides:
exec
in classReadOnlyZKClient.Task
-
delay
-
connectFailed
- Overrides:
connectFailed
in classReadOnlyZKClient.Task
-
closed
- Overrides:
closed
in classReadOnlyZKClient.Task
-