Uses of Interface
org.apache.twill.zookeeper.OperationFuture

Packages that use OperationFuture

Package	Description
org.apache.twill.zookeeper	This package provides functionality for ZooKeeper interactions.

Uses of OperationFuture in org.apache.twill.zookeeper

Methods in org.apache.twill.zookeeper that return OperationFuture

Modifier and Type	Method and Description
OperationFuture<String>	ZKClient.create(String path, byte[] data, org.apache.zookeeper.CreateMode createMode) Creates a path in zookeeper.
OperationFuture<String>	AbstractZKClient.create(String path, byte[] data, org.apache.zookeeper.CreateMode createMode)
OperationFuture<String>	ZKClient.create(String path, byte[] data, org.apache.zookeeper.CreateMode createMode, boolean createParent) Creates a path in zookeeper.
OperationFuture<String>	AbstractZKClient.create(String path, byte[] data, org.apache.zookeeper.CreateMode createMode, boolean createParent)
OperationFuture<String>	ForwardingZKClient.create(String path, byte[] data, org.apache.zookeeper.CreateMode createMode, boolean createParent, Iterable<org.apache.zookeeper.data.ACL> acl)
OperationFuture<String>	ZKClient.create(String path, byte[] data, org.apache.zookeeper.CreateMode createMode, boolean createParent, Iterable<org.apache.zookeeper.data.ACL> acl) Creates a path in zookeeper, with given data and create mode.
OperationFuture<String>	ZKClient.create(String path, byte[] data, org.apache.zookeeper.CreateMode createMode, Iterable<org.apache.zookeeper.data.ACL> acl) Creates a path in zookeeper.
OperationFuture<String>	AbstractZKClient.create(String path, byte[] data, org.apache.zookeeper.CreateMode createMode, Iterable<org.apache.zookeeper.data.ACL> acl)
static OperationFuture<String>	ZKOperations.createDeleteIfExists(ZKClient zkClient, String path, byte[] data, org.apache.zookeeper.CreateMode createMode, boolean createParent, org.apache.zookeeper.data.ACL... acls) Creates a ZK node of the given path.
OperationFuture<String>	ZKClient.delete(String path) Deletes the node of the given path without matching version.
OperationFuture<String>	AbstractZKClient.delete(String path)
OperationFuture<String>	ForwardingZKClient.delete(String deletePath, int version)
OperationFuture<String>	ZKClient.delete(String deletePath, int version) Deletes the node of the given path that match the given version.
OperationFuture<org.apache.zookeeper.data.Stat>	ZKClient.exists(String path) Checks if the path exists.
OperationFuture<org.apache.zookeeper.data.Stat>	AbstractZKClient.exists(String path)
OperationFuture<org.apache.zookeeper.data.Stat>	ForwardingZKClient.exists(String path, org.apache.zookeeper.Watcher watcher)
OperationFuture<org.apache.zookeeper.data.Stat>	ZKClient.exists(String path, org.apache.zookeeper.Watcher watcher) Checks if the given path exists and leave a watcher on the node for watching creation/deletion/data changes on the node.
OperationFuture<ACLData>	ForwardingZKClient.getACL(String path)
OperationFuture<ACLData>	ZKClient.getACL(String path) Retrieves the Stat and ACL being set at the given path.
OperationFuture<NodeChildren>	ZKClient.getChildren(String path) Gets the list of children nodes under the given path.
OperationFuture<NodeChildren>	AbstractZKClient.getChildren(String path)
OperationFuture<NodeChildren>	ForwardingZKClient.getChildren(String path, org.apache.zookeeper.Watcher watcher)
OperationFuture<NodeChildren>	ZKClient.getChildren(String path, org.apache.zookeeper.Watcher watcher) Gets the list of children nodes under the given path and leave a watcher on the node for watching node deletion and children nodes creation/deletion.
OperationFuture<NodeData>	ZKClient.getData(String path) Gets the data stored in the given path.
OperationFuture<NodeData>	AbstractZKClient.getData(String path)
OperationFuture<NodeData>	ForwardingZKClient.getData(String path, org.apache.zookeeper.Watcher watcher)
OperationFuture<NodeData>	ZKClient.getData(String path, org.apache.zookeeper.Watcher watcher) Gets the data stored in the given path and leave a watcher on the node for watching deletion/data changes on the node.
static <V> OperationFuture<V>	ZKOperations.ignoreError(OperationFuture<V> future, Class<? extends org.apache.zookeeper.KeeperException> exceptionType, V errorResult) Returns a new OperationFuture that the result will be the same as the given future, except that when the source future is having an exception matching the giving exception type, the errorResult will be set in to the returned OperationFuture.
static OperationFuture<String>	ZKOperations.recursiveDelete(ZKClient zkClient, String path) Deletes the given path recursively.
OperationFuture<org.apache.zookeeper.data.Stat>	ZKClient.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>	AbstractZKClient.setACL(String path, Iterable<org.apache.zookeeper.data.ACL> acl)
OperationFuture<org.apache.zookeeper.data.Stat>	ForwardingZKClient.setACL(String path, Iterable<org.apache.zookeeper.data.ACL> acl, int version)
OperationFuture<org.apache.zookeeper.data.Stat>	ZKClient.setACL(String path, Iterable<org.apache.zookeeper.data.ACL> acl, int version) Sets the ACL of the given path if the path exists and version matched.
OperationFuture<org.apache.zookeeper.data.Stat>	ZKClient.setData(String path, byte[] data) Sets the data for the given path without matching version.
OperationFuture<org.apache.zookeeper.data.Stat>	AbstractZKClient.setData(String path, byte[] data)
OperationFuture<org.apache.zookeeper.data.Stat>	ForwardingZKClient.setData(String dataPath, byte[] data, int version)
OperationFuture<org.apache.zookeeper.data.Stat>	ZKClient.setData(String dataPath, byte[] data, int version) Sets the data for the given path that match the given version.

Methods in org.apache.twill.zookeeper with parameters of type OperationFuture

Modifier and Type	Method and Description
static <V> OperationFuture<V>	ZKOperations.ignoreError(OperationFuture<V> future, Class<? extends org.apache.zookeeper.KeeperException> exceptionType, V errorResult) Returns a new OperationFuture that the result will be the same as the given future, except that when the source future is having an exception matching the giving exception type, the errorResult will be set in to the returned OperationFuture.