Package com.inductiveautomation.historian.gateway.types.widedb

Class Query.StreamingReader

java.lang.Object

com.inductiveautomation.historian.gateway.types.widedb.Query.Reader

com.inductiveautomation.historian.gateway.types.widedb.Query.StreamingReader

Enclosing class:

Query

protected class Query.StreamingReader
extends Query.Reader

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	StreamingReader(SRConnection conn, PreparedStatement stmt, ResultSet rs)

Method Summary

Modifier and Type	Method	Description
protected void	close()
protected void	closeDBObjects()
protected List<IndexedQualifiedValue>	getAllValues()
protected List<AbstractHistoryQueryExecutor.ColumnDataType>	getColumnTypes()
protected IndexedQualifiedValue	readNext()
protected void	start()

Methods inherited from class java.lang.Object

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

Constructor Details

StreamingReader

protected StreamingReader(SRConnection conn,
 PreparedStatement stmt,
 ResultSet rs)

Method Details

getColumnTypes

protected List<AbstractHistoryQueryExecutor.ColumnDataType> getColumnTypes()

Specified by:

getColumnTypes in class Query.Reader

closeDBObjects

protected void closeDBObjects()

start

protected void start()
              throws Exception

Overrides:

start in class Query.Reader

Throws:

Exception

getAllValues

protected List<IndexedQualifiedValue> getAllValues()
                                            throws Exception

Specified by:

getAllValues in class Query.Reader

Throws:

Exception

readNext

protected IndexedQualifiedValue readNext()
                                  throws Exception

Specified by:

readNext in class Query.Reader

Throws:

Exception

close

protected void close()

Overrides:

close in class Query.Reader