org.epics.pvmanager.timecache.query

Class QueryImpl

java.lang.Object

org.epics.pvmanager.timecache.query.QueryImpl

All Implemented Interfaces:

PVCacheListener, Query

public class QueryImpl
extends Object
implements Query, PVCacheListener

Author:

Fred Arnaud (Sopra Group) - ITER

Constructor Summary

Constructors

Constructor and Description
QueryImpl(PVCache cache)

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Query can be disposed.
PVCache	getCache()
QueryResult	getResult() This method returns all data available for the specified TimeInterval.
QueryResult	getUpdate() This method can be polled at regular interval and should return right away with the data is already available, even if incomplete.
boolean	isComplete()
void	newData(SortedSet<Data> datas) Informs that a new set of Data is available in storage.
void	update(QueryParameters queryParameters) Changes the parameters for the query.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

QueryImpl

public QueryImpl(PVCache cache)

Method Detail

newData

public void newData(SortedSet<Data> datas)

Informs that a new set of Data is available in storage.

Specified by:

newData in interface PVCacheListener

update

public void update(QueryParameters queryParameters)

Changes the parameters for the query. This method is thread safe and returns immediately. It may schedule asynchronous execution of service calls to fetch the data.

Specified by:

update in interface Query

getResult

public QueryResult getResult()

This method returns all data available for the specified TimeInterval.

Specified by:

getResult in interface Query

getUpdate

public QueryResult getUpdate()

This method can be polled at regular interval and should return right away with the data is already available, even if incomplete.

Specified by:

getUpdate in interface Query

close

public void close()

Query can be disposed. Future calls to getResult() and getUpdate() will result in IllegalStateException.

Specified by:

close in interface Query

getCache

public PVCache getCache()

isComplete

public boolean isComplete()