org.apache.nutch.mapReduce
Interface JobSubmissionProtocol

All Known Implementing Classes:

JobTracker

public interface JobSubmissionProtocol

Protocol that a JobClient and the central JobTracker use to communicate. The JobClient can use these methods to submit a Job for execution, and learn about the current system status.

Method Summary

String	getFilesystemName() A MapReduce system always operates on a single filesystem.
JobProfile	getJobProfile(String jobid) Grab a handle to a job that is already known to the JobTracker
JobStatus	getJobStatus(String jobid) Grab a handle to a job that is already known to the JobTracker
void	killJob(String jobid) Kill the indicated job
JobStatus	submitJob(String jobFile) Submit a Job for execution.

Method Detail

submitJob

public JobStatus submitJob(String jobFile)
                    throws IOException

Submit a Job for execution. Returns the latest profile for that job.

Throws:

IOException

killJob

public void killJob(String jobid)

Kill the indicated job

getJobProfile

public JobProfile getJobProfile(String jobid)

Grab a handle to a job that is already known to the JobTracker

getJobStatus

public JobStatus getJobStatus(String jobid)

Grab a handle to a job that is already known to the JobTracker

getFilesystemName

public String getFilesystemName()
                         throws IOException

A MapReduce system always operates on a single filesystem. This function returns the fs name. ('local' if the localfs; 'addr:port' if ndfs). The client can then copy files into the right locations prior to submitting the job.

Throws:

IOException