Package org.epics.archiverappliance.retrieval

Class UnitOfRetrieval

java.lang.Object

org.epics.archiverappliance.retrieval.UnitOfRetrieval

All Implemented Interfaces:

Callable<RetrievalResult>

public class UnitOfRetrieval
extends Object
implements Callable<RetrievalResult>

Author:

mshankar This class encapsulates a storage plugin, a PVName, a start time and an end time (all the items needed to make a getDataForPV call). The retrieval servlet creates multiple UnitOfRetrieval's, one or more for each storage plugin. Some variation of a ExecutorService is expected to be used to launch the UnitOfRetrievals in parallel and then push the event streams into the consumer.

Constructor Summary

Constructors

Constructor	Description
UnitOfRetrieval(String desc, Reader reader, String pvName, String pvNameFromRequest, Timestamp start, Timestamp end, PostProcessor postProcessor, BasicContext context)

Method Summary

Modifier and Type	Method	Description
RetrievalResult	call()
String	getDescription()
Timestamp	getEnd()
String	getPvName()
String	getPvNameFromRequest()
Timestamp	getStart()
void	wrapWithFailoverStreams(List<Callable<EventStream>> failoverStrms)

Methods inherited from class java.lang.Object

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

Constructor Detail

UnitOfRetrieval

public UnitOfRetrieval(String desc,
                       Reader reader,
                       String pvName,
                       String pvNameFromRequest,
                       Timestamp start,
                       Timestamp end,
                       PostProcessor postProcessor,
                       BasicContext context)

Method Detail

call

public RetrievalResult call()
                     throws IOException

Specified by:

call in interface Callable<RetrievalResult>

Throws:

IOException

getDescription

public String getDescription()

getPvName

public String getPvName()

getStart

public Timestamp getStart()

getEnd

public Timestamp getEnd()

getPvNameFromRequest

public String getPvNameFromRequest()

wrapWithFailoverStreams

public void wrapWithFailoverStreams(List<Callable<EventStream>> failoverStrms)