org.apache.solr.handler

Class CalciteJDBCStream

java.lang.Object

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

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

org.apache.solr.handler.CalciteJDBCStream

All Implemented Interfaces:

Closeable, Serializable, AutoCloseable, Expressible, MapSerializable, MapWriter

public class CalciteJDBCStream
extends 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

JDBCStream.ResultSetValueSelector

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

TupleStream.IgnoreException

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

MapWriter.EntryWriter

Field Summary

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

resultSet, sep, streamContext

Constructor Summary

Constructors

Constructor and Description
CalciteJDBCStream(String connectionUrl, String sqlQuery, StreamComparator definedSort, Properties connectionProperties, String driverClassName)

Method Summary

Modifier and Type	Method and Description
protected JDBCStream.ResultSetValueSelector	determineValueSelector(int columnIdx, ResultSetMetaData metadata)

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, getStreamNodeId, writeMap

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

jsonStr, toMap

Constructor Detail

CalciteJDBCStream

public CalciteJDBCStream(String connectionUrl,
                         String sqlQuery,
                         StreamComparator definedSort,
                         Properties connectionProperties,
                         String driverClassName)
                  throws IOException

Throws:

IOException

Method Detail

determineValueSelector

protected JDBCStream.ResultSetValueSelector determineValueSelector(int columnIdx,
                                                                   ResultSetMetaData metadata)
                                                            throws SQLException

Overrides:

determineValueSelector in class JDBCStream

Throws:

SQLException