Package org.apache.solr.handler.export

Class ExportWriterStream

  • All Implemented Interfaces:
    Closeable, Serializable, AutoCloseable, org.apache.solr.client.solrj.io.stream.expr.Expressible, org.apache.solr.common.MapSerializable, org.apache.solr.common.MapWriter, org.apache.solr.common.NavigableObject
    public class ExportWriterStream
extends org.apache.solr.client.solrj.io.stream.TupleStream
implements org.apache.solr.client.solrj.io.stream.expr.Expressible
    Stream implementation that helps supporting 'expr' streaming in export writer.

    Note: this class is made public only to allow access from ExportHandler, it should be treated as an internal detail of implementation.

    See Also:
    Serialized Form
    WARNING: This API is experimental and might change in incompatible ways in the next release.

    • 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

    • Constructor Summary

      Constructors 
      Constructor Description
      ExportWriterStream​(org.apache.solr.client.solrj.io.stream.expr.StreamExpression expression, org.apache.solr.client.solrj.io.stream.expr.StreamFactory factory)  

    • 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)
      NOTE: this context must contain an instance of ExportBuffers under the ExportBuffers.EXPORT_BUFFERS_KEY key.
      org.apache.solr.client.solrj.io.stream.expr.Explanation toExplanation​(org.apache.solr.client.solrj.io.stream.expr.StreamFactory factory)  
      org.apache.solr.client.solrj.io.stream.expr.StreamExpressionParameter toExpression​(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

      • ExportWriterStream

        public ExportWriterStream​(org.apache.solr.client.solrj.io.stream.expr.StreamExpression expression,
                          org.apache.solr.client.solrj.io.stream.expr.StreamFactory factory)
                   throws IOException
        Throws:
        IOException

    • Method Detail

      • setStreamContext

        public void setStreamContext​(org.apache.solr.client.solrj.io.stream.StreamContext context)
        NOTE: this context must contain an instance of ExportBuffers under the ExportBuffers.EXPORT_BUFFERS_KEY key.
        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

      • open

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

      • read

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

      • getStreamSort

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

      • toExpression

        public org.apache.solr.client.solrj.io.stream.expr.StreamExpressionParameter toExpression​(org.apache.solr.client.solrj.io.stream.expr.StreamFactory factory)
                                                                                   throws IOException
        Specified by:
        toExpression in interface org.apache.solr.client.solrj.io.stream.expr.Expressible
        Throws:
        IOException

      • 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 interface org.apache.solr.client.solrj.io.stream.expr.Expressible
        Specified by:
        toExplanation in class org.apache.solr.client.solrj.io.stream.TupleStream
        Throws:
        IOException