org.duracloud.services.amazonmapreduce

Class BaseAmazonMapReducePostJobWorker

java.lang.Object

org.duracloud.services.amazonmapreduce.BaseAmazonMapReducePostJobWorker

All Implemented Interfaces:

Runnable, AmazonMapReduceJobWorker, AmazonMapReducePostJobWorker

Direct Known Subclasses:

DeletePostJobWorker, HeaderPostJobWorker, MimePostJobWorker, MultiPostJobWorker, PassFailPostJobWorker, VerifyHashesPostJobWorker, WrapperPostJobWorker

public abstract class BaseAmazonMapReducePostJobWorker
extends Object
implements AmazonMapReducePostJobWorker

This abstract class is the base class of workers that are designed to be run after the completion of a hadoop job. The predecessor job that is provided to this class is polled for completion. Once the predecessor has status 'complete' this class performs its work.

Author:

Andrew Woods Date: Oct 1, 2010

Nested Class Summary

Nested classes/interfaces inherited from interface org.duracloud.services.amazonmapreduce.AmazonMapReduceJobWorker

AmazonMapReduceJobWorker.JobStatus

Field Summary

Fields

Modifier and Type	Field and Description
protected long	sleepMillis

Constructor Summary

Constructors

Constructor and Description
BaseAmazonMapReducePostJobWorker(AmazonMapReduceJobWorker predecessor)
BaseAmazonMapReducePostJobWorker(AmazonMapReduceJobWorker predecessor, long sleepMillis)

Method Summary

Methods

Modifier and Type	Method and Description
protected abstract void	doWork() This abstract method performs the functional task of this post processor.
Map<String,String>	getBubbleableProperties() This method returns properties related to the post processing job that the caller might be interested in.
String	getError() This method returns any errors associated with the current running job.
Map<String,String>	getJobDetailsMap() This method queries the hadoop framework and returns a listing of details related to the currently running job.
String	getJobId() This method returns the jobId of the current job.
AmazonMapReduceJobWorker.JobStatus	getJobStatus() This method returns the current job state.
void	run()
protected void	setError(String error)
void	shutdown() This methods terminates the processing of this job.
protected static void	sleep(long millis)

Methods inherited from class java.lang.Object

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

Field Detail

sleepMillis

protected long sleepMillis

Constructor Detail

BaseAmazonMapReducePostJobWorker

public BaseAmazonMapReducePostJobWorker(AmazonMapReduceJobWorker predecessor)

BaseAmazonMapReducePostJobWorker

public BaseAmazonMapReducePostJobWorker(AmazonMapReduceJobWorker predecessor,
                                long sleepMillis)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

doWork

protected abstract void doWork()

This abstract method performs the functional task of this post processor.

getJobStatus

public AmazonMapReduceJobWorker.JobStatus getJobStatus()

Description copied from interface: AmazonMapReduceJobWorker

This method returns the current job state.

Specified by:

getJobStatus in interface AmazonMapReduceJobWorker

Returns:

jobStatus

getJobDetailsMap

public Map<String,String> getJobDetailsMap()

Description copied from interface: AmazonMapReduceJobWorker

This method queries the hadoop framework and returns a listing of details related to the currently running job. Details include: jobId, job start time, job state, job end time

Specified by:

getJobDetailsMap in interface AmazonMapReduceJobWorker

Returns:

map

getJobId

public String getJobId()

Description copied from interface: AmazonMapReduceJobWorker

This method returns the jobId of the current job.

Specified by:

getJobId in interface AmazonMapReduceJobWorker

Returns:

jobId

getError

public String getError()

Description copied from interface: AmazonMapReduceJobWorker

This method returns any errors associated with the current running job.

Specified by:

getError in interface AmazonMapReduceJobWorker

Returns:

error text

setError

protected void setError(String error)

shutdown

public void shutdown()

Description copied from interface: AmazonMapReduceJobWorker

This methods terminates the processing of this job.

Specified by:

shutdown in interface AmazonMapReduceJobWorker

getBubbleableProperties

public Map<String,String> getBubbleableProperties()

Description copied from interface: AmazonMapReducePostJobWorker

This method returns properties related to the post processing job that the caller might be interested in. If there are no properties, an empty map should be returned.

Specified by:

getBubbleableProperties in interface AmazonMapReducePostJobWorker

Returns:

map

sleep

protected static void sleep(long millis)