org.apache.hadoop.hbase.zookeeper

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

private abstract class ReadOnlyZKClient.ZKTask<T>
extends ReadOnlyZKClient.Task

Field Summary

Fields

Modifier and Type	Field and Description
private CompletableFuture<T>	future
private String	operationType
protected String	path
private int	retries

Fields inherited from class org.apache.hadoop.hbase.zookeeper.ReadOnlyZKClient.Task

time

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ZKTask(String path, CompletableFuture<T> future, String operationType)

Method Summary

Modifier and Type	Method and Description
void	closed(IOException e)
void	connectFailed(IOException e)
boolean	delay(long intervalMs, int maxRetries)
protected abstract void	doExec(org.apache.zookeeper.ZooKeeper zk)
void	exec(org.apache.zookeeper.ZooKeeper zk)
boolean	needZk()
protected 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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

path

protected final String path

future

private final CompletableFuture<T> future

operationType

private final String operationType

retries

private int retries

Constructor Detail

ZKTask

protected ZKTask(String path,
                 CompletableFuture<T> future,
                 String operationType)

Method Detail

onComplete

protected final void onComplete(org.apache.zookeeper.ZooKeeper zk,
                                int rc,
                                T ret,
                                boolean errorIfNoNode)

needZk

public boolean needZk()

Overrides:

needZk in class ReadOnlyZKClient.Task

doExec

protected abstract void doExec(org.apache.zookeeper.ZooKeeper zk)

exec

public final void exec(org.apache.zookeeper.ZooKeeper zk)

Overrides:

exec in class ReadOnlyZKClient.Task

delay

public boolean delay(long intervalMs,
                     int maxRetries)

connectFailed

public void connectFailed(IOException e)

Overrides:

connectFailed in class ReadOnlyZKClient.Task

closed

public void closed(IOException e)

Overrides:

closed in class ReadOnlyZKClient.Task