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, Instant start, Instant end, PostProcessor postProcessor, BasicContext context)

Method Summary

Modifier and Type	Method	Description
RetrievalResult	call()
String	getDescription()
Instant	getEnd()
String	getPvName()
String	getPvNameFromRequest()
Instant	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 Details

UnitOfRetrieval

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

Method Details

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 Instant getStart()

getEnd

public Instant getEnd()

getPvNameFromRequest

public String getPvNameFromRequest()

wrapWithFailoverStreams

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