Package org.apache.solr.client.solrj.cloud

Interface DistributedQueue

public interface DistributedQueue

Distributed queue component. Methods largely follow those in Queue.

Method Summary

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

peek

byte[] peek()
     throws Exception

Throws:

Exception

peek

byte[] peek(boolean block)
     throws Exception

Throws:

Exception

peek

byte[] peek(long wait)
     throws Exception

Throws:

Exception

poll

byte[] poll()
     throws Exception

Throws:

Exception

remove

byte[] remove()
       throws Exception

Throws:

Exception

take

byte[] take()
     throws Exception

Throws:

Exception

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 retrieve

waitMillis - 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