com.hof.mi.etl.runner.status

Class ETLStepStatusImpl

java.lang.Object

com.hof.mi.etl.runner.status.ETLStepStatusImpl

All Implemented Interfaces:

ETLStepStatus, java.io.Serializable

Direct Known Subclasses:

ETLStepStatusConcurrentImpl

public class ETLStepStatusImpl
extends java.lang.Object
implements ETLStepStatus, java.io.Serializable

Implementation of the ETLStepStatus interface. Errors are stored in a non thread-safe collection.

See Also:

Serialized Form

Nested Class Summary

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

ETLStepStatus.ETLStepStatusCode

Constructor Summary

Constructors

Constructor and Description
ETLStepStatusImpl(java.lang.String stepUuid)
ETLStepStatusImpl(java.lang.String stepUuid, java.util.Collection<ETLException> errors)

Method Summary

Methods

Modifier and Type	Method and Description
void	addData(ETLStepResult newData) Add one or more rows of data to the step's cache.
void	addError(ETLException e) Add an unhandled error to the set of errors.
void	cancel() Set the status of the step to cancelled, if it is not complete.
ETLStepResult	getData(java.lang.String outFlowUuid) Get data generated emitted by this step along the specified output flow UUID.
long	getEndTime() End Time as milliseconds from midnight, January 1, 1970 UTC.
java.util.Collection<ETLException>	getErrors() Get all unhandled errors.
java.util.Map<java.lang.String,java.lang.Long>	getProcessedRowCount() Number of rows processed by the step and sent down the chain for each flow.
long	getProcessedRowCount(java.lang.String outFlowUuid) Number of rows processed by the step and sent down the chain for a given flowUUID.
long	getStartTime() Start Time as milliseconds from midnight, January 1, 1970 UTC.
ETLStepStatus.ETLStepStatusCode	getStatusCode() Get the current status of the step represented by ETLStepStatus.ETLStepStatusCode
java.lang.String	getStepUuid() UUID of the step whose status is encapsulated here.
boolean	hasErrors() Were there any unhandled errors?
boolean	isComplete() True when the step has finished.
void	rowProcessed(java.lang.String outFlowUuid) Indicate that a row has been processed on a given flow.
void	setStatusCode(ETLStepStatus.ETLStepStatusCode statusCode) Set the step's status to an ETLStepStatus.ETLStepStatusCode

Methods inherited from class java.lang.Object

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

Constructor Detail

ETLStepStatusImpl

public ETLStepStatusImpl(java.lang.String stepUuid)

ETLStepStatusImpl

public ETLStepStatusImpl(java.lang.String stepUuid,
                 java.util.Collection<ETLException> errors)

Method Detail

getStepUuid

public java.lang.String getStepUuid()

Description copied from interface: ETLStepStatus

UUID of the step whose status is encapsulated here.

Specified by:

getStepUuid in interface ETLStepStatus

getProcessedRowCount

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

Description copied from interface: ETLStepStatus

Number of rows processed by the step and sent down the chain for each flow.

Specified by:

getProcessedRowCount in interface ETLStepStatus

getProcessedRowCount

public long getProcessedRowCount(java.lang.String outFlowUuid)

Description copied from interface: ETLStepStatus

Number of rows processed by the step and sent down the chain for a given flowUUID.

Specified by:

getProcessedRowCount in interface ETLStepStatus

rowProcessed

public void rowProcessed(java.lang.String outFlowUuid)

Description copied from interface: ETLStepStatus

Indicate that a row has been processed on a given flow.

Specified by:

rowProcessed in interface ETLStepStatus

isComplete

public boolean isComplete()

Description copied from interface: ETLStepStatus

True when the step has finished. It may not have finished successfully.

Specified by:

isComplete in interface ETLStepStatus

hasErrors

public boolean hasErrors()

Description copied from interface: ETLStepStatus

Were there any unhandled errors?

Specified by:

hasErrors in interface ETLStepStatus

getErrors

public java.util.Collection<ETLException> getErrors()

Description copied from interface: ETLStepStatus

Get all unhandled errors.

Specified by:

getErrors in interface ETLStepStatus

addError

public void addError(ETLException e)

Description copied from interface: ETLStepStatus

Add an unhandled error to the set of errors.

Specified by:

addError in interface ETLStepStatus

getStatusCode

public ETLStepStatus.ETLStepStatusCode getStatusCode()

Description copied from interface: ETLStepStatus

Get the current status of the step represented by ETLStepStatus.ETLStepStatusCode

Specified by:

getStatusCode in interface ETLStepStatus

setStatusCode

public void setStatusCode(ETLStepStatus.ETLStepStatusCode statusCode)

Description copied from interface: ETLStepStatus

Set the step's status to an ETLStepStatus.ETLStepStatusCode

Specified by:

setStatusCode in interface ETLStepStatus

getData

public ETLStepResult getData(java.lang.String outFlowUuid)

Description copied from interface: ETLStepStatus

Get data generated emitted by this step along the specified output flow UUID. When there is no output flow, this should return data corresponding to the default metadata.

Specified by:

getData in interface ETLStepStatus

addData

public void addData(ETLStepResult newData)

Description copied from interface: ETLStepStatus

Add one or more rows of data to the step's cache.

Specified by:

addData in interface ETLStepStatus

Parameters:

newData - - Instance of ETLStepResult.

cancel

public void cancel()

Description copied from interface: ETLStepStatus

Set the status of the step to cancelled, if it is not complete.

Specified by:

cancel in interface ETLStepStatus

getStartTime

public long getStartTime()

Description copied from interface: ETLStepStatus

Start Time as milliseconds from midnight, January 1, 1970 UTC.

Specified by:

getStartTime in interface ETLStepStatus

getEndTime

public long getEndTime()

Description copied from interface: ETLStepStatus

End Time as milliseconds from midnight, January 1, 1970 UTC.

Specified by:

getEndTime in interface ETLStepStatus