Package | Description |
---|---|
org.apache.zookeeper | |
org.apache.zookeeper.admin |
Modifier and Type | Method and Description |
---|---|
Stat |
ZooKeeper.exists(String path,
boolean watch)
Return the stat of the node of the given path.
|
Stat |
ZooKeeper.exists(String path,
Watcher watcher)
Return the stat of the node of the given path.
|
Stat |
ZooKeeper.setACL(String path,
List<ACL> acl,
int version)
Set the ACL for the node of the given path if such a node exists and the
given version matches the version of the node.
|
Stat |
ZooKeeper.setData(String path,
byte[] data,
int version)
Set the data for the node of the given path if such a node exists and the
given version matches the version of the node (if the given version is
-1, it matches any node's versions).
|
Modifier and Type | Method and Description |
---|---|
String |
ZooKeeper.create(String path,
byte[] data,
List<ACL> acl,
CreateMode createMode,
Stat stat)
Create a node with the given path and returns the Stat of that node.
|
String |
ZooKeeper.create(String path,
byte[] data,
List<ACL> acl,
CreateMode createMode,
Stat stat,
long ttl)
same as
ZooKeeper.create(String, byte[], List, CreateMode, Stat) but
allows for specifying a TTL when mode is CreateMode.PERSISTENT_WITH_TTL
or CreateMode.PERSISTENT_SEQUENTIAL_WITH_TTL . |
List<ACL> |
ZooKeeper.getACL(String path,
Stat stat)
Return the ACL and stat of the node of the given path.
|
void |
ZooKeeper.getACL(String path,
Stat stat,
AsyncCallback.ACLCallback cb,
Object ctx)
The asynchronous version of getACL.
|
List<String> |
ZooKeeper.getChildren(String path,
boolean watch,
Stat stat)
For the given znode path return the stat and children list.
|
List<String> |
ZooKeeper.getChildren(String path,
Watcher watcher,
Stat stat)
For the given znode path return the stat and children list.
|
byte[] |
ZooKeeper.getConfig(boolean watch,
Stat stat)
Return the last committed configuration (as known to the server to which the client is connected)
and the stat of the configuration.
|
byte[] |
ZooKeeper.getConfig(Watcher watcher,
Stat stat)
Return the last committed configuration (as known to the server to which the client is connected)
and the stat of the configuration.
|
byte[] |
ZooKeeper.getData(String path,
boolean watch,
Stat stat)
Return the data and the stat of the node of the given path.
|
byte[] |
ZooKeeper.getData(String path,
Watcher watcher,
Stat stat)
Return the data and the stat of the node of the given path.
|
void |
AsyncCallback.DataCallback.processResult(int rc,
String path,
Object ctx,
byte[] data,
Stat stat)
Process the result of asynchronous calls.
|
void |
AsyncCallback.ACLCallback.processResult(int rc,
String path,
Object ctx,
List<ACL> acl,
Stat stat)
Process the result of the asynchronous call.
|
void |
AsyncCallback.Children2Callback.processResult(int rc,
String path,
Object ctx,
List<String> children,
Stat stat)
Process the result of the asynchronous call.
|
void |
AsyncCallback.StatCallback.processResult(int rc,
String path,
Object ctx,
Stat stat)
Process the result of the asynchronous call.
|
void |
AsyncCallback.Create2Callback.processResult(int rc,
String path,
Object ctx,
String name,
Stat stat)
Process the result of the asynchronous call.
|
byte[] |
ZooKeeper.reconfig(List<String> joiningServers,
List<String> leavingServers,
List<String> newMembers,
long fromConfig,
Stat stat)
Deprecated.
instead use the reconfigure() methods instead in
ZooKeeperAdmin |
byte[] |
ZooKeeper.reconfig(String joiningServers,
String leavingServers,
String newMembers,
long fromConfig,
Stat stat)
Deprecated.
instead use the reconfigure() methods instead in
ZooKeeperAdmin |
Modifier and Type | Method and Description |
---|---|
byte[] |
ZooKeeperAdmin.reconfigure(List<String> joiningServers,
List<String> leavingServers,
List<String> newMembers,
long fromConfig,
Stat stat)
Convenience wrapper around reconfig that takes Lists of strings instead of comma-separated servers.
|
byte[] |
ZooKeeperAdmin.reconfigure(String joiningServers,
String leavingServers,
String newMembers,
long fromConfig,
Stat stat)
Reconfigure - add/remove servers.
|
Copyright © 2017 The Apache Software Foundation