Home - News ( United States | United Kingdom | Italy | Germany ) - Football scores

Showing content from https://hadoop.apache.org/docs/r1.2.1/api/org/apache/hadoop/mapred/RunningJob.html below:

RunningJob (Hadoop 1.2.1 API)

public interface RunningJob

RunningJob is the user-interface to query for details on a running Map-Reduce job.

Clients can get hold of RunningJob via the JobClient and then query the running-job for details such as name, configuration, progress etc.

See Also:

JobClient

JobID getID()

Get the job identifier.

Returns:

the job identifier.

@Deprecated
String getJobID()

Deprecated. This method is deprecated and will be removed. Applications should rather use getID().

String getJobName()

Get the name of the job.

Returns:

the name of the job.

String getJobFile()

Get the path of the submitted job configuration.

Returns:

the path of the submitted job configuration.

String getTrackingURL()

Get the URL where some job progress information will be displayed.

Returns:

the URL where some job progress information will be displayed.

float mapProgress()
                  throws IOException

Get the progress of the job's map-tasks, as a float between 0.0 and 1.0. When all map tasks have completed, the function returns 1.0.

Returns:

the progress of the job's map-tasks.

Throws:

IOException

float reduceProgress()
                     throws IOException

Get the progress of the job's reduce-tasks, as a float between 0.0 and 1.0. When all reduce tasks have completed, the function returns 1.0.

Returns:

the progress of the job's reduce-tasks.

Throws:

IOException

float cleanupProgress()
                      throws IOException

Get the progress of the job's cleanup-tasks, as a float between 0.0 and 1.0. When all cleanup tasks have completed, the function returns 1.0.

Returns:

the progress of the job's cleanup-tasks.

Throws:

IOException

float setupProgress()
                    throws IOException

Get the progress of the job's setup-tasks, as a float between 0.0 and 1.0. When all setup tasks have completed, the function returns 1.0.

Returns:

the progress of the job's setup-tasks.

Throws:

IOException

boolean isComplete()
                   throws IOException

Check if the job is finished or not. This is a non-blocking call.

Returns:

true if the job is complete, else false.

Throws:

IOException

boolean isSuccessful()
                     throws IOException

Check if the job completed successfully.

Returns:

true if the job succeeded, else false.

Throws:

IOException

void waitForCompletion()
                       throws IOException

Blocks until the job is complete.

Throws:

IOException

int getJobState()
                throws IOException

Returns the current state of the Job.

Throws:

IOException

JobStatus getJobStatus()
                       throws IOException

Returns a snapshot of the current status, JobStatus, of the Job. Need to call again for latest information.

Throws:

IOException

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

void setJobPriority(String priority)
                    throws IOException

Set the priority of a running job.

Parameters:

priority - the new priority for the job.

Throws:

IOException

TaskCompletionEvent[] getTaskCompletionEvents(int startFrom)
                                              throws IOException

Get events indicating completion (success/failure) of component tasks.

Parameters:

startFrom - index to start fetching events from

Returns:

an array of TaskCompletionEvents

Throws:

IOException

void killTask(TaskAttemptID taskId,
              boolean shouldFail)
              throws IOException

Kill indicated task attempt.

Parameters:

taskId - the id of the task to be terminated.

shouldFail - if true the task is failed and added to failed tasks list, otherwise it is just killed, w/o affecting job failure status.

Throws:

IOException

@Deprecated
void killTask(String taskId,
                         boolean shouldFail)
              throws IOException

Deprecated. Applications should rather use killTask(TaskAttemptID, boolean)

Throws:

IOException

Counters getCounters()
                     throws IOException

Gets the counters for this job.

Returns:

the counters for this job.

Throws:

IOException

String getFailureInfo()
                      throws IOException

Get failure info for the job.

Returns:

the failure info for the job.

Throws:

IOException

String[] getTaskDiagnostics(TaskAttemptID taskid)
                            throws IOException

Gets the diagnostic messages for a given task attempt.

Parameters:

taskid -

Returns:

the list of diagnostic messages for the task

Throws:

IOException

RetroSearch is an open source project built by @garambo | Open a GitHub Issue

Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo

HTML: 3.2 | Encoding: UTF-8 | Version: 0.7.4