org.apache.twill.zookeeper

Class AbstractZKClient

java.lang.Object

org.apache.twill.zookeeper.AbstractZKClient

All Implemented Interfaces:

ZKClient

Direct Known Subclasses:

ForwardingZKClient

public abstract class AbstractZKClient
extends Object
implements ZKClient

An abstract base implementation of ZKClient that simplifies implementation by providing forwarding for methods that are meant to be delegated to other methods.

Constructor Summary

Constructors

Constructor and Description
AbstractZKClient()

Method Summary

Modifier and Type	Method and Description
OperationFuture<String>	create(String path, byte[] data, org.apache.zookeeper.CreateMode createMode) Creates a path in zookeeper.
OperationFuture<String>	create(String path, byte[] data, org.apache.zookeeper.CreateMode createMode, boolean createParent) Creates a path in zookeeper.
OperationFuture<String>	create(String path, byte[] data, org.apache.zookeeper.CreateMode createMode, Iterable<org.apache.zookeeper.data.ACL> acl) Creates a path in zookeeper.
OperationFuture<String>	delete(String path) Deletes the node of the given path without matching version.
OperationFuture<org.apache.zookeeper.data.Stat>	exists(String path) Checks if the path exists.
OperationFuture<NodeChildren>	getChildren(String path) Gets the list of children nodes under the given path.
OperationFuture<NodeData>	getData(String path) Gets the data stored in the given path.
OperationFuture<org.apache.zookeeper.data.Stat>	setACL(String path, Iterable<org.apache.zookeeper.data.ACL> acl) Sets the ACL of the given path if the path exists.
OperationFuture<org.apache.zookeeper.data.Stat>	setData(String path, byte[] data) Sets the data for the given path without matching version.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.twill.zookeeper.ZKClient

addConnectionWatcher, create, delete, exists, getACL, getChildren, getConnectString, getData, getSessionId, setACL, setData

Constructor Detail

AbstractZKClient

public AbstractZKClient()

Method Detail

create

public final OperationFuture<String> create(String path,
                                            @Nullable
                                            byte[] data,
                                            org.apache.zookeeper.CreateMode createMode)

Description copied from interface: ZKClient

Creates a path in zookeeper. Same as calling create(path, data, createMode, true).

Specified by:

create in interface ZKClient

See Also:

ZKClient.create(String, byte[], org.apache.zookeeper.CreateMode, boolean)

create

public final OperationFuture<String> create(String path,
                                            @Nullable
                                            byte[] data,
                                            org.apache.zookeeper.CreateMode createMode,
                                            boolean createParent)

Description copied from interface: ZKClient

Creates a path in zookeeper. Same as calling create(path, data, createMode, createParent, ZooDefs.Ids.OPEN_ACL_UNSAFE)

Specified by:

create in interface ZKClient

See Also:

ZKClient.create(String, byte[], org.apache.zookeeper.CreateMode, boolean, Iterable)

create

public final OperationFuture<String> create(String path,
                                            @Nullable
                                            byte[] data,
                                            org.apache.zookeeper.CreateMode createMode,
                                            Iterable<org.apache.zookeeper.data.ACL> acl)

Description copied from interface: ZKClient

Creates a path in zookeeper. Same as calling create(path, data, createMode, true, acl)

Specified by:

create in interface ZKClient

See Also:

ZKClient.create(String, byte[], org.apache.zookeeper.CreateMode, boolean, Iterable)

exists

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

Description copied from interface: ZKClient

Checks if the path exists. Same as calling exists(path, null).

Specified by:

exists in interface ZKClient

See Also:

ZKClient.exists(String, org.apache.zookeeper.Watcher)

getChildren

public final OperationFuture<NodeChildren> getChildren(String path)

Description copied from interface: ZKClient

Gets the list of children nodes under the given path. Same as calling getChildren(path, null).

Specified by:

getChildren in interface ZKClient

See Also:

ZKClient.getChildren(String, org.apache.zookeeper.Watcher)

getData

public final OperationFuture<NodeData> getData(String path)

Description copied from interface: ZKClient

Gets the data stored in the given path. Same as calling getData(path, null).

Specified by:

getData in interface ZKClient

setData

public final OperationFuture<org.apache.zookeeper.data.Stat> setData(String path,
                                                                     byte[] data)

Description copied from interface: ZKClient

Sets the data for the given path without matching version. Same as calling setData(path, data, -1).

Specified by:

setData in interface ZKClient

delete

public final OperationFuture<String> delete(String path)

Description copied from interface: ZKClient

Deletes the node of the given path without matching version. Same as calling delete(path, -1).

Specified by:

delete in interface ZKClient

See Also:

ZKClient.delete(String, int)

setACL

public final OperationFuture<org.apache.zookeeper.data.Stat> setACL(String path,
                                                                    Iterable<org.apache.zookeeper.data.ACL> acl)

Description copied from interface: ZKClient

Sets the ACL of the given path if the path exists. Same as calling setACL(path, acl, -1)

Specified by:

setACL in interface ZKClient

See Also:

ZKClient.setACL(String, Iterable, int)