Package org.apache.solr.handler.sql

Class CalciteJDBCStream

  • 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 CalciteJDBCStream
extends org.apache.solr.client.solrj.io.stream.JDBCStream
    Used with o.a.s.Handler.SQLHandler.
    Since:
    7.0.0
    See Also:
    Serialized Form
    NOTE: This API is for internal purposes only 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.JDBCStream

        org.apache.solr.client.solrj.io.stream.JDBCStream.ResultSetValueSelector

      • 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 class org.apache.solr.client.solrj.io.stream.JDBCStream

        resultSet, sep, streamContext

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

        EMPTY

    • Constructor Summary

      Constructors 
      Constructor Description
      CalciteJDBCStream​(String connectionUrl, String sqlQuery, org.apache.solr.client.solrj.io.comp.StreamComparator definedSort, Properties connectionProperties, String driverClassName)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected org.apache.solr.client.solrj.io.stream.JDBCStream.ResultSetValueSelector determineValueSelector​(int columnIdx, ResultSetMetaData metadata)  
      protected Driver getDriver()  

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

        children, close, getStreamSort, open, read, setStreamContext, toExplanation, toExpression

      • 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

      • CalciteJDBCStream

        public CalciteJDBCStream​(String connectionUrl,
                         String sqlQuery,
                         org.apache.solr.client.solrj.io.comp.StreamComparator definedSort,
                         Properties connectionProperties,
                         String driverClassName)
                  throws IOException
        Throws:
        IOException

    • Method Detail

      • determineValueSelector

        protected org.apache.solr.client.solrj.io.stream.JDBCStream.ResultSetValueSelector determineValueSelector​(int columnIdx,
                                                                                                          ResultSetMetaData metadata)
                                                                                                   throws SQLException
        Overrides:
        determineValueSelector in class org.apache.solr.client.solrj.io.stream.JDBCStream
        Throws:
        SQLException

      • getDriver

        protected Driver getDriver()
        Overrides:
        getDriver in class org.apache.solr.client.solrj.io.stream.JDBCStream