Package org.apache.hadoop.mapreduce.v2.hs

Class CompletedJob

java.lang.Object
org.apache.hadoop.mapreduce.v2.hs.CompletedJob
All Implemented Interfaces:
org.apache.hadoop.mapreduce.v2.app.job.Job
public class CompletedJob extends Object implements org.apache.hadoop.mapreduce.v2.app.job.Job
Loads the basic job level data upfront. Data from job history file is loaded lazily.

  • Constructor Details

    • CompletedJob

      public CompletedJob(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.mapreduce.v2.api.records.JobId jobId, org.apache.hadoop.fs.Path historyFile, boolean loadTasks, String userName, HistoryFileManager.HistoryFileInfo info, org.apache.hadoop.mapred.JobACLsManager aclsMgr) throws IOException
      Throws:
      IOException

  • Method Details

    • getCompletedMaps

      public int getCompletedMaps()
      Specified by:
      getCompletedMaps in interface org.apache.hadoop.mapreduce.v2.app.job.Job

    • getCompletedReduces

      public int getCompletedReduces()
      Specified by:
      getCompletedReduces in interface org.apache.hadoop.mapreduce.v2.app.job.Job

    • getAllCounters

      public org.apache.hadoop.mapreduce.Counters getAllCounters()
      Specified by:
      getAllCounters in interface org.apache.hadoop.mapreduce.v2.app.job.Job

    • getID

      public org.apache.hadoop.mapreduce.v2.api.records.JobId getID()
      Specified by:
      getID in interface org.apache.hadoop.mapreduce.v2.app.job.Job

    • getReport

      public org.apache.hadoop.mapreduce.v2.api.records.JobReport getReport()
      Specified by:
      getReport in interface org.apache.hadoop.mapreduce.v2.app.job.Job

    • getProgress

      public float getProgress()
      Specified by:
      getProgress in interface org.apache.hadoop.mapreduce.v2.app.job.Job

    • getState

      public org.apache.hadoop.mapreduce.v2.api.records.JobState getState()
      Specified by:
      getState in interface org.apache.hadoop.mapreduce.v2.app.job.Job

    • getTask

      public org.apache.hadoop.mapreduce.v2.app.job.Task getTask(org.apache.hadoop.mapreduce.v2.api.records.TaskId taskId)
      Specified by:
      getTask in interface org.apache.hadoop.mapreduce.v2.app.job.Job

    • getTaskAttemptCompletionEvents

      public org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptCompletionEvent[] getTaskAttemptCompletionEvents(int fromEventId, int maxEvents)
      Specified by:
      getTaskAttemptCompletionEvents in interface org.apache.hadoop.mapreduce.v2.app.job.Job

    • getMapAttemptCompletionEvents

      public org.apache.hadoop.mapred.TaskCompletionEvent[] getMapAttemptCompletionEvents(int startIndex, int maxEvents)
      Specified by:
      getMapAttemptCompletionEvents in interface org.apache.hadoop.mapreduce.v2.app.job.Job

    • getTasks

      public Map<org.apache.hadoop.mapreduce.v2.api.records.TaskId,org.apache.hadoop.mapreduce.v2.app.job.Task> getTasks()
      Specified by:
      getTasks in interface org.apache.hadoop.mapreduce.v2.app.job.Job

    • createJobHistoryParser

      protected org.apache.hadoop.mapreduce.jobhistory.JobHistoryParser createJobHistoryParser(org.apache.hadoop.fs.Path historyFileAbsolute) throws IOException
      Throws:
      IOException

    • loadFullHistoryData

      protected void loadFullHistoryData(boolean loadTasks, org.apache.hadoop.fs.Path historyFileAbsolute) throws IOException
      Throws:
      IOException

    • getDiagnostics

      public List<String> getDiagnostics()
      Specified by:
      getDiagnostics in interface org.apache.hadoop.mapreduce.v2.app.job.Job

    • getName

      public String getName()
      Specified by:
      getName in interface org.apache.hadoop.mapreduce.v2.app.job.Job

    • getQueueName

      public String getQueueName()
      Specified by:
      getQueueName in interface org.apache.hadoop.mapreduce.v2.app.job.Job

    • getTotalMaps

      public int getTotalMaps()
      Specified by:
      getTotalMaps in interface org.apache.hadoop.mapreduce.v2.app.job.Job

    • getTotalReduces

      public int getTotalReduces()
      Specified by:
      getTotalReduces in interface org.apache.hadoop.mapreduce.v2.app.job.Job

    • isUber

      public boolean isUber()
      Specified by:
      isUber in interface org.apache.hadoop.mapreduce.v2.app.job.Job

    • getTasks

      public Map<org.apache.hadoop.mapreduce.v2.api.records.TaskId,org.apache.hadoop.mapreduce.v2.app.job.Task> getTasks(org.apache.hadoop.mapreduce.v2.api.records.TaskType taskType)
      Specified by:
      getTasks in interface org.apache.hadoop.mapreduce.v2.app.job.Job

    • checkAccess

      public boolean checkAccess(org.apache.hadoop.security.UserGroupInformation callerUGI, org.apache.hadoop.mapreduce.JobACL jobOperation)
      Specified by:
      checkAccess in interface org.apache.hadoop.mapreduce.v2.app.job.Job

    • getJobACLs

      public Map<org.apache.hadoop.mapreduce.JobACL,org.apache.hadoop.security.authorize.AccessControlList> getJobACLs()
      Specified by:
      getJobACLs in interface org.apache.hadoop.mapreduce.v2.app.job.Job

    • getUserName

      public String getUserName()
      Specified by:
      getUserName in interface org.apache.hadoop.mapreduce.v2.app.job.Job

    • getConfFile

      public org.apache.hadoop.fs.Path getConfFile()
      Specified by:
      getConfFile in interface org.apache.hadoop.mapreduce.v2.app.job.Job

    • loadConfFile

      public org.apache.hadoop.conf.Configuration loadConfFile() throws IOException
      Specified by:
      loadConfFile in interface org.apache.hadoop.mapreduce.v2.app.job.Job
      Throws:
      IOException

    • getAMInfos

      public List<org.apache.hadoop.mapreduce.v2.api.records.AMInfo> getAMInfos()
      Specified by:
      getAMInfos in interface org.apache.hadoop.mapreduce.v2.app.job.Job

    • setQueueName

      public void setQueueName(String queueName)
      Specified by:
      setQueueName in interface org.apache.hadoop.mapreduce.v2.app.job.Job

    • setJobPriority

      public void setJobPriority(org.apache.hadoop.yarn.api.records.Priority priority)
      Specified by:
      setJobPriority in interface org.apache.hadoop.mapreduce.v2.app.job.Job

    • getFailedMaps

      public int getFailedMaps()
      Specified by:
      getFailedMaps in interface org.apache.hadoop.mapreduce.v2.app.job.Job

    • getFailedReduces

      public int getFailedReduces()
      Specified by:
      getFailedReduces in interface org.apache.hadoop.mapreduce.v2.app.job.Job

    • getKilledMaps

      public int getKilledMaps()
      Specified by:
      getKilledMaps in interface org.apache.hadoop.mapreduce.v2.app.job.Job

    • getKilledReduces

      public int getKilledReduces()
      Specified by:
      getKilledReduces in interface org.apache.hadoop.mapreduce.v2.app.job.Job