org.apache.nutch.mapReduce
Interface RunningJob

public interface RunningJob

Includes details on a running MapReduce job. A client can track a living job using this object.

Author:

Mike Cafarella

Method Summary

String	getJobFile() Returns the path of the submitted job.
String	getJobID() Returns an identifier for the job
String	getTrackingURL() Returns a URL where some job progress information will be displayed.
boolean	isComplete() Non-blocking function to check whether the job is finished or not.
void	killJob() Kill the running job.
float	mapProgress() Returns a float between 0.0 and 1.0, indicating progress on the map portion of the job.
float	reduceProgress() Returns a float between 0.0 and 1.0, indicating progress on the reduce portion of the job.
void	waitForCompletion() Blocks until the job is complete.

Method Detail

getJobID

public String getJobID()

Returns an identifier for the job

getJobFile

public String getJobFile()

Returns the path of the submitted job.

getTrackingURL

public String getTrackingURL()

Returns a URL where some job progress information will be displayed.

mapProgress

public float mapProgress()
                  throws IOException

Returns a float between 0.0 and 1.0, indicating progress on the map portion of the job. When all map tasks have completed, the function returns 1.0.

Throws:

IOException

reduceProgress

public float reduceProgress()
                     throws IOException

Returns a float between 0.0 and 1.0, indicating progress on the reduce portion of the job. When all reduce tasks have completed, the function returns 1.0.

Throws:

IOException

isComplete

public boolean isComplete()
                   throws IOException

Non-blocking function to check whether the job is finished or not.

Throws:

IOException

waitForCompletion

public void waitForCompletion()
                       throws IOException

Blocks until the job is complete.

Throws:

IOException

killJob

public void killJob()
             throws IOException

Kill the running job. Blocks until all job tasks have been killed as well. If the job is no longer running, it simply returns.

Throws:

IOException