co.cask.cdap.proto

Class MRJobInfo

java.lang.Object

co.cask.cdap.proto.MRJobInfo

public class MRJobInfo
extends Object

Simplified (filtered) representation of a MapReduce Job.

Constructor Summary

Constructors

Constructor and Description
MRJobInfo(Float mapProcess, Float reduceProgress, Map<String,Long> counters, List<MRTaskInfo> mapTasks, List<MRTaskInfo> reduceTasks, boolean complete)

Method Summary

Methods

Modifier and Type	Method and Description
Map<String,Long>	getCounters()
Float	getMapProgress()
List<MRTaskInfo>	getMapTasks()
Float	getReduceProgress()
List<MRTaskInfo>	getReduceTasks()
Long	getStartTime()
String	getState()
Long	getStopTime()
boolean	isComplete()
void	setStartTime(Long startTime)
void	setState(String state)
void	setStopTime(Long stopTime)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MRJobInfo

public MRJobInfo(Float mapProcess,
         Float reduceProgress,
         Map<String,Long> counters,
         List<MRTaskInfo> mapTasks,
         List<MRTaskInfo> reduceTasks,
         boolean complete)

Method Detail

setState

public void setState(@Nullable
            String state)

setStartTime

public void setStartTime(@Nullable
                Long startTime)

setStopTime

public void setStopTime(@Nullable
               Long stopTime)

getState

@Nullable
public String getState()

getStartTime

@Nullable
public Long getStartTime()

getStopTime

@Nullable
public Long getStopTime()

getMapProgress

public Float getMapProgress()

getReduceProgress

public Float getReduceProgress()

getCounters

public Map<String,Long> getCounters()

getMapTasks

public List<MRTaskInfo> getMapTasks()

getReduceTasks

public List<MRTaskInfo> getReduceTasks()

isComplete

public boolean isComplete()