public class QueryImpl extends Object implements Query, PVCacheListener
Constructor and Description |
---|
QueryImpl(PVCache cache) |
QueryImpl(PVCache cache,
int nbChunks) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Query can be disposed.
|
boolean |
equals(Object obj) |
PVCache |
getCache() |
List<QueryChunk> |
getChunks() |
TimeInterval |
getInterval() |
QueryResult |
getResult()
This method returns all data available for the specified
TimeInterval . |
QueryStatistics |
getStatistics() |
QueryResult |
getUpdate()
This method can be polled at regular interval and should return right
away with the data is already available, even if incomplete.
|
int |
hashCode() |
boolean |
isCompleted() |
boolean |
isProcessingData() |
void |
newDataInCache(SortedSet<Data> newData,
TimeInterval newDataInterval,
IntervalsList completedIntervals)
Informs that a new set of
Data is available in storage. |
String |
toString() |
void |
update(QueryParameters queryParameters)
Changes the parameters for the query.
|
void |
updatedCompletedIntervals(IntervalsList completedIntervals) |
public QueryImpl(PVCache cache)
public QueryImpl(PVCache cache, int nbChunks)
public void newDataInCache(SortedSet<Data> newData, TimeInterval newDataInterval, IntervalsList completedIntervals)
Data
is available in storage.newDataInCache
in interface PVCacheListener
public void updatedCompletedIntervals(IntervalsList completedIntervals)
updatedCompletedIntervals
in interface PVCacheListener
public void update(QueryParameters queryParameters)
public QueryResult getResult()
TimeInterval
.public QueryResult getUpdate()
public void close()
public boolean isCompleted()
isCompleted
in interface Query
true
if the query has finished processing.public PVCache getCache()
public TimeInterval getInterval()
public QueryStatistics getStatistics()
public List<QueryChunk> getChunks()
public boolean isProcessingData()
Copyright © 2015. All rights reserved.