Uses of Class
org.epics.archiverappliance.etl.ETLContext
-
Packages that use ETLContext Package Description edu.stanford.slac.archiverappliance.PlainPB Files supporting the PlainPBStoragePlugin; one of the main StoragePlugin's in the Archiver Appliance.org.epics.archiverappliance.common.mergededup org.epics.archiverappliance.etl Functionality pertaining to theetl
webapp.org.epics.archiverappliance.utils.blackhole Functionality pertaining to the blackhole storage plugin. -
-
Uses of ETLContext in edu.stanford.slac.archiverappliance.PlainPB
Methods in edu.stanford.slac.archiverappliance.PlainPB with parameters of type ETLContext Modifier and Type Method Description boolean
PlainPBStoragePlugin. appendToETLAppendData(String pvName, EventStream stream, ETLContext context)
boolean
AppendDataStateData. bulkAppend(String pvName, ETLContext context, ETLBulkStream bulkStream, String extension, String extensionToCopyFrom)
Append data in bulk skipping some of the per event checks.boolean
PlainPBStoragePlugin. commitETLAppendData(String pvName, ETLContext context)
List<ETLInfo>
PlainPBStoragePlugin. getETLStreams(String pvName, Timestamp currentTime, ETLContext context)
void
PlainPBStoragePlugin. markForDeletion(ETLInfo info, ETLContext context)
boolean
PlainPBStoragePlugin. prepareForNewPartition(String pvName, Event ev, ArchDBRTypes archDBRType, ETLContext context)
boolean
PlainPBStoragePlugin. runPostProcessors(String pvName, ArchDBRTypes dbrtype, ETLContext context)
-
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. getETLStreams(String pv, Timestamp currentTime, ETLContext context)
void
MergeDedupStoragePlugin. markForDeletion(ETLInfo info, ETLContext context)
boolean
MergeDedupStoragePlugin. prepareForNewPartition(String pvName, Event ev, ArchDBRTypes archDBRType, 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. getETLStreams(String pv, Timestamp 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. prepareForNewPartition(String pvName, Event ev, ArchDBRTypes archDBRType, ETLContext context)
This informs the destination that we are switching to a new partition and this dest needs to execute its pre-processing for a new partition.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.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. prepareForNewPartition(String pvName, Event ev, ArchDBRTypes archDBRType, ETLContext context)
boolean
BlackholeStoragePlugin. runPostProcessors(String pvName, ArchDBRTypes dbrtype, ETLContext context)
-