Package org.apache.hadoop.mapreduce.v2.app.job

Interface Job

All Known Implementing Classes:
JobImpl
public interface Job
Main interface to interact with the job.

  • Method Details

    • getID

      org.apache.hadoop.mapreduce.v2.api.records.JobId getID()

    • getName

      String getName()

    • getState

      org.apache.hadoop.mapreduce.v2.api.records.JobState getState()

    • getReport

      org.apache.hadoop.mapreduce.v2.api.records.JobReport getReport()

    • getAllCounters

      org.apache.hadoop.mapreduce.Counters getAllCounters()
      Get all the counters of this job. This includes job-counters aggregated together with the counters of each task. This creates a clone of the Counters, so use this judiciously.
      Returns:
      job-counters and aggregate task-counters

    • getTasks

      Map<org.apache.hadoop.mapreduce.v2.api.records.TaskId,Task> getTasks()

    • getTasks

      Map<org.apache.hadoop.mapreduce.v2.api.records.TaskId,Task> getTasks(org.apache.hadoop.mapreduce.v2.api.records.TaskType taskType)

    • getTask

      Task getTask(org.apache.hadoop.mapreduce.v2.api.records.TaskId taskID)

    • getDiagnostics

      List<String> getDiagnostics()

    • getTotalMaps

      int getTotalMaps()

    • getTotalReduces

      int getTotalReduces()

    • getCompletedMaps

      int getCompletedMaps()

    • getCompletedReduces

      int getCompletedReduces()

    • getFailedMaps

      int getFailedMaps()

    • getFailedReduces

      int getFailedReduces()

    • getKilledMaps

      int getKilledMaps()

    • getKilledReduces

      int getKilledReduces()

    • getProgress

      float getProgress()

    • isUber

      boolean isUber()

    • getUserName

      String getUserName()

    • getQueueName

      String getQueueName()

    • getConfFile

      org.apache.hadoop.fs.Path getConfFile()
      Returns:
      a path to where the config file for this job is located.

    • loadConfFile

      org.apache.hadoop.conf.Configuration loadConfFile() throws IOException
      Returns:
      a parsed version of the config files pointed to by getConfFile().
      Throws:
      IOException - on any error trying to load the conf file.

    • getJobACLs

      Map<org.apache.hadoop.mapreduce.JobACL,org.apache.hadoop.security.authorize.AccessControlList> getJobACLs()
      Returns:
      the ACLs for this job for each type of JobACL given.

    • getTaskAttemptCompletionEvents

      org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptCompletionEvent[] getTaskAttemptCompletionEvents(int fromEventId, int maxEvents)

    • getMapAttemptCompletionEvents

      org.apache.hadoop.mapred.TaskCompletionEvent[] getMapAttemptCompletionEvents(int startIndex, int maxEvents)

    • getAMInfos

      List<org.apache.hadoop.mapreduce.v2.api.records.AMInfo> getAMInfos()
      Returns:
      information for MR AppMasters (previously failed and current)

    • checkAccess

      boolean checkAccess(org.apache.hadoop.security.UserGroupInformation callerUGI, org.apache.hadoop.mapreduce.JobACL jobOperation)

    • setQueueName

      void setQueueName(String queueName)

    • setJobPriority

      void setJobPriority(org.apache.hadoop.yarn.api.records.Priority priority)