Uses of Class
org.epics.archiverappliance.etl.ETLContext

Packages that use ETLContext

Package	Description
edu.stanford.slac.archiverappliance.plain
edu.stanford.slac.archiverappliance.plain.parquet
edu.stanford.slac.archiverappliance.plain.pb
org.epics.archiverappliance.common.mergededup
org.epics.archiverappliance.etl
org.epics.archiverappliance.etl.common
org.epics.archiverappliance.utils.blackhole

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

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

Modifier and Type	Method	Description
boolean	PlainStoragePlugin.appendToETLAppendData(String pvName, EventStream stream, ETLContext context)
abstract boolean	AppendDataStateData.bulkAppend(String pvName, ETLContext context, ETLBulkStream bulkStream, String extension, String extensionToCopyFrom)	Append data in bulk skipping some of the per event checks.
protected Event	AppendDataStateData.checkStream(String pvName, ETLContext context, ETLBulkStream bulkStream, Class<? extends ETLBulkStream> streamType)
boolean	PlainStoragePlugin.commitETLAppendData(String pvName, ETLContext context)
List<ETLInfo>	PlainStoragePlugin.getAllStreams(String pvName, ETLContext context)
List<ETLInfo>	PlainStoragePlugin.getETLStreams(String pvName, Instant currentTime, ETLContext context)
void	PlainStoragePlugin.markForDeletion(ETLInfo info, ETLContext context)
boolean	PlainStoragePlugin.runPostProcessors(String pvName, ArchDBRTypes dbrtype, ETLContext context)

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

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

Modifier and Type	Method	Description
boolean	ParquetAppendDataStateData.bulkAppend(String pvName, ETLContext context, ETLBulkStream bulkStream, String extension, String extensionToCopyFrom)	Performs a bulk append optimized for ETL processes.
protected ETLInfoListStatistics	ParquetETLInfoListProcessor.process(List<ETLInfo> etlInfoList, String pvName, List<ETLInfo> movedList, ETLStage etlStage, ETLContext etlContext)

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

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

Modifier and Type	Method	Description
boolean	PBAppendDataStateData.bulkAppend(String pvName, ETLContext context, ETLBulkStream bulkStream, String extension, String extensionToCopyFrom)	Append data in bulk skipping some of the per event checks.

Uses of ETLContext in org.epics.archiverappliance.common.mergededup

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

Modifier and Type	Method	Description
boolean	MergeDedupStoragePlugin.appendToETLAppendData(String pvName, EventStream stream, ETLContext context)
boolean	MergeDedupStoragePlugin.commitETLAppendData(String pvName, ETLContext context)
List<ETLInfo>	MergeDedupStoragePlugin.getAllStreams(String pv, ETLContext context)
List<ETLInfo>	MergeDedupStoragePlugin.getETLStreams(String pv, Instant currentTime, ETLContext context)
void	MergeDedupStoragePlugin.markForDeletion(ETLInfo info, ETLContext context)
boolean	MergeDedupStoragePlugin.runPostProcessors(String pvName, ArchDBRTypes dbrtype, ETLContext context)

Uses of ETLContext in org.epics.archiverappliance.etl

Methods in org.epics.archiverappliance.etl with parameters of type ETLContext

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.
boolean	ETLDest.commitETLAppendData(String pvName, ETLContext context)	This concatenates the ETL append data for a PV with the PV's destination data.
List<ETLInfo>	ETLSource.getAllStreams(String pv, ETLContext context)	Given a pv and a time, this method returns all the streams.
List<ETLInfo>	ETLSource.getETLStreams(String pv, Instant currentTime, ETLContext context)	Given a pv and a time, this method returns all the streams that are ready for ETL.
void	ETLSource.markForDeletion(ETLInfo info, ETLContext context)	Delete the ETLStream identifier by info when you can as it has already been consumed by the ETL destination.
boolean	ETLDest.runPostProcessors(String pvName, ArchDBRTypes dbrtype, ETLContext context)	Run the post processors associated with this plugin if any for this pv.

Uses of ETLContext in org.epics.archiverappliance.etl.common

Methods in org.epics.archiverappliance.etl.common with parameters of type ETLContext

Modifier and Type	Method	Description
protected ETLInfoListStatistics	DefaultETLInfoListProcessor.process(List<ETLInfo> etlInfoList, String pvName, List<ETLInfo> movedList, ETLStage etlStage, ETLContext etlContext)
protected abstract ETLInfoListStatistics	ETLInfoListProcessor.process(List<ETLInfo> etlInfoList, String pvName, List<ETLInfo> movedList, ETLStage etlStage, ETLContext etlContext)

Uses of ETLContext in org.epics.archiverappliance.utils.blackhole

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

Modifier and Type	Method	Description
boolean	BlackholeStoragePlugin.appendToETLAppendData(String pvName, EventStream stream, ETLContext context)
boolean	BlackholeStoragePlugin.commitETLAppendData(String pvName, ETLContext context)
boolean	BlackholeStoragePlugin.runPostProcessors(String pvName, ArchDBRTypes dbrtype, ETLContext context)