org.duracloud.services.amazonmapreduce
Interface AmazonMapReduceJobWorker

All Superinterfaces:

java.lang.Runnable

All Known Implementing Classes:

AmazonFixityJobWorker, AmazonFixityPropertiesJobWorker, BaseAmazonMapReduceJobWorker, BaseAmazonMapReducePostJobWorker, DeletePostJobWorker, FixityPassFailPostJobWorker, HadoopJobWorker, HeaderPostJobWorker, MimePostJobWorker, MultiPostJobWorker, PassFailPostJobWorker, ReplicationOnDemandJobWorker, SimplePassFailPostJobWorker, VerifyHashesPostJobWorker, WrapperPostJobWorker

public interface AmazonMapReduceJobWorker
extends java.lang.Runnable

This interface defines the contract for workers that manage jobs in the hadoop framework.

Author:

Andrew Woods Date: Sep 29, 2010

Nested Class Summary

static class

AmazonMapReduceJobWorker.JobStatus This enum holds the states of a hadoop job.

Method Summary

java.lang.String	getError() This method returns any errors associated with the current running job.
java.util.Map<java.lang.String,java.lang.String>	getJobDetailsMap() This method queries the hadoop framework and returns a listing of details related to the currently running job.
java.lang.String	getJobId() This method returns the jobId of the current job.
AmazonMapReduceJobWorker.JobStatus	getJobStatus() This method returns the current job state.
void	shutdown() This methods terminates the processing of this job.

Methods inherited from interface java.lang.Runnable

run

Method Detail

getJobStatus

AmazonMapReduceJobWorker.JobStatus getJobStatus()

This method returns the current job state.

Returns:

jobStatus

getJobDetailsMap

java.util.Map<java.lang.String,java.lang.String> getJobDetailsMap()

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

Returns:

map

getJobId

java.lang.String getJobId()

This method returns the jobId of the current job.

Returns:

jobId

getError

java.lang.String getError()

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

Returns:

error text

shutdown

void shutdown()

This methods terminates the processing of this job.