public class

ZkClient

extends ZkClient

java.lang.Object
↳	org.I0Itec.zkclient.ZkClient
	↳	org.apache.helix.manager.zk.ZkClient

Class Overview

ZKClient does not provide some functionalities, this will be used for quick fixes if any bug found in ZKClient or if we need additional features but can't wait for the new ZkClient jar Ideally we should commit the changes we do here to ZKClient.

Summary

Constants
int	DEFAULT_CONNECTION_TIMEOUT
int	DEFAULT_SESSION_TIMEOUT

[Expand]

Inherited Fields

From class org.I0Itec.zkclient.ZkClient

Public Constructors
	ZkClient(IZkConnection connection, int connectionTimeout, PathBasedZkSerializer zkSerializer)
	ZkClient(IZkConnection connection, int connectionTimeout, ZkSerializer zkSerializer)
	ZkClient(IZkConnection connection, int connectionTimeout)
	ZkClient(IZkConnection connection)
	ZkClient(String zkServers, int sessionTimeout, int connectionTimeout, ZkSerializer zkSerializer)
	ZkClient(String zkServers, int sessionTimeout, int connectionTimeout, PathBasedZkSerializer zkSerializer)
	ZkClient(String zkServers, int sessionTimeout, int connectionTimeout)
	ZkClient(String zkServers, int connectionTimeout)
	ZkClient(String zkServers)

Public Methods
void	asyncCreate(String path, Object datat, CreateMode mode, ZkAsyncCallbacks.CreateCallbackHandler cb)
void	asyncDelete(String path, ZkAsyncCallbacks.DeleteCallbackHandler cb)
void	asyncExists(String path, ZkAsyncCallbacks.ExistsCallbackHandler cb)
void	asyncGetData(String path, ZkAsyncCallbacks.GetDataCallbackHandler cb)
void	asyncSetData(String path, Object datat, int version, ZkAsyncCallbacks.SetDataCallbackHandler cb)
void	close()
String	create(String path, Object data, CreateMode mode)
boolean	delete(String path)
boolean	delete(String path, int version)
<T> T	deserialize(byte[] data, String path)
IZkConnection	getConnection()
String	getServers()
Stat	getStat(String path)
<T> T	readDataAndStat(String path, Stat stat, boolean returnNullIfPathNotExists)
byte[]	serialize(Object data, String path)
void	setZkSerializer(PathBasedZkSerializer zkSerializer)
void	setZkSerializer(ZkSerializer zkSerializer)
void	writeData(String path, Object datat, int expectedVersion)
Stat	writeDataGetStat(String path, Object datat, int expectedVersion)

Protected Methods
boolean	exists(String path, boolean watch)
List<String>	getChildren(String path, boolean watch)
<T> T	readData(String path, Stat stat, boolean watch)

[Expand]

Inherited Methods

From class org.I0Itec.zkclient.ZkClient

void	close()
void	connect(long arg0, Watcher arg1)
int	countChildren(String arg0)
String	create(String arg0, Object arg1, CreateMode arg2)
void	createEphemeral(String arg0, Object arg1)
void	createEphemeral(String arg0)
String	createEphemeralSequential(String arg0, Object arg1)
void	createPersistent(String arg0, Object arg1)
void	createPersistent(String arg0)
void	createPersistent(String arg0, boolean arg1)
String	createPersistentSequential(String arg0, Object arg1)
boolean	delete(String arg0)
boolean	deleteRecursive(String arg0)
boolean	exists(String arg0, boolean arg1)
boolean	exists(String arg0)
List<String>	getChildren(String arg0, boolean arg1)
List<String>	getChildren(String arg0)
long	getCreationTime(String arg0)
Set<IZkDataListener>	getDataListener(String arg0)
ZkLock	getEventLock()
boolean	getShutdownTrigger()
int	numberOfListeners()
void	process(WatchedEvent arg0)
<T> T	readData(String arg0, Stat arg1, boolean arg2)
<T> T	readData(String arg0, boolean arg1)
<T> T	readData(String arg0)
<T> T	readData(String arg0, Stat arg1)
<T> T	retryUntilConnected(Callable<T> arg0)
void	setCurrentState(Watcher.Event.KeeperState arg0)
void	setShutdownTrigger(boolean arg0)
void	setZkSerializer(ZkSerializer arg0)
void	showFolders(OutputStream arg0)
List<String>	subscribeChildChanges(String arg0, IZkChildListener arg1)
void	subscribeDataChanges(String arg0, IZkDataListener arg1)
void	subscribeStateChanges(IZkStateListener arg0)
void	unsubscribeAll()
void	unsubscribeChildChanges(String arg0, IZkChildListener arg1)
void	unsubscribeDataChanges(String arg0, IZkDataListener arg1)
void	unsubscribeStateChanges(IZkStateListener arg0)
<T> void	updateDataSerialized(String arg0, DataUpdater<T> arg1)
boolean	waitForKeeperState(Watcher.Event.KeeperState arg0, long arg1, TimeUnit arg2)
boolean	waitUntilConnected(long arg0, TimeUnit arg1)
void	waitUntilConnected()
boolean	waitUntilExists(String arg0, TimeUnit arg1, long arg2)
List<String>	watchForChilds(String arg0)
void	watchForData(String arg0)
void	writeData(String arg0, Object arg1, int arg2)
void	writeData(String arg0, Object arg1)

From class java.lang.Object

From interface org.apache.zookeeper.Watcher

Constants

public static final int DEFAULT_CONNECTION_TIMEOUT

Constant Value: 60000 (0x0000ea60)

public static final int DEFAULT_SESSION_TIMEOUT

Constant Value: 30000 (0x00007530)

Public Constructors

public ZkClient (IZkConnection connection, int connectionTimeout, PathBasedZkSerializer zkSerializer)

public ZkClient (IZkConnection connection, int connectionTimeout, ZkSerializer zkSerializer)

public ZkClient (IZkConnection connection, int connectionTimeout)

public ZkClient (IZkConnection connection)

public ZkClient (String zkServers, int sessionTimeout, int connectionTimeout, ZkSerializer zkSerializer)

public ZkClient (String zkServers, int sessionTimeout, int connectionTimeout, PathBasedZkSerializer zkSerializer)

public ZkClient (String zkServers, int sessionTimeout, int connectionTimeout)

public ZkClient (String zkServers, int connectionTimeout)

public ZkClient (String zkServers)

Public Methods

public void asyncCreate (String path, Object datat, CreateMode mode, ZkAsyncCallbacks.CreateCallbackHandler cb)

public void asyncDelete (String path, ZkAsyncCallbacks.DeleteCallbackHandler cb)

public void asyncExists (String path, ZkAsyncCallbacks.ExistsCallbackHandler cb)

public void asyncGetData (String path, ZkAsyncCallbacks.GetDataCallbackHandler cb)

public void asyncSetData (String path, Object datat, int version, ZkAsyncCallbacks.SetDataCallbackHandler cb)

public void close ()

Throws

ZkInterruptedException

public String create (String path, Object data, CreateMode mode)

Throws

ZkInterruptedException
IllegalArgumentException
ZkException
RuntimeException

public boolean delete (String path)

public boolean delete (String path, int version)

public T deserialize (byte[] data, String path)

public IZkConnection getConnection ()

public String getServers ()

public Stat getStat (String path)

public T readDataAndStat (String path, Stat stat, boolean returnNullIfPathNotExists)

public byte[] serialize (Object data, String path)

public void setZkSerializer (PathBasedZkSerializer zkSerializer)

public void setZkSerializer (ZkSerializer zkSerializer)

public void writeData (String path, Object datat, int expectedVersion)

public Stat writeDataGetStat (String path, Object datat, int expectedVersion)

Throws

InterruptedException

Interfaces

Classes

Enums

ZkClient

Class Overview

Summary

Constants

public static final int DEFAULT_CONNECTION_TIMEOUT

public static final int DEFAULT_SESSION_TIMEOUT

Public Constructors

public ZkClient (IZkConnection connection, int connectionTimeout, PathBasedZkSerializer zkSerializer)

public ZkClient (IZkConnection connection, int connectionTimeout, ZkSerializer zkSerializer)

public ZkClient (IZkConnection connection, int connectionTimeout)

public ZkClient (IZkConnection connection)

public ZkClient (String zkServers, int sessionTimeout, int connectionTimeout, ZkSerializer zkSerializer)

public ZkClient (String zkServers, int sessionTimeout, int connectionTimeout, PathBasedZkSerializer zkSerializer)

public ZkClient (String zkServers, int sessionTimeout, int connectionTimeout)

public ZkClient (String zkServers, int connectionTimeout)

public ZkClient (String zkServers)

Public Methods

public void asyncCreate (String path, Object datat, CreateMode mode, ZkAsyncCallbacks.CreateCallbackHandler cb)

public void asyncDelete (String path, ZkAsyncCallbacks.DeleteCallbackHandler cb)

public void asyncExists (String path, ZkAsyncCallbacks.ExistsCallbackHandler cb)

public void asyncGetData (String path, ZkAsyncCallbacks.GetDataCallbackHandler cb)

public void asyncSetData (String path, Object datat, int version, ZkAsyncCallbacks.SetDataCallbackHandler cb)

public void close ()

Throws

public String create (String path, Object data, CreateMode mode)

Throws

public boolean delete (String path)

public boolean delete (String path, int version)

public T deserialize (byte[] data, String path)

public IZkConnection getConnection ()

public String getServers ()

public Stat getStat (String path)

public T readDataAndStat (String path, Stat stat, boolean returnNullIfPathNotExists)

public byte[] serialize (Object data, String path)

public void setZkSerializer (PathBasedZkSerializer zkSerializer)

public void setZkSerializer (ZkSerializer zkSerializer)

public void writeData (String path, Object datat, int expectedVersion)

public Stat writeDataGetStat (String path, Object datat, int expectedVersion)

Throws

Protected Methods

protected boolean exists (String path, boolean watch)

protected List<String> getChildren (String path, boolean watch)

protected T readData (String path, Stat stat, boolean watch)