Class ZooQueueLock
- java.lang.Object
-
- org.apache.accumulo.fate.zookeeper.ZooQueueLock
-
- All Implemented Interfaces:
DistributedReadWriteLock.QueueLock
public class ZooQueueLock extends Object implements DistributedReadWriteLock.QueueLock
-
-
Constructor Summary
Constructors Constructor Description ZooQueueLock(ZooReaderWriter zrw, String path, boolean ephemeral)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description longaddEntry(byte[] data)SortedMap<Long,byte[]>getEarlierEntries(long entry)voidremoveEntry(long entry)
-
-
-
Constructor Detail
-
ZooQueueLock
public ZooQueueLock(ZooReaderWriter zrw, String path, boolean ephemeral)
-
-
Method Detail
-
addEntry
public long addEntry(byte[] data)
- Specified by:
addEntryin interfaceDistributedReadWriteLock.QueueLock
-
getEarlierEntries
public SortedMap<Long,byte[]> getEarlierEntries(long entry)
- Specified by:
getEarlierEntriesin interfaceDistributedReadWriteLock.QueueLock
-
removeEntry
public void removeEntry(long entry)
- Specified by:
removeEntryin interfaceDistributedReadWriteLock.QueueLock
-
-