org.apache.accumulo.fate.zookeeper
public class ZooQueueLock extends Object implements DistributedReadWriteLock.QueueLock
Modifier | Constructor and Description |
---|---|
protected |
ZooQueueLock(IZooReaderWriter zrw,
String path,
boolean ephemeral) |
|
ZooQueueLock(String zookeepers,
int timeInMillis,
String scheme,
byte[] auth,
String path,
boolean ephemeral) |
Modifier and Type | Method and Description |
---|---|
long |
addEntry(byte[] data) |
SortedMap<Long,byte[]> |
getEarlierEntries(long entry) |
void |
removeEntry(long entry) |
public ZooQueueLock(String zookeepers, int timeInMillis, String scheme, byte[] auth, String path, boolean ephemeral) throws org.apache.zookeeper.KeeperException, InterruptedException
org.apache.zookeeper.KeeperException
InterruptedException
protected ZooQueueLock(IZooReaderWriter zrw, String path, boolean ephemeral)
public long addEntry(byte[] data)
addEntry
in interface DistributedReadWriteLock.QueueLock
public SortedMap<Long,byte[]> getEarlierEntries(long entry)
getEarlierEntries
in interface DistributedReadWriteLock.QueueLock
public void removeEntry(long entry)
removeEntry
in interface DistributedReadWriteLock.QueueLock
Copyright © 2011-2015 The Apache Software Foundation. All Rights Reserved.