public class CalciteJDBCStream extends JDBCStream
JDBCStream.ResultSetValueSelector
TupleStream.IgnoreException
MapWriter.EntryWriter
resultSet, sep, streamContext
Constructor and Description |
---|
CalciteJDBCStream(String connectionUrl,
String sqlQuery,
StreamComparator definedSort,
Properties connectionProperties,
String driverClassName) |
Modifier and Type | Method and Description |
---|---|
protected JDBCStream.ResultSetValueSelector |
determineValueSelector(int columnIdx,
ResultSetMetaData metadata) |
children, close, getStreamSort, open, read, setStreamContext, toExplanation, toExpression
getCost, getShards, getSlices, getStreamNodeId, writeMap
public CalciteJDBCStream(String connectionUrl, String sqlQuery, StreamComparator definedSort, Properties connectionProperties, String driverClassName) throws IOException
IOException
protected JDBCStream.ResultSetValueSelector determineValueSelector(int columnIdx, ResultSetMetaData metadata) throws SQLException
determineValueSelector
in class JDBCStream
SQLException
Copyright © 2000-2017 Apache Software Foundation. All Rights Reserved.