Uses of Interface
org.epics.archiverappliance.EventStream

Packages that use EventStream

Package	Description
edu.stanford.slac.archiverappliance.PBOverHTTP
edu.stanford.slac.archiverappliance.plain
edu.stanford.slac.archiverappliance.plain.parquet
edu.stanford.slac.archiverappliance.plain.pb
org.epics.archiverappliance
org.epics.archiverappliance.common
org.epics.archiverappliance.common.mergededup
org.epics.archiverappliance.engine.membuf
org.epics.archiverappliance.etl
org.epics.archiverappliance.etl.conversion
org.epics.archiverappliance.retrieval
org.epics.archiverappliance.retrieval.channelarchiver
org.epics.archiverappliance.retrieval.client
org.epics.archiverappliance.retrieval.mimeresponses
org.epics.archiverappliance.retrieval.postprocessors
org.epics.archiverappliance.retrieval.pva
org.epics.archiverappliance.retrieval.workers
org.epics.archiverappliance.utils.blackhole
org.epics.archiverappliance.utils.imprt
org.epics.archiverappliance.utils.simulation
org.epics.archiverappliance.utils.ui

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, Instant startTime, Instant endTime, PostProcessor postProcessor)
List<Callable<EventStream>>	PBOverHTTPStoragePlugin.getDataForPV(BasicContext context, String pvName, Instant startTime, Instant endTime, PostProcessor postProcessor)

Methods in edu.stanford.slac.archiverappliance.PBOverHTTP with parameters of type EventStream

Modifier and Type	Method	Description
int	PBOverHTTPStoragePlugin.appendData(BasicContext context, String pvName, EventStream stream)

Uses of EventStream in edu.stanford.slac.archiverappliance.plain

Methods in edu.stanford.slac.archiverappliance.plain that return EventStream

Modifier and Type	Method	Description
EventStream	PlainETLStreamCreator.getStream()
EventStream	PlainStreams.getStream(String pvName, Path path, ArchDBRTypes dbrType)
EventStream	PlainStreams.getTimeStream(String pvName, Path path, Instant start, Instant end, boolean skipSearch, FileInfo fileInfo)
EventStream	PlainStreams.getTimeStream(String pvName, Path path, ArchDBRTypes dbrType, Instant start, Instant end, boolean skipSearch)

Methods in edu.stanford.slac.archiverappliance.plain that return types with arguments of type EventStream

Modifier and Type	Method	Description
List<Callable<EventStream>>	PlainStoragePlugin.getDataForPV(BasicContext context, String pvName, Instant startTime, Instant endTime)
List<Callable<EventStream>>	PlainStoragePlugin.getDataForPV(BasicContext context, String pvName, Instant startTime, Instant endTime, PostProcessor postProcessor)

Methods in edu.stanford.slac.archiverappliance.plain with parameters of type EventStream

Modifier and Type	Method	Description
int	PlainStoragePlugin.appendData(BasicContext context, String pvName, EventStream stream)
boolean	PlainStoragePlugin.appendToETLAppendData(String pvName, EventStream stream, ETLContext context)
protected abstract EventFileWriter	AppendDataStateData.createNewWriter(String pvName, Path pvPath, EventStream stream)
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.
protected Path	AppendDataStateData.preparePartition(String pvName, EventStream stream, BasicContext context, String extension, String extensionToCopyFrom, Instant ts, Path pvPath, PathResolver pathResolver)	Prepare a new partition.
default void	EventFileWriter.writeStreamToFile(EventStream stream)	Write the entire stream to the file.

Uses of EventStream in edu.stanford.slac.archiverappliance.plain.parquet

Subinterfaces of EventStream in edu.stanford.slac.archiverappliance.plain.parquet

Modifier and Type	Interface	Description
interface	ETLParquetFilesStream	ETL Parquet files stream, provides access to the list of parquet files for combination.

Classes in edu.stanford.slac.archiverappliance.plain.parquet that implement EventStream

Modifier and Type	Class	Description
class	ParquetBackedPBEventFileStream	An EventStream implementation that reads data from one or more Parquet files.

Methods in edu.stanford.slac.archiverappliance.plain.parquet that return EventStream

Modifier and Type	Method	Description
EventStream	ParquetPlainFileHandler.getStream(String pvName, Path path, ArchDBRTypes dbrType)
EventStream	ParquetPlainFileHandler.getTimeStream(String pvName, Path path, Instant start, Instant end, boolean skipSearch, FileInfo fileInfo)
EventStream	ParquetPlainFileHandler.getTimeStream(String pvName, Path path, ArchDBRTypes dbrType, Instant start, Instant end, boolean skipSearch)

Methods in edu.stanford.slac.archiverappliance.plain.parquet with parameters of type EventStream

Modifier and Type	Method	Description
protected EventFileWriter	ParquetAppendDataStateData.createNewWriter(String pvName, Path pvPath, EventStream stream)

Uses of EventStream in edu.stanford.slac.archiverappliance.plain.pb

Subinterfaces of EventStream in edu.stanford.slac.archiverappliance.plain.pb

Modifier and Type	Interface	Description
interface	ETLPBByteStream	Event streams can optionally implement bulk transfer friendly methods.

Classes in edu.stanford.slac.archiverappliance.plain.pb that implement EventStream

Modifier and Type	Class	Description
class	ArrayListEventStreamWithPositionedIterator
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.plain.pb that return EventStream

Modifier and Type	Method	Description
EventStream	PBPlainFileHandler.getStream(String pvName, Path path, ArchDBRTypes dbrType)
static EventStream	PBPlainFileHandler.getStreamForIteration(String pvName, Path path, Instant startAtTime, ArchDBRTypes archDBRTypes, BiDirectionalIterable.IterationDirection direction)
EventStream	PBPlainFileHandler.getTimeStream(String pvName, Path path, Instant start, Instant end, boolean skipSearch, FileInfo fileInfo)
EventStream	PBPlainFileHandler.getTimeStream(String pvName, Path path, ArchDBRTypes dbrType, Instant start, Instant end, boolean skipSearch)

Methods in edu.stanford.slac.archiverappliance.plain.pb with parameters of type EventStream

Modifier and Type	Method	Description
protected EventFileWriter	PBAppendDataStateData.createNewWriter(String pvName, Path pvPath, EventStream stream)	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, Instant startTime, Instant endTime, PostProcessor postProcessor)

Methods in org.epics.archiverappliance with parameters of type EventStream

Modifier and Type	Method	Description
int	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 EventStream
class	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, Instant startTime, Instant endTime, PostProcessor postProcessor)

Methods in org.epics.archiverappliance.common.mergededup with parameters of type EventStream

Modifier and Type	Method	Description
int	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

Modifier	Constructor	Description
	MergeDedupEventStream(EventStream stream1, EventStream stream2)
	MergeDedupWithCallablesEventStream(List<Callable<EventStream>> clbs, EventStream stream2, PostProcessor postProcessor)
	TimeSpanLimitEventStream(EventStream srcStream, Instant startTime, Instant endTime)

Constructor parameters in org.epics.archiverappliance.common.mergededup with type arguments of type EventStream

Modifier	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, Instant streamStartTime, Instant 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, Instant streamStartTime, Instant streamEndTime)
boolean	ConversionFunction.shouldConvert(EventStream srcEventStream, Instant streamStartTime, Instant 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, Instant streamStartTime, Instant streamEndTime)

Methods in org.epics.archiverappliance.etl.conversion with parameters of type EventStream

Modifier and Type	Method	Description
EventStream	ThruNumberAndStringConversion.convertStream(EventStream srcEventStream, Instant streamStartTime, Instant streamEndTime)
boolean	ThruNumberAndStringConversion.shouldConvert(EventStream srcEventStream, Instant streamStartTime, Instant 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

Modifier	Constructor	Description
	CallableEventStream(EventStream st)

Constructor parameters in org.epics.archiverappliance.retrieval with type arguments of type EventStream

Modifier	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	Quick handler to parse archiver.values returns.

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, Instant startTime, Instant endTime, PostProcessor postProcessor)

Methods in org.epics.archiverappliance.retrieval.channelarchiver with parameters of type EventStream

Modifier and Type	Method	Description
int	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	DataRetrievalForPVs.getDataForPVS(String[] pvNames, Instant startTime, Instant endTime, RetrievalEventProcessor retrievalEventProcessor)	Get data for multiple PVs from starttime to endtime.
EventStream	DataRetrievalForPVs.getDataForPVS(String[] pvNames, Instant startTime, Instant endTime, RetrievalEventProcessor retrievalEventProcessor, boolean useReducedDataSet)	Get data for multiple PVs from starttime to endtime.
EventStream	DataRetrievalForPVs.getDataForPVS(String[] pvNames, Instant startTime, Instant endTime, RetrievalEventProcessor retrievalEventProcessor, boolean useReducedDataSet, HashMap<String,String> otherParams)	Get data for multiple PVs from starttime to endtime.
EventStream	RawDataRetrievalAsEventStream.getDataForPVS(String[] pvNames, Instant startTime, Instant endTime, RetrievalEventProcessor retrievalEventProcessor)
EventStream	RawDataRetrievalAsEventStream.getDataForPVS(String[] pvNames, Instant startTime, Instant endTime, RetrievalEventProcessor retrievalEventProcessor, boolean useReducedDataSet)
EventStream	RawDataRetrievalAsEventStream.getDataForPVS(String[] pvNames, Instant startTime, Instant 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()

Methods in org.epics.archiverappliance.retrieval.postprocessors that return types with arguments of type EventStream

Modifier and Type	Method	Description
Callable<EventStream>	OptimizedWithLastSample.customStatsWrap(Callable<EventStream> callable)
Callable<EventStream>	CAPlotBinning.wrap(Callable<EventStream> callable)
Callable<EventStream>	DeadBand.wrap(Callable<EventStream> callable)
Callable<EventStream>	DefaultRawPostProcessor.wrap(Callable<EventStream> callable)
Callable<EventStream>	ExtraFieldsPostProcessor.wrap(Callable<EventStream> callable)
Callable<EventStream>	FirstFill.wrap(Callable<EventStream> callable)
Callable<EventStream>	FirstSamplePP.wrap(Callable<EventStream> callable)
Callable<EventStream>	Fliers.wrap(Callable<EventStream> callable)
Callable<EventStream>	IgnoreFliers.wrap(Callable<EventStream> callable)
Callable<EventStream>	LastFill.wrap(Callable<EventStream> callable)
Callable<EventStream>	LastSample.wrap(Callable<EventStream> callable)
Callable<EventStream>	NCount.wrap(Callable<EventStream> callable)
Callable<EventStream>	Nth.wrap(Callable<EventStream> callable)
Callable<EventStream>	Optimized.wrap(Callable<EventStream> callable)
Callable<EventStream>	OptimizedWithLastSample.wrap(Callable<EventStream> callable)
Callable<EventStream>	PostProcessor.wrap(Callable<EventStream> callable)	Primary data generation method.
Callable<EventStream>	SummaryStatsPostProcessor.wrap(Callable<EventStream> callable)
Callable<EventStream>	TwoWeekRaw.wrap(Callable<EventStream> callable)

Method parameters in org.epics.archiverappliance.retrieval.postprocessors with type arguments of type EventStream

Modifier and Type	Method	Description
Callable<EventStream>	OptimizedWithLastSample.customStatsWrap(Callable<EventStream> callable)
Callable<EventStream>	CAPlotBinning.wrap(Callable<EventStream> callable)
Callable<EventStream>	DeadBand.wrap(Callable<EventStream> callable)
Callable<EventStream>	DefaultRawPostProcessor.wrap(Callable<EventStream> callable)
Callable<EventStream>	ExtraFieldsPostProcessor.wrap(Callable<EventStream> callable)
Callable<EventStream>	FirstFill.wrap(Callable<EventStream> callable)
Callable<EventStream>	FirstSamplePP.wrap(Callable<EventStream> callable)
Callable<EventStream>	Fliers.wrap(Callable<EventStream> callable)
Callable<EventStream>	IgnoreFliers.wrap(Callable<EventStream> callable)
Callable<EventStream>	LastFill.wrap(Callable<EventStream> callable)
Callable<EventStream>	LastSample.wrap(Callable<EventStream> callable)
Callable<EventStream>	NCount.wrap(Callable<EventStream> callable)
Callable<EventStream>	Nth.wrap(Callable<EventStream> callable)
Callable<EventStream>	Optimized.wrap(Callable<EventStream> callable)
Callable<EventStream>	OptimizedWithLastSample.wrap(Callable<EventStream> callable)
Callable<EventStream>	PostProcessor.wrap(Callable<EventStream> callable)	Primary data generation method.
Callable<EventStream>	SummaryStatsPostProcessor.wrap(Callable<EventStream> callable)
Callable<EventStream>	TwoWeekRaw.wrap(Callable<EventStream> callable)

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

Modifier	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, Instant startTime, Instant endTime, PostProcessor postProcessor)

Methods in org.epics.archiverappliance.utils.blackhole with parameters of type EventStream

Modifier and Type	Method	Description
int	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, Instant start, Instant end)	Push the events in st into the output stream os.