org.apache.accumulo.server.zookeeper
Interface IZooReaderWriter

All Superinterfaces:
IZooReader
All Known Implementing Classes:
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 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)
           
 
Methods inherited from interface org.apache.accumulo.core.zookeeper.IZooReader
exists, exists, getChildren, getChildren, getData, getStatus, getStatus
 

Method Detail

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

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


Copyright © 2012 The Apache Software Foundation. All Rights Reserved.