public class RemoteTagHistoryQueryExecutor extends java.lang.Object implements HistoryQueryExecutor
Constructor and Description |
---|
RemoteTagHistoryQueryExecutor(com.inductiveautomation.metro.api.services.Service<TagHistoryService> service,
java.util.List<ColumnQueryDefinition> paths,
QueryController controller,
LoggerEx logger)
The paths here have been transformed to the remote provider's name.
|
Modifier and Type | Method and Description |
---|---|
protected void |
closeStream() |
protected StreamingDataset |
data() |
void |
endReading()
If startReading was called, this function must be called (that is, it should be in a finally
block).
|
protected ProcessedHistoryColumn |
getColumn(int ndx) |
java.util.List<? extends HistoryNode> |
getColumnNodes()
Returns the HistoryNodes of this executor.
|
int |
getEffectiveWindowSizeMS()
When "natural" results are requested, this will be called to let the query executors say what they think
"natural" means.
|
boolean |
hasMore()
Returns TRUE if there is more data available to be written on call to processData()
|
void |
initialize()
Initializes the query, performing any actions necessary to get the information required to run the query.
|
protected void |
moveForward() |
long |
nextTime()
The timestamp of the next value.
|
long |
processData()
Since we load all of the data at once on start read, we return the max timestamp received here as the processed
timestamp.
|
protected void |
readColumnData() |
void |
startReading()
Begins reading data.
|
protected LoggerEx ganLogger
public RemoteTagHistoryQueryExecutor(com.inductiveautomation.metro.api.services.Service<TagHistoryService> service, java.util.List<ColumnQueryDefinition> paths, QueryController controller, LoggerEx logger)
public java.util.List<? extends HistoryNode> getColumnNodes()
HistoryQueryExecutor
DelegatingHistoryNode
s, which get filled in later.getColumnNodes
in interface HistoryQueryExecutor
public int getEffectiveWindowSizeMS()
HistoryQueryExecutor
getEffectiveWindowSizeMS
in interface HistoryQueryExecutor
protected StreamingDataset data()
protected void closeStream()
protected ProcessedHistoryColumn getColumn(int ndx)
public void initialize() throws java.lang.Exception
HistoryQueryExecutor
initialize
in interface HistoryQueryExecutor
java.lang.Exception
protected void readColumnData() throws java.lang.Exception
java.lang.Exception
protected void moveForward() throws java.lang.Exception
java.lang.Exception
public void startReading() throws java.lang.Exception
HistoryQueryExecutor
startReading
in interface HistoryQueryExecutor
java.lang.Exception
public void endReading()
HistoryQueryExecutor
endReading
in interface HistoryQueryExecutor
public boolean hasMore()
HistoryQueryExecutor
hasMore
in interface HistoryQueryExecutor
public long nextTime()
HistoryQueryExecutor
nextTime
in interface HistoryQueryExecutor
public long processData() throws java.lang.Exception
processData
in interface HistoryQueryExecutor
java.lang.Exception