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 and 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 and 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

_finish, cancel, finish, 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