Package 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	Description
private final CompletableFuture<T>	future
private final String	operationType
protected final String	path
private int	retries

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

time

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	closed(IOException e)
void	connectFailed(Exception e)
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

Methods inherited from class java.lang.Object

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

Field Details

path

protected final String path

future

private final CompletableFuture<T> future

operationType

private final String operationType

retries

private int retries

Constructor Details

ZKTask

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

Method Details

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(Exception e)

Overrides:

connectFailed in class ReadOnlyZKClient.Task

closed

public void closed(IOException e)

Overrides:

closed in class ReadOnlyZKClient.Task