Interface DistributedQueue


  • public interface DistributedQueue
    Distributed queue component. Methods largely follow those in Queue.
    • Method Detail

      • 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