com.hof.mi.etl.runner

Class ETLRunnerImpl

java.lang.Object

com.hof.mi.etl.runner.ETLRunnerImpl

All Implemented Interfaces:

ETLRunner

public class ETLRunnerImpl
extends java.lang.Object
implements ETLRunner

An implementation of the ETLRunner interface. The runner builds and runs and ETL Process.

Constructor Summary

Constructors

Constructor and Description
ETLRunnerImpl(java.lang.String processUuid)
ETLRunnerImpl(java.lang.String processUuid, ETLRunContext context)
ETLRunnerImpl(java.lang.String processUuid, ETLRunContext context, boolean useMainThreadForExec)

Method Summary

Methods

Modifier and Type	Method and Description
void	buildProcess() Build the process by building steps, linking them together and identifying heads of execution.
void	cancel() Stop executing the process
ETLRunContext	getContext() Get the ETLRunContext for this runner
java.util.Set<ExecutionHead>	getHeads() Get runnable heads
java.lang.String	getProcessUuid()
ETLProcessStatus	getStatus() Get the status of the process.
java.util.Map<java.lang.String,ETLStep>	getSteps() Get all built ETLStep objects for this process
java.lang.String	getUUID() Get the runner UUID
void	run() Begin running the ETL process
void	setDependencies(com.hof.mi.etl.ETLDependencies dependencies)
boolean	shouldSaveRun() Check if a run must be saved.

Methods inherited from class java.lang.Object

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

Constructor Detail

ETLRunnerImpl

public ETLRunnerImpl(java.lang.String processUuid,
             ETLRunContext context)

ETLRunnerImpl

public ETLRunnerImpl(java.lang.String processUuid,
             ETLRunContext context,
             boolean useMainThreadForExec)

ETLRunnerImpl

public ETLRunnerImpl(java.lang.String processUuid)

Method Detail

setDependencies

public void setDependencies(com.hof.mi.etl.ETLDependencies dependencies)

getContext

public ETLRunContext getContext()

Description copied from interface: ETLRunner

Get the ETLRunContext for this runner

Specified by:

getContext in interface ETLRunner

run

public void run()

Description copied from interface: ETLRunner

Begin running the ETL process

Specified by:

run in interface ETLRunner

cancel

public void cancel()

Description copied from interface: ETLRunner

Stop executing the process

Specified by:

cancel in interface ETLRunner

getStatus

public ETLProcessStatus getStatus()

Description copied from interface: ETLRunner

Get the status of the process.

Specified by:

getStatus in interface ETLRunner

getProcessUuid

public java.lang.String getProcessUuid()

buildProcess

public void buildProcess()
                  throws ETLException

Build the process by building steps, linking them together and identifying heads of execution.

Specified by:

buildProcess in interface ETLRunner

Throws:

ETLException

shouldSaveRun

public boolean shouldSaveRun()

Check if a run must be saved. It will be true by default. Set to false when one tries to run a process that has no steps

Specified by:

shouldSaveRun in interface ETLRunner

getSteps

public java.util.Map<java.lang.String,ETLStep> getSteps()

Get all built ETLStep objects for this process

Specified by:

getSteps in interface ETLRunner

getUUID

public java.lang.String getUUID()

Description copied from interface: ETLRunner

Get the runner UUID

Specified by:

getUUID in interface ETLRunner

getHeads

public java.util.Set<ExecutionHead> getHeads()

Get runnable heads