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 Details

    • 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