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:

BasicSyncQueryResults, 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() If this constructor is used, setPathInfo must be called later.
BasicQueryResult(java.util.List<PathInfo> pathInfos)

Method Summary

Modifier and Type	Method and Description
void	cancel() Cancels the query.
void	finish()
protected void	finishInternal(java.lang.Exception ex)
void	finishWithError(java.lang.Exception e)
java.lang.Exception	getError()
java.util.List<PathInfo>	getPathInfo()
boolean	hasNext()
boolean	isCanceled()
boolean	isErrored()
ResultDataPoint	next()
void	onData(java.util.function.Consumer<DataPoint> consumer, java.util.function.BiConsumer<java.lang.Boolean,java.lang.Throwable> onComplete)
void	publish(ResultDataPoint point)
protected void	setPathInfo(java.util.List<PathInfo> pathInfo) Sets the path info and releases the lock on getPathInfos.

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()

If this constructor is used, setPathInfo must be called later. No results will be processed until path info is set.

BasicQueryResult

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

Method Detail

isErrored

public boolean isErrored()

Specified by:

isErrored in interface QueryResult

getError

public java.lang.Exception getError()

Specified by:

getError in interface QueryResult

getPathInfo

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

Specified by:

getPathInfo in interface QueryResult

setPathInfo

protected void setPathInfo(java.util.List<PathInfo> pathInfo)

Sets the path info and releases the lock on getPathInfos.

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

publish

public void publish(ResultDataPoint point)

Specified by:

publish in interface ResultPublisher

finishInternal

protected void finishInternal(java.lang.Exception ex)

finish

public void finish()

Specified by:

finish in interface ResultPublisher

finishWithError

public void finishWithError(java.lang.Exception e)

Specified by:

finishWithError in interface ResultPublisher