Package com.inductiveautomation.gateway.tsdb.historians

Class SQLiteHistorian.Query

java.lang.Object

com.inductiveautomation.gateway.tsdb.impl.BasicQueryResult

com.inductiveautomation.gateway.tsdb.historians.SQLiteHistorian.Query

All Implemented Interfaces:

QueryResult, ResultPublisher, java.lang.Runnable, java.util.Iterator<ResultDataPoint>

Enclosing class:

SQLiteHistorian

protected class SQLiteHistorian.Query
extends BasicQueryResult
implements java.lang.Runnable

Constructor Summary

Constructors

Constructor	Description
Query(java.util.List<PathInfo> pathInfos, java.util.List<PathInfo> badPaths, com.google.common.collect.Multimap<java.lang.Long,java.lang.Integer> idToPos, long startTime, long endTime, boolean includeBounding)

Method Summary

Modifier and Type	Method	Description
protected void	loadDatapointsFromRS(java.util.List<BasicResultDataPoint> points, java.sql.ResultSet rs)
protected int	publishFromRS(java.sql.ResultSet rs)	Publishes values, returns data count.
void	run()

Methods inherited from class com.inductiveautomation.gateway.tsdb.impl.BasicQueryResult

cancel, finish, finishInternal, finishWithError, getError, getPathInfo, hasNext, isCanceled, isErrored, next, onData, publish, setPathInfo

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining, remove

Constructor Detail

Query

public Query(@Nonnull
             java.util.List<PathInfo> pathInfos,
             @Nonnull
             java.util.List<PathInfo> badPaths,
             @Nonnull
             com.google.common.collect.Multimap<java.lang.Long,java.lang.Integer> idToPos,
             long startTime,
             long endTime,
             boolean includeBounding)

Method Detail

loadDatapointsFromRS

protected void loadDatapointsFromRS(java.util.List<BasicResultDataPoint> points,
                                    java.sql.ResultSet rs)
                             throws java.lang.Exception

Throws:

java.lang.Exception

publishFromRS

protected int publishFromRS(java.sql.ResultSet rs)
                     throws java.lang.Exception

Publishes values, returns data count.

Throws:

java.lang.Exception

run

public void run()

Specified by:

run in interface java.lang.Runnable