com.hof.mi.etl.runner

Class AbstractETLRunContext

java.lang.Object

com.hof.mi.etl.runner.AbstractETLRunContext

All Implemented Interfaces:

ETLRunContext, java.io.Serializable

Direct Known Subclasses:

ETLBackgroundRunContext, ETLPreviewRunContext

public abstract class AbstractETLRunContext
extends java.lang.Object
implements ETLRunContext, java.io.Serializable

Partial implementation of the ETLRunContext interface.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface com.hof.mi.etl.runner.ETLRunContext

ETLRunContext.RunMode

Field Summary

Fields

Modifier and Type	Field and Description
protected ETLThreadManager	threadManager

Constructor Summary

Constructors

Constructor and Description
AbstractETLRunContext()

Method Summary

Methods

Modifier and Type	Method and Description
int	getErrorThreshold() The number of rows which may be rejected because of errors, before the process fails.
java.lang.Thread	getMainThread() If the context has designated a Thread which will run the job from end to end, use this method to access it.
java.util.Map<java.lang.String,java.lang.String>	getProcessConfig() Get all configuration for an ETL Process as a map keyed by configKey and configValue.
java.lang.String	getRunFromStep() Get the UUID of the step from which the job should be run.
java.lang.String	getRunStep() Get the UUID of the step which should be run.
java.lang.String	getRunTillStep() Get the UUID of the step till which the job should be run.
boolean	hasExceededErrorThreshold() True if the number of errors in this execution has exceeded the error threshold
void	incrementErrorCount() Increment by 1, the number of errors in the current execution.
void	setMainThread(java.lang.Thread mainThread) Designate a "main" thread.
void	setProcessConfig(java.util.Map<java.lang.String,java.lang.String> configMap) Set a map containing configuration for an ETL Process.
void	setRunFromStep(java.lang.String runFromStepUuid)
void	setRunStep(java.lang.String runStepUuid)
void	setRunTillStep(java.lang.String runTillStepUuid)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hof.mi.etl.runner.ETLRunContext

destroy, getClientReferenceId, getETLThreadManager, getIpOrg, getIpPerson, getMaxRowsPerStep, getRunMode

Field Detail

threadManager

protected ETLThreadManager threadManager

Constructor Detail

AbstractETLRunContext

public AbstractETLRunContext()

Method Detail

getRunTillStep

public java.lang.String getRunTillStep()

Description copied from interface: ETLRunContext

Get the UUID of the step till which the job should be run. Use this to run everything up to and including this step, along this step's chain.

Specified by:

getRunTillStep in interface ETLRunContext

setRunTillStep

public void setRunTillStep(java.lang.String runTillStepUuid)

getRunFromStep

public java.lang.String getRunFromStep()

Description copied from interface: ETLRunContext

Get the UUID of the step from which the job should be run. Use this to run everything including this step and beyond, along this step's chain.

Specified by:

getRunFromStep in interface ETLRunContext

setRunFromStep

public void setRunFromStep(java.lang.String runFromStepUuid)

getRunStep

public java.lang.String getRunStep()

Description copied from interface: ETLRunContext

Get the UUID of the step which should be run. Use this to run the step using previously fetched data.

Specified by:

getRunStep in interface ETLRunContext

setRunStep

public void setRunStep(java.lang.String runStepUuid)

getMainThread

public java.lang.Thread getMainThread()

Description copied from interface: ETLRunContext

If the context has designated a Thread which will run the job from end to end, use this method to access it. This thread will block till the job finishes.

Specified by:

getMainThread in interface ETLRunContext

setMainThread

public void setMainThread(java.lang.Thread mainThread)

Description copied from interface: ETLRunContext

Designate a "main" thread.

Specified by:

setMainThread in interface ETLRunContext

See Also:

ETLRunContext.getMainThread()

getErrorThreshold

public int getErrorThreshold()

Description copied from interface: ETLRunContext

The number of rows which may be rejected because of errors, before the process fails.

Specified by:

getErrorThreshold in interface ETLRunContext

hasExceededErrorThreshold

public boolean hasExceededErrorThreshold()

Description copied from interface: ETLRunContext

True if the number of errors in this execution has exceeded the error threshold

Specified by:

hasExceededErrorThreshold in interface ETLRunContext

incrementErrorCount

public void incrementErrorCount()

Description copied from interface: ETLRunContext

Increment by 1, the number of errors in the current execution.

Specified by:

incrementErrorCount in interface ETLRunContext

getProcessConfig

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

Description copied from interface: ETLRunContext

Get all configuration for an ETL Process as a map keyed by configKey and configValue.

Specified by:

getProcessConfig in interface ETLRunContext

setProcessConfig

public void setProcessConfig(java.util.Map<java.lang.String,java.lang.String> configMap)

Description copied from interface: ETLRunContext

Set a map containing configuration for an ETL Process. Key: configKey; value: configValue

Specified by:

setProcessConfig in interface ETLRunContext