org.apache.hadoop.hbase.zookeeper

Class ReadOnlyZKClient

java.lang.Object

org.apache.hadoop.hbase.zookeeper.ReadOnlyZKClient

All Implemented Interfaces:

Closeable, AutoCloseable

@InterfaceAudience.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 and Description
private static class	ReadOnlyZKClient.Task
private class	ReadOnlyZKClient.ZKTask<T>

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
ReadOnlyZKClient(org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method and Description
void	close()
private void	closeZk()
CompletableFuture<org.apache.zookeeper.data.Stat>	exists(String path)
CompletableFuture<byte[]>	get(String path)
String	getConnectString()
private String	getId()
private org.apache.zookeeper.ZooKeeper	getZk()
CompletableFuture<List<String>>	list(String path)
private void	run()

Methods inherited from class java.lang.Object

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

Field Detail

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

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 Detail

ReadOnlyZKClient

public ReadOnlyZKClient(org.apache.hadoop.conf.Configuration conf)

Method Detail

getId

private String getId()

get

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

exists

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

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 Closeable

Specified by:

close in interface AutoCloseable

getConnectString

public String getConnectString()