com.hof.mi.etl.runner

Class ETLBackgroundRunContext

java.lang.Object

com.hof.mi.etl.runner.AbstractETLRunContext

com.hof.mi.etl.runner.ETLBackgroundRunContext

All Implemented Interfaces:

ETLRunContext, java.io.Serializable

public class ETLBackgroundRunContext
extends AbstractETLRunContext

Implementation of the ETLRunContext interface for running the entire ETL Process in the background.

See Also:

Serialized Form

Nested Class Summary

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

ETLRunContext.RunMode

Field Summary

Fields inherited from class com.hof.mi.etl.runner.AbstractETLRunContext

threadManager

Constructor Summary

Constructors

Constructor and Description
ETLBackgroundRunContext(java.lang.Integer ipOrg, java.lang.Integer ipPerson, java.lang.String clientReferenceId)

Method Summary

Methods

Modifier and Type	Method and Description
void	destroy() Executed for destroying the context.
java.lang.String	getClientReferenceId() Client Reference ID of the logged-in user.
ETLThreadManager	getETLThreadManager(int headCount) Return a Thread Manager to which tasks may be submitted.
java.lang.Integer	getIpOrg() Org of the logged-in user.
java.lang.Integer	getIpPerson() ID of the logged-in user.
long	getMaxRowsPerStep() This is the max number of rows a step can emit along an output flow.
ETLRunContext.RunMode	getRunMode() Return the ETLRunContext.RunMode
void	setThreadManager(ETLThreadManager etm)

Methods inherited from class com.hof.mi.etl.runner.AbstractETLRunContext

getErrorThreshold, getMainThread, getProcessConfig, getRunFromStep, getRunStep, getRunTillStep, hasExceededErrorThreshold, incrementErrorCount, setMainThread, setProcessConfig, setRunFromStep, setRunStep, setRunTillStep

Methods inherited from class java.lang.Object

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

Constructor Detail

ETLBackgroundRunContext

public ETLBackgroundRunContext(java.lang.Integer ipOrg,
                       java.lang.Integer ipPerson,
                       java.lang.String clientReferenceId)

Method Detail

getRunMode

public ETLRunContext.RunMode getRunMode()

Description copied from interface: ETLRunContext

Return the ETLRunContext.RunMode

getETLThreadManager

public ETLThreadManager getETLThreadManager(int headCount)

Description copied from interface: ETLRunContext

Return a Thread Manager to which tasks may be submitted. If an implementation wants to restrict the number of threads based on the number of "head" steps, it may do so using the headCount param. Pass -1 to ignore.

setThreadManager

public void setThreadManager(ETLThreadManager etm)

destroy

public void destroy()

Description copied from interface: ETLRunContext

Executed for destroying the context. Perform cleanup tasks here.

getMaxRowsPerStep

public long getMaxRowsPerStep()

Description copied from interface: ETLRunContext

This is the max number of rows a step can emit along an output flow. A value of -1 indicates that there's no limit.

getIpOrg

public java.lang.Integer getIpOrg()

Description copied from interface: ETLRunContext

Org of the logged-in user.

getIpPerson

public java.lang.Integer getIpPerson()

Description copied from interface: ETLRunContext

ID of the logged-in user.

getClientReferenceId

public java.lang.String getClientReferenceId()

Description copied from interface: ETLRunContext

Client Reference ID of the logged-in user.