org.duracloud.services.amazonmapreduce

Interface AmazonMapReduceJobWorker

All Superinterfaces:

Runnable

All Known Subinterfaces:

AmazonMapReducePostJobWorker

All Known Implementing Classes:

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

public interface AmazonMapReduceJobWorker
extends 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

Nested Classes

Modifier and Type	Interface and Description
static class	AmazonMapReduceJobWorker.JobStatus This enum holds the states of a hadoop job.

Method Summary

Methods

Modifier and Type	Method and Description
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	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

Map<String,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

String getJobId()

This method returns the jobId of the current job.

Returns:

jobId

getError

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.