Package | Description |
---|---|
org.apache.solr.cloud |
Classes for dealing with ZooKeeper when operating in SolrCloud mode.
|
Modifier and Type | Method and Description |
---|---|
DistributedQueue.QueueEvent |
DistributedQueue.offer(byte[] data,
long timeout)
Offer the data and wait for the response
|
DistributedQueue.QueueEvent |
DistributedQueue.peek(boolean block)
Returns the data at the first element of the queue, or null if the queue is
empty and block is false.
|
DistributedQueue.QueueEvent |
DistributedQueue.peek(long wait)
Returns the data at the first element of the queue, or null if the queue is
empty after wait ms.
|
Modifier and Type | Method and Description |
---|---|
List<DistributedQueue.QueueEvent> |
DistributedQueue.peekTopN(int n,
Set<String> excludeSet,
Long wait) |
Modifier and Type | Method and Description |
---|---|
byte[] |
DistributedQueue.remove(DistributedQueue.QueueEvent event)
Remove the event and save the response into the other path.
|
Constructor and Description |
---|
OverseerCollectionProcessor.Runner(ZkNodeProps message,
String operation,
DistributedQueue.QueueEvent head) |
Copyright © 2000-2014 Apache Software Foundation. All Rights Reserved.