Interface DistributedQueue
-
public interface DistributedQueue
Distributed queue component. Methods largely follow those inQueue
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description Map<String,Object>
getStats()
Retrieve statistics about the queue size, operations and their timings.void
offer(byte[] data)
default void
offer(org.apache.solr.common.MapWriter mw)
byte[]
peek()
byte[]
peek(boolean block)
byte[]
peek(long wait)
Collection<org.apache.solr.common.util.Pair<String,byte[]>>
peekElements(int max, long waitMillis, Predicate<String> acceptFilter)
Peek multiple elements from the queue in a single call.byte[]
poll()
byte[]
remove()
byte[]
take()
-
-
-
Method Detail
-
offer
void offer(byte[] data) throws org.apache.zookeeper.KeeperException, InterruptedException
- Throws:
org.apache.zookeeper.KeeperException
InterruptedException
-
offer
default void offer(org.apache.solr.common.MapWriter mw) throws org.apache.zookeeper.KeeperException, InterruptedException
- Throws:
org.apache.zookeeper.KeeperException
InterruptedException
-
getStats
Map<String,Object> getStats()
Retrieve statistics about the queue size, operations and their timings.
-
peekElements
Collection<org.apache.solr.common.util.Pair<String,byte[]>> peekElements(int max, long waitMillis, Predicate<String> acceptFilter) throws Exception
Peek multiple elements from the queue in a single call.- Parameters:
max
- maximum elements to retrievewaitMillis
- if less than maximum element is in the queue then wait at most this time for at least one new element.acceptFilter
- peek only elements that pass this filter- Returns:
- peeked elements
- Throws:
Exception
- on errors
-
-