org.apache.accumulo.server.zookeeper
Class ZooQueueLock
java.lang.Object
org.apache.accumulo.server.zookeeper.ZooQueueLock
- All Implemented Interfaces:
- DistributedReadWriteLock.QueueLock
public class ZooQueueLock
- extends Object
- implements DistributedReadWriteLock.QueueLock
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ZooQueueLock
public ZooQueueLock(String path,
boolean ephemeral)
throws org.apache.zookeeper.KeeperException,
InterruptedException
- Throws:
org.apache.zookeeper.KeeperException
InterruptedException
addEntry
public long addEntry(byte[] data)
- Specified by:
addEntry
in interface DistributedReadWriteLock.QueueLock
getEarlierEntries
public SortedMap<Long,byte[]> getEarlierEntries(long entry)
- Specified by:
getEarlierEntries
in interface DistributedReadWriteLock.QueueLock
removeEntry
public void removeEntry(long entry)
- Specified by:
removeEntry
in interface DistributedReadWriteLock.QueueLock
main
public static void main(String[] args)
throws InterruptedException,
org.apache.zookeeper.KeeperException
- Throws:
InterruptedException
org.apache.zookeeper.KeeperException
Copyright © 2012 The Apache Software Foundation. All Rights Reserved.