com.inductiveautomation.gateway.tsdb.impl

Class BasicQueryResult

java.lang.Object

com.inductiveautomation.gateway.tsdb.impl.BasicQueryResult

All Implemented Interfaces:

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

Direct Known Subclasses:

FixedDailyDataHistorian.DataPump, SQLiteHistorian.Query

public class BasicQueryResult
extends java.lang.Object
implements QueryResult, ResultPublisher

A basic implementation of QueryResult that can be used to publish data. To use this class, simply call publish() until data is complete and while hasNext==true, and then call publishDone(). If the query is cancelled, it will be reflected in hasMore being false before publishDone is called. Therefore care should be taken to not block forever, but to regularly check for this condition while waiting for data.

Constructor Summary

Constructors

Constructor and Description
BasicQueryResult(java.util.List<PathInfo> pathInfos)

Method Summary

Modifier and Type	Method and Description
void	cancel() Cancels the query.
void	finish()
void	finishWithError(java.lang.Exception e)
java.util.List<PathInfo>	getPathInfo()
boolean	hasNext()
boolean	isCanceled()
ResultDataPoint	next()
void	onData(java.util.function.Consumer<DataPoint> consumer, java.lang.Runnable onComplete)
void	publish(ResultDataPoint point)

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

BasicQueryResult

public BasicQueryResult(java.util.List<PathInfo> pathInfos)

Method Detail

getPathInfo

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

Specified by:

getPathInfo in interface QueryResult

hasNext

public boolean hasNext()

Specified by:

hasNext in interface java.util.Iterator<ResultDataPoint>

isCanceled

public boolean isCanceled()

Specified by:

isCanceled in interface ResultPublisher

next

public ResultDataPoint next()

Specified by:

next in interface java.util.Iterator<ResultDataPoint>

onData

public void onData(java.util.function.Consumer<DataPoint> consumer,
                   java.lang.Runnable 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

publish

public void publish(ResultDataPoint point)

Specified by:

publish in interface ResultPublisher

finish

public void finish()

Specified by:

finish in interface ResultPublisher

finishWithError

public void finishWithError(java.lang.Exception e)

Specified by:

finishWithError in interface ResultPublisher