Uses of Interface
org.epics.archiverappliance.EventStream
-
Packages that use EventStream Package Description edu.stanford.slac.archiverappliance.PBOverHTTP Contains classes for an EventStream that is backed by a HTTP connection.edu.stanford.slac.archiverappliance.PlainPB Files supporting the PlainPBStoragePlugin; one of the main StoragePlugin's in the Archiver Appliance.org.epics.archiverappliance The interfaces inorg.epics.archiverappliance
are the main interfaces in the archiver appliance.org.epics.archiverappliance.common Contains classes and interfaces fundamental and common to all the web apps.org.epics.archiverappliance.common.mergededup org.epics.archiverappliance.engine.membuf Functionality pertaining to in memory EventStreams.org.epics.archiverappliance.etl Functionality pertaining to theetl
webapp.org.epics.archiverappliance.etl.conversion org.epics.archiverappliance.retrieval Business processes pertaining to theretrieval
webapp.org.epics.archiverappliance.retrieval.channelarchiver Classes used in fetching data from Channel Archiver XML-RPC data servers.org.epics.archiverappliance.retrieval.client Starting point for clients interested in getting data using the PB/HTTP protocol.org.epics.archiverappliance.retrieval.mimeresponses Classes and interfaces implementing the various mime responses.org.epics.archiverappliance.retrieval.postprocessors Classes and interfaces implementing the various post processors.org.epics.archiverappliance.retrieval.pva org.epics.archiverappliance.retrieval.workers Various threading schemes used in retrieval.org.epics.archiverappliance.utils.blackhole Functionality pertaining to the blackhole storage plugin.org.epics.archiverappliance.utils.imprt Classes used in the import and export of configuration.org.epics.archiverappliance.utils.simulation Classes used in testing and generation of simulated data.org.epics.archiverappliance.utils.ui Various utilities used in inter-appliance communication. -
-
Uses of EventStream in edu.stanford.slac.archiverappliance.PBOverHTTP
Classes in edu.stanford.slac.archiverappliance.PBOverHTTP that implement EventStream Modifier and Type Class Description class
InputStreamBackedEventStream
An EventStream that is backed by an arbitrary input stream.Methods in edu.stanford.slac.archiverappliance.PBOverHTTP that return types with arguments of type EventStream Modifier and Type Method Description List<Callable<EventStream>>
PBOverHTTPStoragePlugin. getDataForMultiPVs(BasicContext context, List<String> pvNames, Timestamp startTime, Timestamp endTime, PostProcessor postProcessor)
List<Callable<EventStream>>
PBOverHTTPStoragePlugin. getDataForPV(BasicContext context, String pvName, Timestamp startTime, Timestamp endTime, PostProcessor postProcessor)
Methods in edu.stanford.slac.archiverappliance.PBOverHTTP with parameters of type EventStream Modifier and Type Method Description boolean
PBOverHTTPStoragePlugin. appendData(BasicContext context, String pvName, EventStream stream)
-
Uses of EventStream in edu.stanford.slac.archiverappliance.PlainPB
Classes in edu.stanford.slac.archiverappliance.PlainPB that implement EventStream Modifier and Type Class Description class
FileBackedPBEventStream
An EventStream that is backed by a single PB file.class
MultiFilePBEventStream
An eventstream that spans multiple PB files.Methods in edu.stanford.slac.archiverappliance.PlainPB that return EventStream Modifier and Type Method Description EventStream
FileStreamCreator. getStream()
Methods in edu.stanford.slac.archiverappliance.PlainPB that return types with arguments of type EventStream Modifier and Type Method Description List<Callable<EventStream>>
PlainPBStoragePlugin. getDataForPV(BasicContext context, String pvName, Timestamp startTime, Timestamp endTime)
List<Callable<EventStream>>
PlainPBStoragePlugin. getDataForPV(BasicContext context, String pvName, Timestamp startTime, Timestamp endTime, PostProcessor postProcessor)
Methods in edu.stanford.slac.archiverappliance.PlainPB with parameters of type EventStream Modifier and Type Method Description boolean
PlainPBStoragePlugin. appendData(BasicContext context, String pvName, EventStream stream)
boolean
PlainPBStoragePlugin. appendToETLAppendData(String pvName, EventStream stream, ETLContext context)
int
AppendDataStateData. partitionBoundaryAwareAppendData(BasicContext context, String pvName, EventStream stream, String extension, String extensionToCopyFrom)
Append data into PB files honoring partition boundaries switching into new partitions as we cross the boundary. -
Uses of EventStream in org.epics.archiverappliance
Methods in org.epics.archiverappliance that return types with arguments of type EventStream Modifier and Type Method Description List<Callable<EventStream>>
Reader. getDataForPV(BasicContext context, String pvName, Timestamp startTime, Timestamp endTime, PostProcessor postProcessor)
Methods in org.epics.archiverappliance with parameters of type EventStream Modifier and Type Method Description boolean
Writer. appendData(BasicContext context, String pvName, EventStream stream)
-
Uses of EventStream in org.epics.archiverappliance.common
Classes in org.epics.archiverappliance.common that implement EventStream Modifier and Type Class Description class
EmptyEventStream
Instead of returning null, in some cases, it may be more convenient to return a EventStream with no events -
Uses of EventStream in org.epics.archiverappliance.common.mergededup
Classes in org.epics.archiverappliance.common.mergededup that implement EventStream Modifier and Type Class Description class
MergeDedupEventStream
EventStream that is constructed with two source EventStream's ( for the same PV ) and then return's a merged-deduped stream of Events.class
MergeDedupWithCallablesEventStream
This is almost idential to the MergeDedupEventStream; expect it takes as its first argument a list of EventStream callables which it then merges with the second EventStreamclass
TimeSpanLimitEventStream
An EventStream that wraps another event stream but limits the data to samples greater than or equal to a specified start time and less than or equal to a specified end time.Methods in org.epics.archiverappliance.common.mergededup that return types with arguments of type EventStream Modifier and Type Method Description List<Callable<EventStream>>
MergeDedupStoragePlugin. getDataForPV(BasicContext context, String pvName, Timestamp startTime, Timestamp endTime, PostProcessor postProcessor)
Methods in org.epics.archiverappliance.common.mergededup with parameters of type EventStream Modifier and Type Method Description boolean
MergeDedupStoragePlugin. appendData(BasicContext context, String pvName, EventStream stream)
boolean
MergeDedupStoragePlugin. appendToETLAppendData(String pvName, EventStream stream, ETLContext context)
Constructors in org.epics.archiverappliance.common.mergededup with parameters of type EventStream Constructor Description MergeDedupEventStream(EventStream stream1, EventStream stream2)
MergeDedupWithCallablesEventStream(List<Callable<EventStream>> clbs, EventStream stream2, PostProcessor postProcessor)
TimeSpanLimitEventStream(EventStream srcStream, long startEpoch, long endEpoch)
TimeSpanLimitEventStream(EventStream srcStream, Timestamp startTime, Timestamp endTime)
Constructor parameters in org.epics.archiverappliance.common.mergededup with type arguments of type EventStream Constructor Description MergeDedupWithCallablesEventStream(List<Callable<EventStream>> clbs1, List<Callable<EventStream>> clbs2)
MergeDedupWithCallablesEventStream(List<Callable<EventStream>> clbs, EventStream stream2, PostProcessor postProcessor)
-
Uses of EventStream in org.epics.archiverappliance.engine.membuf
Classes in org.epics.archiverappliance.engine.membuf that implement EventStream Modifier and Type Class Description class
ArrayListEventStream
Implements an event stream on top of an arraylist -
Uses of EventStream in org.epics.archiverappliance.etl
Subinterfaces of EventStream in org.epics.archiverappliance.etl Modifier and Type Interface Description interface
ETLBulkStream
Event streams can optionally implement bulk transfer friendly methods.Methods in org.epics.archiverappliance.etl that return EventStream Modifier and Type Method Description EventStream
ConversionFunction. convertStream(EventStream srcEventStream, Timestamp streamStartTime, Timestamp streamEndTime)
EventStream
ETLInfo. getEv()
EventStream
ETLStreamCreator. getStream()
Methods in org.epics.archiverappliance.etl with parameters of type EventStream Modifier and Type Method Description boolean
ETLDest. appendToETLAppendData(String pvName, EventStream stream, ETLContext context)
This appends an EventStream to the ETL append data for a PV.EventStream
ConversionFunction. convertStream(EventStream srcEventStream, Timestamp streamStartTime, Timestamp streamEndTime)
boolean
ConversionFunction. shouldConvert(EventStream srcEventStream, Timestamp streamStartTime, Timestamp streamEndTime)
-
Uses of EventStream in org.epics.archiverappliance.etl.conversion
Methods in org.epics.archiverappliance.etl.conversion that return EventStream Modifier and Type Method Description EventStream
ThruNumberAndStringConversion. convertStream(EventStream srcEventStream, Timestamp streamStartTime, Timestamp streamEndTime)
Methods in org.epics.archiverappliance.etl.conversion with parameters of type EventStream Modifier and Type Method Description EventStream
ThruNumberAndStringConversion. convertStream(EventStream srcEventStream, Timestamp streamStartTime, Timestamp streamEndTime)
boolean
ThruNumberAndStringConversion. shouldConvert(EventStream srcEventStream, Timestamp streamStartTime, Timestamp streamEndTime)
-
Uses of EventStream in org.epics.archiverappliance.retrieval
Methods in org.epics.archiverappliance.retrieval that return EventStream Modifier and Type Method Description EventStream
CallableEventStream. call()
Methods in org.epics.archiverappliance.retrieval that return types with arguments of type EventStream Modifier and Type Method Description List<Callable<EventStream>>
RetrievalResult. getResultStreams()
static Callable<EventStream>
CallableEventStream. makeOneEventCallable(Event ev, RemotableEventStreamDesc desc, PostProcessor postProcessor, boolean wrapWithPostProcessor)
static Callable<EventStream>
CallableEventStream. makeOneStreamCallable(EventStream st, PostProcessor postProcessor, boolean wrapWithPostProcessor)
static List<Callable<EventStream>>
CallableEventStream. makeOneStreamCallableList(EventStream st)
static List<Callable<EventStream>>
CallableEventStream. makeOneStreamCallableList(EventStream st, PostProcessor postProcessor, boolean wrapWithPostProcessor)
Methods in org.epics.archiverappliance.retrieval with parameters of type EventStream Modifier and Type Method Description void
EventStreamConsumer. consumeEventStream(EventStream e)
static Callable<EventStream>
CallableEventStream. makeOneStreamCallable(EventStream st, PostProcessor postProcessor, boolean wrapWithPostProcessor)
static List<Callable<EventStream>>
CallableEventStream. makeOneStreamCallableList(EventStream st)
static List<Callable<EventStream>>
CallableEventStream. makeOneStreamCallableList(EventStream st, PostProcessor postProcessor, boolean wrapWithPostProcessor)
Method parameters in org.epics.archiverappliance.retrieval with type arguments of type EventStream Modifier and Type Method Description void
UnitOfRetrieval. wrapWithFailoverStreams(List<Callable<EventStream>> failoverStrms)
Constructors in org.epics.archiverappliance.retrieval with parameters of type EventStream Constructor Description CallableEventStream(EventStream st)
Constructor parameters in org.epics.archiverappliance.retrieval with type arguments of type EventStream Constructor Description RetrievalResult(List<Callable<EventStream>> strms, UnitOfRetrieval retrievalRequest)
-
Uses of EventStream in org.epics.archiverappliance.retrieval.channelarchiver
Classes in org.epics.archiverappliance.retrieval.channelarchiver that implement EventStream Modifier and Type Class Description class
ArchiverValuesHandler
Methods in org.epics.archiverappliance.retrieval.channelarchiver that return types with arguments of type EventStream Modifier and Type Method Description List<Callable<EventStream>>
ChannelArchiverReadOnlyPlugin. getDataForPV(BasicContext context, String pvName, Timestamp startTime, Timestamp endTime, PostProcessor postProcessor)
Methods in org.epics.archiverappliance.retrieval.channelarchiver with parameters of type EventStream Modifier and Type Method Description boolean
ChannelArchiverReadOnlyPlugin. appendData(BasicContext context, String pvName, EventStream stream)
-
Uses of EventStream in org.epics.archiverappliance.retrieval.client
Methods in org.epics.archiverappliance.retrieval.client that return EventStream Modifier and Type Method Description EventStream
DataRetrieval. getDataForPVS(String[] pvNames, Timestamp startTime, Timestamp endTime, RetrievalEventProcessor retrievalEventProcessor)
Get data for multiple PVs from starttime to endtime.EventStream
DataRetrieval. getDataForPVS(String[] pvNames, Timestamp startTime, Timestamp endTime, RetrievalEventProcessor retrievalEventProcessor, boolean useReducedDataSet)
Get data for multiple PVs from starttime to endtime.EventStream
DataRetrieval. getDataForPVS(String[] pvNames, Timestamp startTime, Timestamp endTime, RetrievalEventProcessor retrievalEventProcessor, boolean useReducedDataSet, HashMap<String,String> otherParams)
Get data for multiple PVs from starttime to endtime.EventStream
RawDataRetrievalAsEventStream. getDataForPVS(String[] pvNames, Timestamp startTime, Timestamp endTime, RetrievalEventProcessor retrievalEventProcessor)
EventStream
RawDataRetrievalAsEventStream. getDataForPVS(String[] pvNames, Timestamp startTime, Timestamp endTime, RetrievalEventProcessor retrievalEventProcessor, boolean useReducedDataSet)
EventStream
RawDataRetrievalAsEventStream. getDataForPVS(String[] pvNames, Timestamp startTime, Timestamp endTime, RetrievalEventProcessor retrievalEventProcessor, boolean useReducedDataSet, HashMap<String,String> otherParams)
-
Uses of EventStream in org.epics.archiverappliance.retrieval.mimeresponses
Methods in org.epics.archiverappliance.retrieval.mimeresponses with parameters of type EventStream Modifier and Type Method Description void
FlxXMLResponse. swicthingToStream(EventStream strm)
void
JPlotResponse. swicthingToStream(EventStream strm)
void
JSONResponse. swicthingToStream(EventStream strm)
void
MatlabResponse. swicthingToStream(EventStream strm)
void
MimeResponse. swicthingToStream(EventStream strm)
void
PBRAWResponse. swicthingToStream(EventStream strm)
void
QWResponse. swicthingToStream(EventStream strm)
void
SinglePVCSVResponse. swicthingToStream(EventStream strm)
void
SVGResponse. swicthingToStream(EventStream strm)
void
TextResponse. swicthingToStream(EventStream strm)
-
Uses of EventStream in org.epics.archiverappliance.retrieval.postprocessors
Classes in org.epics.archiverappliance.retrieval.postprocessors that implement EventStream Modifier and Type Class Description class
ArrayListCollectorEventStream
An event stream that wraps an ArrayList event stream; use this if the data in your consolidated results do not fit a clean binning pattern and you need to return results that span multiple years.class
FillsCollectorEventStream
This is similar to the summary stats collector except we keep aspects of the original event stream like dbr_type and so on.class
SummaryStatsCollectorEventStream
An event stream over a list of SummaryStatsCollectors; typically used by post processors that return consolidated results.Methods in org.epics.archiverappliance.retrieval.postprocessors that return EventStream Modifier and Type Method Description EventStream
AfterAllStreams. anyFinalData()
EventStream
FirstSamplePP. anyFinalData()
EventStream
CAPlotBinning. getConsolidatedEventStream()
EventStream
FirstFill. getConsolidatedEventStream()
EventStream
LastFill. getConsolidatedEventStream()
EventStream
LastSample. getConsolidatedEventStream()
EventStream
NCount. getConsolidatedEventStream()
EventStream
Nth. getConsolidatedEventStream()
EventStream
Optimized. getConsolidatedEventStream()
EventStream
OptimizedWithLastSample. getConsolidatedEventStream()
EventStream
PostProcessorWithConsolidatedEventStream. getConsolidatedEventStream()
EventStream
SummaryStatsPostProcessor. getConsolidatedEventStream()
-
Uses of EventStream in org.epics.archiverappliance.retrieval.pva
Methods in org.epics.archiverappliance.retrieval.pva with parameters of type EventStream Modifier and Type Method Description void
PvaMergeDedupConsumer. consumeEventStream(EventStream strm)
void
PvaMimeResponse. swicthingToStream(EventStream strm)
-
Uses of EventStream in org.epics.archiverappliance.retrieval.workers
Classes in org.epics.archiverappliance.retrieval.workers that implement EventStream Modifier and Type Class Description class
CurrentThreadWorkerEventStream
Expands the results from a Reader using the current thread.Constructor parameters in org.epics.archiverappliance.retrieval.workers with type arguments of type EventStream Constructor Description CurrentThreadWorkerEventStream(String pvName, List<Callable<EventStream>> streams)
-
Uses of EventStream in org.epics.archiverappliance.utils.blackhole
Methods in org.epics.archiverappliance.utils.blackhole that return types with arguments of type EventStream Modifier and Type Method Description List<Callable<EventStream>>
BlackholeStoragePlugin. getDataForPV(BasicContext context, String pvName, Timestamp startTime, Timestamp endTime, PostProcessor postProcessor)
Methods in org.epics.archiverappliance.utils.blackhole with parameters of type EventStream Modifier and Type Method Description boolean
BlackholeStoragePlugin. appendData(BasicContext context, String pvName, EventStream stream)
boolean
BlackholeStoragePlugin. appendToETLAppendData(String pvName, EventStream stream, ETLContext context)
-
Uses of EventStream in org.epics.archiverappliance.utils.imprt
Classes in org.epics.archiverappliance.utils.imprt that implement EventStream Modifier and Type Class Description class
CSVEventStream
An event stream backed by a CSV file. -
Uses of EventStream in org.epics.archiverappliance.utils.simulation
Classes in org.epics.archiverappliance.utils.simulation that implement EventStream Modifier and Type Class Description class
SimulationEventStream
An EventStream that backed by a generator. -
Uses of EventStream in org.epics.archiverappliance.utils.ui
Methods in org.epics.archiverappliance.utils.ui with parameters of type EventStream Modifier and Type Method Description static int
StreamPBIntoOutput. streamPBIntoOutputStream(EventStream st, OutputStream os, Timestamp start, Timestamp end)
Push the events in st into the output stream os.
-