Package org.apache.hadoop.hbase.zookeeper

Class ReadOnlyZKClient

java.lang.Object

org.apache.hadoop.hbase.zookeeper.ReadOnlyZKClient

All Implemented Interfaces:

Closeable, AutoCloseable

@Private
public final class ReadOnlyZKClient
extends Object
implements Closeable

A very simple read only zookeeper implementation without watcher support.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	ReadOnlyZKClient.Task
private class	ReadOnlyZKClient.ZKTask<T>

Field Summary

Fields

Modifier and Type	Field	Description
private static final ReadOnlyZKClient.Task	CLOSE
private final AtomicBoolean	closed
private final String	connectString
private static final int	DEFAULT_KEEPALIVE_MILLIS
private static final int	DEFAULT_RECOVERY_RETRY
private static final int	DEFAULT_RECOVERY_RETRY_INTERVAL_MILLIS
private static final EnumSet<org.apache.zookeeper.KeeperException.Code>	FAIL_FAST_CODES
static final String	KEEPALIVE_MILLIS
private final int	keepAliveTimeMs
private static final org.slf4j.Logger	LOG
private final int	maxRetries
private int	pendingRequests
static final String	RECOVERY_RETRY
static final String	RECOVERY_RETRY_INTERVAL_MILLIS
private final int	retryIntervalMs
private org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer	retryTimer
private final int	sessionTimeoutMs
private final DelayQueue<ReadOnlyZKClient.Task>	tasks
private final org.apache.zookeeper.client.ZKClientConfig	zkClientConfig
(package private) org.apache.zookeeper.ZooKeeper	zookeeper

Constructor Summary

Constructors

Constructor	Description
ReadOnlyZKClient(org.apache.hadoop.conf.Configuration conf, org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer retryTimer)

Method Summary

Modifier and Type	Method	Description
void	close()
private void	closeZk()
CompletableFuture<org.apache.zookeeper.data.Stat>	exists(String path)
CompletableFuture<org.apache.zookeeper.data.Stat>	exists(String path, long timeoutMs)
CompletableFuture<byte[]>	get(String path)
CompletableFuture<byte[]>	get(String path, long timeoutMs)
String	getConnectString()
private String	getId()
private static org.apache.hbase.thirdparty.io.netty.util.TimerTask	getTimerTask(long timeoutMs, CompletableFuture<?> future, String api)
private org.apache.zookeeper.ZooKeeper	getZk()
CompletableFuture<List<String>>	list(String path)
CompletableFuture<List<String>>	list(String path, long timeoutMs)
private void	run()

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

RECOVERY_RETRY

public static final String RECOVERY_RETRY

See Also:

• Constant Field Values

DEFAULT_RECOVERY_RETRY

private static final int DEFAULT_RECOVERY_RETRY

See Also:

• Constant Field Values

RECOVERY_RETRY_INTERVAL_MILLIS

public static final String RECOVERY_RETRY_INTERVAL_MILLIS

See Also:

• Constant Field Values

DEFAULT_RECOVERY_RETRY_INTERVAL_MILLIS

private static final int DEFAULT_RECOVERY_RETRY_INTERVAL_MILLIS

See Also:

• Constant Field Values

KEEPALIVE_MILLIS

public static final String KEEPALIVE_MILLIS

See Also:

• Constant Field Values

DEFAULT_KEEPALIVE_MILLIS

private static final int DEFAULT_KEEPALIVE_MILLIS

See Also:

• Constant Field Values

FAIL_FAST_CODES

private static final EnumSet<org.apache.zookeeper.KeeperException.Code> FAIL_FAST_CODES

connectString

private final String connectString

sessionTimeoutMs

private final int sessionTimeoutMs

maxRetries

private final int maxRetries

retryIntervalMs

private final int retryIntervalMs

keepAliveTimeMs

private final int keepAliveTimeMs

retryTimer

private org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer retryTimer

zkClientConfig

private final org.apache.zookeeper.client.ZKClientConfig zkClientConfig

CLOSE

private static final ReadOnlyZKClient.Task CLOSE

tasks

private final DelayQueue<ReadOnlyZKClient.Task> tasks

closed

private final AtomicBoolean closed

zookeeper

org.apache.zookeeper.ZooKeeper zookeeper

pendingRequests

private int pendingRequests

Constructor Details

ReadOnlyZKClient

public ReadOnlyZKClient(org.apache.hadoop.conf.Configuration conf,
 org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer retryTimer)

Method Details

getId

private String getId()

getTimerTask

private static org.apache.hbase.thirdparty.io.netty.util.TimerTask getTimerTask(long timeoutMs,
 CompletableFuture<?> future,
 String api)

get

public CompletableFuture<byte[]> get(String path,
 long timeoutMs)

get

public CompletableFuture<byte[]> get(String path)

exists

public CompletableFuture<org.apache.zookeeper.data.Stat> exists(String path,
 long timeoutMs)

exists

public CompletableFuture<org.apache.zookeeper.data.Stat> exists(String path)

list

public CompletableFuture<List<String>> list(String path,
 long timeoutMs)

list

public CompletableFuture<List<String>> list(String path)

closeZk

private void closeZk()

getZk

private org.apache.zookeeper.ZooKeeper getZk()
                                      throws IOException

Throws:

IOException

run

private void run()

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

getConnectString

public String getConnectString()