com.mulesoft.mule.runtime.module.batch.internal

Class DefaultBatchJobResult

java.lang.Object

com.mulesoft.mule.runtime.module.batch.internal.DefaultBatchJobResult

All Implemented Interfaces:

com.mulesoft.mule.runtime.module.batch.api.BatchJobResult, BatchJobResultAdapter, Serializable

public class DefaultBatchJobResult
extends Object
implements BatchJobResultAdapter

Default implementation for BatchJobResultAdapter

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DefaultBatchJobResult(String batchJodInstanceId)

Method Summary

Modifier and Type	Method and Description
String	getBatchJobInstanceId()
Map<String,com.mulesoft.mule.runtime.module.batch.api.BatchStepResult>	getBatchStepResults() Returns a Map in which the key is the name of a step and the value is a BatchStepResult
long	getElapsedTimeInMillis()
long	getFailedRecords()
Exception	getInputPhaseException()
long	getLoadedRecords()
Exception	getLoadingPhaseException()
Exception	getOnCompletePhaseException()
long	getProcessedRecords()
com.mulesoft.mule.runtime.module.batch.api.BatchStepResult	getResultForStep(String stepId)
long	getSuccessfulRecords()
long	getTotalRecords()
long	incrementLoadedRecords(long howMany) Increments the load records count by howMany
boolean	isFailedOnCompletePhase()
boolean	isFailedOnInputPhase()
boolean	isFailedOnLoadingPhase()
void	setInputPhaseException(Exception inputPhaseException) Sets an Exception thrown in the input phase
void	setLoadingPhaseException(Exception loadingPhaseException) Sets an Exception thrown in the loading phase
void	setOnCompletePhaseException(Exception onCompleteStepException) Sets an Exception thrown in the on complete phase
void	setTotalRecords(long totalRecords) sets the amount of total records that make for the owning BatchJobInstance
long	startClock() Starts tracking the time that a BatchJobInstance has been processing since the moment that this method has been invoked.
long	stopClock() Signals that the owning BatchJobInstance has stopped processing at the time this method was invoked
void	updateFor(BatchJobAdapter job, Collection<Record> records) Updates the values in this instance

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultBatchJobResult

public DefaultBatchJobResult(String batchJodInstanceId)

Method Detail

updateFor

public void updateFor(BatchJobAdapter job,
                      Collection<Record> records)

Updates the values in this instance

Specified by:

updateFor in interface BatchJobResultAdapter

Parameters:

job - the owning BatchJobAdapter

records - a collection of Record processed

getResultForStep

public com.mulesoft.mule.runtime.module.batch.api.BatchStepResult getResultForStep(String stepId)

Specified by:

getResultForStep in interface com.mulesoft.mule.runtime.module.batch.api.BatchJobResult

startClock

public long startClock()

Starts tracking the time that a BatchJobInstance has been processing since the moment that this method has been invoked. After invoking this method, BatchJobResultAdapter.stopClock() has to be invoked at some point so that BatchJobResult.getElapsedTimeInMillis() can eventually return a valid value

Specified by:

startClock in interface BatchJobResultAdapter

Returns:

the instant in milliseconds in which this method was invoked

stopClock

public long stopClock()

Signals that the owning BatchJobInstance has stopped processing at the time this method was invoked

Specified by:

stopClock in interface BatchJobResultAdapter

Returns:

the time in millis that the owning BatchJobInstance has been processing

getElapsedTimeInMillis

public long getElapsedTimeInMillis()

Specified by:

getElapsedTimeInMillis in interface com.mulesoft.mule.runtime.module.batch.api.BatchJobResult

getSuccessfulRecords

public long getSuccessfulRecords()

Specified by:

getSuccessfulRecords in interface com.mulesoft.mule.runtime.module.batch.api.BatchJobResult

getFailedRecords

public long getFailedRecords()

Specified by:

getFailedRecords in interface com.mulesoft.mule.runtime.module.batch.api.BatchJobResult

getProcessedRecords

public long getProcessedRecords()

Specified by:

getProcessedRecords in interface com.mulesoft.mule.runtime.module.batch.api.BatchJobResult

getTotalRecords

public long getTotalRecords()

Specified by:

getTotalRecords in interface com.mulesoft.mule.runtime.module.batch.api.BatchJobResult

getBatchJobInstanceId

public String getBatchJobInstanceId()

Specified by:

getBatchJobInstanceId in interface com.mulesoft.mule.runtime.module.batch.api.BatchJobResult

getLoadedRecords

public long getLoadedRecords()

Specified by:

getLoadedRecords in interface com.mulesoft.mule.runtime.module.batch.api.BatchJobResult

incrementLoadedRecords

public long incrementLoadedRecords(long howMany)

Increments the load records count by howMany

Specified by:

incrementLoadedRecords in interface BatchJobResultAdapter

Parameters:

howMany - the amount of new records that have been loaded

Returns:

the updated count of records that have been loaded

setTotalRecords

public void setTotalRecords(long totalRecords)

sets the amount of total records that make for the owning BatchJobInstance

Specified by:

setTotalRecords in interface BatchJobResultAdapter

Parameters:

totalRecords - the total amount of records

isFailedOnInputPhase

public boolean isFailedOnInputPhase()

Specified by:

isFailedOnInputPhase in interface com.mulesoft.mule.runtime.module.batch.api.BatchJobResult

getInputPhaseException

public Exception getInputPhaseException()

Specified by:

getInputPhaseException in interface com.mulesoft.mule.runtime.module.batch.api.BatchJobResult

getLoadingPhaseException

public Exception getLoadingPhaseException()

Specified by:

getLoadingPhaseException in interface com.mulesoft.mule.runtime.module.batch.api.BatchJobResult

isFailedOnLoadingPhase

public boolean isFailedOnLoadingPhase()

Specified by:

isFailedOnLoadingPhase in interface com.mulesoft.mule.runtime.module.batch.api.BatchJobResult

isFailedOnCompletePhase

public boolean isFailedOnCompletePhase()

Specified by:

isFailedOnCompletePhase in interface com.mulesoft.mule.runtime.module.batch.api.BatchJobResult

getOnCompletePhaseException

public Exception getOnCompletePhaseException()

Specified by:

getOnCompletePhaseException in interface com.mulesoft.mule.runtime.module.batch.api.BatchJobResult

setOnCompletePhaseException

public void setOnCompletePhaseException(Exception onCompleteStepException)

Sets an Exception thrown in the on complete phase

Specified by:

setOnCompletePhaseException in interface BatchJobResultAdapter

Parameters:

onCompleteStepException - a Exception

setInputPhaseException

public void setInputPhaseException(Exception inputPhaseException)

Sets an Exception thrown in the input phase

Specified by:

setInputPhaseException in interface BatchJobResultAdapter

Parameters:

inputPhaseException - a Exception

setLoadingPhaseException

public void setLoadingPhaseException(Exception loadingPhaseException)

Sets an Exception thrown in the loading phase

Specified by:

setLoadingPhaseException in interface BatchJobResultAdapter

Parameters:

loadingPhaseException - a Exception

getBatchStepResults

public Map<String,com.mulesoft.mule.runtime.module.batch.api.BatchStepResult> getBatchStepResults()

Returns a Map in which the key is the name of a step and the value is a BatchStepResult

Specified by:

getBatchStepResults in interface BatchJobResultAdapter