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

An ETLJob does the actual work of moving data from one data source to another. This is a runnable, we expect to execute this on some executor.

Author:

mshankar

Constructor Summary

Constructors

Constructor	Description
ETLJob(ETLStage etlStage, Instant runAsIfAtTime, ConfigService configService)
ETLJob(ETLStage etlStage, Instant runAsIfAtTime, ConfigService configService, boolean allData)

Method Summary

Modifier and Type	Method	Description
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(ETLStage etlStage,
 Instant runAsIfAtTime,
 ConfigService configService)

Parameters:

etlStage - ETLStage

runAsIfAtTime - Instant

ETLJob

public ETLJob(ETLStage etlStage,
 Instant runAsIfAtTime,
 ConfigService configService,
 boolean allData)

Parameters:

etlStage - ETLStage

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