Package org.apache.solr.handler

Class StreamHandler.DaemonCollectionStream

  • All Implemented Interfaces:
    Closeable, Serializable, AutoCloseable, org.apache.solr.common.MapSerializable, org.apache.solr.common.MapWriter, org.apache.solr.common.NavigableObject
    Enclosing class:
    StreamHandler
    public static class StreamHandler.DaemonCollectionStream
extends org.apache.solr.client.solrj.io.stream.TupleStream
    See Also:
    Serialized Form

    • Nested Class Summary

      • Nested classes/interfaces inherited from class org.apache.solr.client.solrj.io.stream.TupleStream

        org.apache.solr.client.solrj.io.stream.TupleStream.IgnoreException

      • Nested classes/interfaces inherited from interface org.apache.solr.common.MapWriter

        org.apache.solr.common.MapWriter.EntryWriter

    • Field Summary

      • Fields inherited from interface org.apache.solr.common.MapWriter

        EMPTY

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      List<org.apache.solr.client.solrj.io.stream.TupleStream> children()  
      void close()  
      org.apache.solr.client.solrj.io.comp.StreamComparator getStreamSort()  
      void open()  
      org.apache.solr.client.solrj.io.Tuple read()  
      void setStreamContext​(org.apache.solr.client.solrj.io.stream.StreamContext context)  
      org.apache.solr.client.solrj.io.stream.expr.Explanation toExplanation​(org.apache.solr.client.solrj.io.stream.expr.StreamFactory factory)  

      • Methods inherited from class org.apache.solr.client.solrj.io.stream.TupleStream

        getCost, getShards, getShards, getStreamNodeId, writeMap

      • Methods inherited from interface org.apache.solr.common.MapWriter

        jsonStr, toMap

      • Methods inherited from interface org.apache.solr.common.NavigableObject

        _forEachEntry, _forEachEntry, _forEachEntry, _get, _get, _getStr, _getStr, _size

    • Constructor Detail

      • DaemonCollectionStream

        public DaemonCollectionStream​(Collection<org.apache.solr.client.solrj.io.stream.DaemonStream> col)

    • Method Detail

      • getStreamSort

        public org.apache.solr.client.solrj.io.comp.StreamComparator getStreamSort()
        Specified by:
        getStreamSort in class org.apache.solr.client.solrj.io.stream.TupleStream

      • close

        public void close()
        Specified by:
        close in interface AutoCloseable
        Specified by:
        close in interface Closeable
        Specified by:
        close in class org.apache.solr.client.solrj.io.stream.TupleStream

      • open

        public void open()
        Specified by:
        open in class org.apache.solr.client.solrj.io.stream.TupleStream

      • setStreamContext

        public void setStreamContext​(org.apache.solr.client.solrj.io.stream.StreamContext context)
        Specified by:
        setStreamContext in class org.apache.solr.client.solrj.io.stream.TupleStream

      • children

        public List<org.apache.solr.client.solrj.io.stream.TupleStream> children()
        Specified by:
        children in class org.apache.solr.client.solrj.io.stream.TupleStream

      • toExplanation

        public org.apache.solr.client.solrj.io.stream.expr.Explanation toExplanation​(org.apache.solr.client.solrj.io.stream.expr.StreamFactory factory)
                                                                      throws IOException
        Specified by:
        toExplanation in class org.apache.solr.client.solrj.io.stream.TupleStream
        Throws:
        IOException

      • read

        public org.apache.solr.client.solrj.io.Tuple read()
        Specified by:
        read in class org.apache.solr.client.solrj.io.stream.TupleStream