public class ErroredQueryExecutor extends java.lang.Object implements HistoryQueryExecutor
Constructor and Description |
---|
ErroredQueryExecutor() |
ErroredQueryExecutor(java.util.List<ColumnQueryDefinition> columns) |
Modifier and Type | Method and Description |
---|---|
void |
addErroredColumn(ColumnQueryDefinition column) |
void |
addErroredColumns(java.util.List<ColumnQueryDefinition> columns) |
void |
endReading()
If startReading was called, this function must be called (that is, it should be in a finally
block).
|
java.util.List<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.
|
long |
nextTime()
The timestamp of the next value.
|
long |
processData()
Puts the next value(s) into the appropriate column, returning the latest timestamp loaded, or -1 if no data was
loaded.
|
void |
startReading()
Begins reading data.
|
public ErroredQueryExecutor()
public ErroredQueryExecutor(java.util.List<ColumnQueryDefinition> columns)
public void addErroredColumns(java.util.List<ColumnQueryDefinition> columns)
public void addErroredColumn(ColumnQueryDefinition column)
public java.util.List<HistoryNode> getColumnNodes()
HistoryQueryExecutor
getColumnNodes
in interface HistoryQueryExecutor
public void initialize() throws java.lang.Exception
HistoryQueryExecutor
initialize
in interface HistoryQueryExecutor
java.lang.Exception
public int getEffectiveWindowSizeMS()
HistoryQueryExecutor
getEffectiveWindowSizeMS
in interface HistoryQueryExecutor
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
HistoryQueryExecutor
processData
in interface HistoryQueryExecutor
java.lang.Exception