Package com.inductiveautomation.gateway.tsdb.impl

Class NonStreamingQueryResults

java.lang.Object

com.inductiveautomation.gateway.tsdb.impl.NonStreamingQueryResults

All Implemented Interfaces:

QueryResult, SyncQueryResults, java.util.Iterator<ResultDataPoint>

public class NonStreamingQueryResults
extends java.lang.Object
implements SyncQueryResults

An implementation of query result that holds all data in memory.

Constructor Summary

Constructors

Constructor	Description
NonStreamingQueryResults()
NonStreamingQueryResults(long syncId)

Method Summary

Modifier and Type	Method	Description
void	addData(PathInfo info, DataPoint data)
void	addData(PathInfo info, java.util.List<DataPoint> data)
void	cancel()	Cancels the query.
java.lang.Exception	getError()
java.util.List<PathInfo>	getPathInfo()	Information about the paths queried.
long	getSyncId()
boolean	hasNext()
boolean	isErrored()
protected void	moveForward()
ResultDataPoint	next()
void	onData(java.util.function.Consumer<DataPoint> consumer, java.util.function.BiConsumer<java.lang.Boolean,java.lang.Throwable> onComplete)
void	onError(java.lang.Exception t)
void	setSyncId(long syncId)

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

NonStreamingQueryResults

public NonStreamingQueryResults()

NonStreamingQueryResults

public NonStreamingQueryResults(long syncId)

Method Detail

isErrored

public boolean isErrored()

Specified by:

isErrored in interface QueryResult

getError

public java.lang.Exception getError()

Specified by:

getError in interface QueryResult

setSyncId

public void setSyncId(long syncId)

addData

public void addData(PathInfo info,
                    DataPoint data)

addData

public void addData(PathInfo info,
                    java.util.List<DataPoint> data)

getPathInfo

public java.util.List<PathInfo> getPathInfo()

Description copied from interface: QueryResult

Information about the paths queried. Corresponds 1-to-1 with the paths passed in when the query was executed.

Specified by:

getPathInfo in interface QueryResult

moveForward

protected void moveForward()

hasNext

public boolean hasNext()

Specified by:

hasNext in interface java.util.Iterator<ResultDataPoint>

next

public ResultDataPoint next()

Specified by:

next in interface java.util.Iterator<ResultDataPoint>

onData

public void onData(java.util.function.Consumer<DataPoint> consumer,
                   java.util.function.BiConsumer<java.lang.Boolean,java.lang.Throwable> onComplete)

Specified by:

onData in interface QueryResult

cancel

public void cancel()

Description copied from interface: QueryResult

Cancels the query. Will call onComplete immediately, and will no longer process values. If takeNext() is blocked, it will throw an interrupted exception.

Specified by:

cancel in interface QueryResult

getSyncId

public long getSyncId()

Specified by:

getSyncId in interface SyncQueryResults

onError

public void onError(java.lang.Exception t)