Package org.epics.archiverappliance.retrieval.client

Class RawDataRetrievalAsEventStream

java.lang.Object

org.epics.archiverappliance.retrieval.client.RawDataRetrievalAsEventStream

All Implemented Interfaces:

DataRetrievalForPVs

public class RawDataRetrievalAsEventStream
extends Object
implements DataRetrievalForPVs

Client side class for retrieving data from the appliance archiver using the PB over HTTP protocol. This is mostly used by the unit tests where the ability to treat retrieval results as event streams is veru useful. Java clients should use the pbrawclient which is a lightweight implementation of the same.

Author:

mshankar

Constructor Summary

Constructors

Constructor	Description
RawDataRetrievalAsEventStream(String accessURL)

Method Summary

Modifier and Type	Method	Description
EventStream	getDataForPVS(String[] pvNames, Instant startTime, Instant endTime, RetrievalEventProcessor retrievalEventProcessor)	Get data for multiple PVs from starttime to endtime.
EventStream	getDataForPVS(String[] pvNames, Instant startTime, Instant endTime, RetrievalEventProcessor retrievalEventProcessor, boolean useReducedDataSet)	Get data for multiple PVs from starttime to endtime.
EventStream	getDataForPVS(String[] pvNames, Instant startTime, Instant endTime, RetrievalEventProcessor retrievalEventProcessor, boolean useReducedDataSet, HashMap<String,String> otherParams)	Get data for multiple PVs from starttime to endtime.

Methods inherited from class java.lang.Object

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

Constructor Details

RawDataRetrievalAsEventStream

public RawDataRetrievalAsEventStream(String accessURL)

Method Details

getDataForPVS

public EventStream getDataForPVS(String[] pvNames,
 Instant startTime,
 Instant endTime,
 RetrievalEventProcessor retrievalEventProcessor)

Description copied from interface: DataRetrievalForPVs

Get data for multiple PVs from starttime to endtime. Pass out-of-band events into the supplied retrievalEventProcessor We default to getting raw data

Specified by:

getDataForPVS in interface DataRetrievalForPVs

Parameters:

pvNames - The name of PVs

startTime - Instant

endTime - Instant

retrievalEventProcessor - RetrievalEventProcessor

Returns:

EventStream Data for PVs  

getDataForPVS

public EventStream getDataForPVS(String[] pvNames,
 Instant startTime,
 Instant endTime,
 RetrievalEventProcessor retrievalEventProcessor,
 boolean useReducedDataSet)

Description copied from interface: DataRetrievalForPVs

Get data for multiple PVs from starttime to endtime. Pass out-of-band events into the supplied retrievalEventProcessor

Specified by:

getDataForPVS in interface DataRetrievalForPVs

Parameters:

pvNames - The name of PVs

startTime - Instant

endTime - Instant

retrievalEventProcessor - RetrievalEventProcessor

useReducedDataSet - Is it ok to use a reduced data set?

Returns:

EventStream Data for PVs

getDataForPVS

public EventStream getDataForPVS(String[] pvNames,
 Instant startTime,
 Instant endTime,
 RetrievalEventProcessor retrievalEventProcessor,
 boolean useReducedDataSet,
 HashMap<String,String> otherParams)

Description copied from interface: DataRetrievalForPVs

Get data for multiple PVs from starttime to endtime. Pass out-of-band events into the supplied retrievalEventProcessor

Specified by:

getDataForPVS in interface DataRetrievalForPVs

Parameters:

pvNames - The name of PVs

startTime - Instant

endTime - Instant

retrievalEventProcessor - RetrievalEventProcessor

useReducedDataSet - Is it ok to use a reduced data set?

otherParams - Any other name/value pairs that are passed onto the server.

Returns:

EventStream Data for PVs