Package org.epics.archiverappliance.etl.common

Class ETLJob

java.lang.Object

org.epics.archiverappliance.etl.common.ETLJob

All Implemented Interfaces:

Runnable

public class ETLJob
extends Object
implements Runnable

We schedule a ETLPVLookupItems with the appropriate thread using an ETLJob

Author:

mshankar

Constructor Summary

Constructors

Constructor	Description
ETLJob(ETLPVLookupItems lookupItem)
ETLJob(ETLPVLookupItems lookupItem, Instant runAsIfAtTime)	Mostly used by ETL unit tests.

Method Summary

Modifier and Type	Method	Description
Exception	getExceptionFromLastRun()	Was there an exception in the last ETL run for this job Mostly used by unit tests.
void	processETL(Instant processingTime)	Main ETL algorithm.
void	run()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ETLJob

public ETLJob(ETLPVLookupItems lookupItem)

ETLJob

public ETLJob(ETLPVLookupItems lookupItem,
 Instant runAsIfAtTime)

Mostly used by ETL unit tests.

Parameters:

lookupItem - ETLPVLookupItems

runAsIfAtTime - Instant

Method Details

run

public void run()

Specified by:

run in interface Runnable

processETL

public void processETL(Instant processingTime)
                throws IOException

Main ETL algorithm.

Parameters:

processingTime - Typically we'd use TimeUtils.now() for this. However, we can also run as if it's a certain time by using this parameter.

Throws:

IOException -  

getExceptionFromLastRun

public Exception getExceptionFromLastRun()

Was there an exception in the last ETL run for this job Mostly used by unit tests.

Returns:

exceptionFromLastRun