Package org.apache.solr.handler

Class ClassifyStream

  • 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 ClassifyStream
extends org.apache.solr.client.solrj.io.stream.TupleStream
implements org.apache.solr.client.solrj.io.stream.expr.Expressible
    The classify expression retrieves a model trained by the train expression and uses it to classify documents from a stream Syntax: classif(model(...), anyStream(...), field="body")
    Since:
    6.3.0
    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

    • Constructor Summary

      Constructors 
      Constructor Description
      ClassifyStream​(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)  
      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

      • ClassifyStream

        public ClassifyStream​(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)
        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