org.apache.accumulo.server.zookeeper
public class DistributedWorkQueue extends Object
Modifier and Type | Class and Description |
---|---|
static interface |
DistributedWorkQueue.Processor |
Constructor and Description |
---|
DistributedWorkQueue(String path) |
Modifier and Type | Method and Description |
---|---|
void |
addWork(String workId,
byte[] data) |
List<String> |
getWorkQueued() |
void |
startProcessing(DistributedWorkQueue.Processor processor,
ThreadPoolExecutor executorService) |
void |
waitUntilDone(Set<String> workIDs) |
public DistributedWorkQueue(String path)
public void startProcessing(DistributedWorkQueue.Processor processor, ThreadPoolExecutor executorService) throws org.apache.zookeeper.KeeperException, InterruptedException
org.apache.zookeeper.KeeperException
InterruptedException
public void addWork(String workId, byte[] data) throws org.apache.zookeeper.KeeperException, InterruptedException
org.apache.zookeeper.KeeperException
InterruptedException
public List<String> getWorkQueued() throws org.apache.zookeeper.KeeperException, InterruptedException
org.apache.zookeeper.KeeperException
InterruptedException
public void waitUntilDone(Set<String> workIDs) throws org.apache.zookeeper.KeeperException, InterruptedException
org.apache.zookeeper.KeeperException
InterruptedException
Copyright © 2015 Apache Accumulo Project. All Rights Reserved.