org.apache.accumulo.fate.zookeeper
Interface IZooReaderWriter
- All Superinterfaces:
- IZooReader
- All Known Implementing Classes:
- ZooReaderWriter, ZooReaderWriter
public interface IZooReaderWriter
- extends IZooReader
Method Summary |
void |
delete(String path,
int version)
|
org.apache.zookeeper.ZooKeeper |
getZooKeeper()
|
boolean |
isLockHeld(ZooUtil.LockID lockID)
|
void |
mkdirs(String path)
|
byte[] |
mutate(String zPath,
byte[] createValue,
List<org.apache.zookeeper.data.ACL> acl,
ZooReaderWriter.Mutator mutator)
|
String |
putEphemeralData(String zPath,
byte[] data)
|
String |
putEphemeralSequential(String zPath,
byte[] data)
|
void |
putPersistentData(String zPath,
byte[] data,
int version,
ZooUtil.NodeExistsPolicy policy)
|
boolean |
putPersistentData(String zPath,
byte[] data,
ZooUtil.NodeExistsPolicy policy)
Create a persistent node with the default ACL |
String |
putPersistentSequential(String zPath,
byte[] data)
|
boolean |
putPrivatePersistentData(String zPath,
byte[] data,
ZooUtil.NodeExistsPolicy policy)
|
void |
recursiveCopyPersistent(String source,
String destination,
ZooUtil.NodeExistsPolicy policy)
|
void |
recursiveDelete(String zPath,
int version,
ZooUtil.NodeMissingPolicy policy)
|
void |
recursiveDelete(String zPath,
ZooUtil.NodeMissingPolicy policy)
|
void |
sync(String path)
|
getZooKeeper
org.apache.zookeeper.ZooKeeper getZooKeeper()
recursiveDelete
void recursiveDelete(String zPath,
ZooUtil.NodeMissingPolicy policy)
throws org.apache.zookeeper.KeeperException,
InterruptedException
- Throws:
org.apache.zookeeper.KeeperException
InterruptedException
recursiveDelete
void recursiveDelete(String zPath,
int version,
ZooUtil.NodeMissingPolicy policy)
throws org.apache.zookeeper.KeeperException,
InterruptedException
- Throws:
org.apache.zookeeper.KeeperException
InterruptedException
putPersistentData
boolean putPersistentData(String zPath,
byte[] data,
ZooUtil.NodeExistsPolicy policy)
throws org.apache.zookeeper.KeeperException,
InterruptedException
- Create a persistent node with the default ACL
- Returns:
- true if the node was created or altered; false if it was skipped
- Throws:
org.apache.zookeeper.KeeperException
InterruptedException
putPrivatePersistentData
boolean putPrivatePersistentData(String zPath,
byte[] data,
ZooUtil.NodeExistsPolicy policy)
throws org.apache.zookeeper.KeeperException,
InterruptedException
- Throws:
org.apache.zookeeper.KeeperException
InterruptedException
putPersistentData
void putPersistentData(String zPath,
byte[] data,
int version,
ZooUtil.NodeExistsPolicy policy)
throws org.apache.zookeeper.KeeperException,
InterruptedException
- Throws:
org.apache.zookeeper.KeeperException
InterruptedException
putPersistentSequential
String putPersistentSequential(String zPath,
byte[] data)
throws org.apache.zookeeper.KeeperException,
InterruptedException
- Throws:
org.apache.zookeeper.KeeperException
InterruptedException
putEphemeralSequential
String putEphemeralSequential(String zPath,
byte[] data)
throws org.apache.zookeeper.KeeperException,
InterruptedException
- Throws:
org.apache.zookeeper.KeeperException
InterruptedException
putEphemeralData
String putEphemeralData(String zPath,
byte[] data)
throws org.apache.zookeeper.KeeperException,
InterruptedException
- Throws:
org.apache.zookeeper.KeeperException
InterruptedException
recursiveCopyPersistent
void recursiveCopyPersistent(String source,
String destination,
ZooUtil.NodeExistsPolicy policy)
throws org.apache.zookeeper.KeeperException,
InterruptedException
- Throws:
org.apache.zookeeper.KeeperException
InterruptedException
delete
void delete(String path,
int version)
throws InterruptedException,
org.apache.zookeeper.KeeperException
- Throws:
InterruptedException
org.apache.zookeeper.KeeperException
mutate
byte[] mutate(String zPath,
byte[] createValue,
List<org.apache.zookeeper.data.ACL> acl,
ZooReaderWriter.Mutator mutator)
throws Exception
- Throws:
Exception
isLockHeld
boolean isLockHeld(ZooUtil.LockID lockID)
throws org.apache.zookeeper.KeeperException,
InterruptedException
- Throws:
org.apache.zookeeper.KeeperException
InterruptedException
mkdirs
void mkdirs(String path)
throws org.apache.zookeeper.KeeperException,
InterruptedException
- Throws:
org.apache.zookeeper.KeeperException
InterruptedException
sync
void sync(String path)
throws org.apache.zookeeper.KeeperException,
InterruptedException
- Specified by:
sync
in interface IZooReader
- Throws:
org.apache.zookeeper.KeeperException
InterruptedException
Copyright © 2013 Apache Accumulo Project. All Rights Reserved.