Package org.apache.hadoop.mapreduce.v2.api.records.impl.pb

Class TaskReportPBImpl

java.lang.Object

org.apache.hadoop.yarn.api.records.impl.pb.ProtoBase<org.apache.hadoop.mapreduce.v2.proto.MRProtos.TaskReportProto>

org.apache.hadoop.mapreduce.v2.api.records.impl.pb.TaskReportPBImpl

All Implemented Interfaces:

TaskReport

public class TaskReportPBImpl
extends org.apache.hadoop.yarn.api.records.impl.pb.ProtoBase<org.apache.hadoop.mapreduce.v2.proto.MRProtos.TaskReportProto>
implements TaskReport

Constructor Summary

Constructors

Constructor	Description
TaskReportPBImpl()
TaskReportPBImpl(org.apache.hadoop.mapreduce.v2.proto.MRProtos.TaskReportProto proto)

Method Summary

Modifier and Type	Method	Description
void	addAllDiagnostics(List<String> diagnostics)
void	addAllRunningAttempts(List<TaskAttemptId> runningAttempts)
void	addDiagnostics(String diagnostics)
void	addRunningAttempt(TaskAttemptId runningAttempts)
void	clearDiagnostics()
void	clearRunningAttempts()
Counters	getCounters()
String	getDiagnostics(int index)
int	getDiagnosticsCount()
List<String>	getDiagnosticsList()
long	getFinishTime()
float	getProgress()
org.apache.hadoop.mapreduce.v2.proto.MRProtos.TaskReportProto	getProto()
org.apache.hadoop.mapreduce.Counters	getRawCounters()
TaskAttemptId	getRunningAttempt(int index)
int	getRunningAttemptsCount()
List<TaskAttemptId>	getRunningAttemptsList()
long	getStartTime()
String	getStatus()
TaskAttemptId	getSuccessfulAttempt()
TaskId	getTaskId()
TaskState	getTaskState()
void	removeDiagnostics(int index)
void	removeRunningAttempt(int index)
void	setCounters(Counters counters)
void	setFinishTime(long finishTime)
void	setProgress(float progress)
void	setRawCounters(org.apache.hadoop.mapreduce.Counters rCounters)
void	setStartTime(long startTime)
void	setStatus(String status)
void	setSuccessfulAttempt(TaskAttemptId successfulAttempt)
void	setTaskId(TaskId taskId)
void	setTaskState(TaskState taskState)

Methods inherited from class org.apache.hadoop.yarn.api.records.impl.pb.ProtoBase

convertFromProtoFormat, convertToProtoFormat, equals, hashCode, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

TaskReportPBImpl

public TaskReportPBImpl()

TaskReportPBImpl

public TaskReportPBImpl(org.apache.hadoop.mapreduce.v2.proto.MRProtos.TaskReportProto proto)

Method Details

getProto

public org.apache.hadoop.mapreduce.v2.proto.MRProtos.TaskReportProto getProto()

Specified by:

getProto in class org.apache.hadoop.yarn.api.records.impl.pb.ProtoBase<org.apache.hadoop.mapreduce.v2.proto.MRProtos.TaskReportProto>

getCounters

public Counters getCounters()

Specified by:

getCounters in interface TaskReport

setCounters

public void setCounters(Counters counters)

Specified by:

setCounters in interface TaskReport

getRawCounters

public org.apache.hadoop.mapreduce.Counters getRawCounters()

Specified by:

getRawCounters in interface TaskReport

setRawCounters

public void setRawCounters(org.apache.hadoop.mapreduce.Counters rCounters)

Specified by:

setRawCounters in interface TaskReport

getStartTime

public long getStartTime()

Specified by:

getStartTime in interface TaskReport

setStartTime

public void setStartTime(long startTime)

Specified by:

setStartTime in interface TaskReport

getFinishTime

public long getFinishTime()

Specified by:

getFinishTime in interface TaskReport

setFinishTime

public void setFinishTime(long finishTime)

Specified by:

setFinishTime in interface TaskReport

getTaskId

public TaskId getTaskId()

Specified by:

getTaskId in interface TaskReport

setTaskId

public void setTaskId(TaskId taskId)

Specified by:

setTaskId in interface TaskReport

getProgress

public float getProgress()

Specified by:

getProgress in interface TaskReport

getStatus

public String getStatus()

Specified by:

getStatus in interface TaskReport

setProgress

public void setProgress(float progress)

Specified by:

setProgress in interface TaskReport

setStatus

public void setStatus(String status)

Specified by:

setStatus in interface TaskReport

getTaskState

public TaskState getTaskState()

Specified by:

getTaskState in interface TaskReport

setTaskState

public void setTaskState(TaskState taskState)

Specified by:

setTaskState in interface TaskReport

getRunningAttemptsList

public List<TaskAttemptId> getRunningAttemptsList()

Specified by:

getRunningAttemptsList in interface TaskReport

getRunningAttempt

public TaskAttemptId getRunningAttempt(int index)

Specified by:

getRunningAttempt in interface TaskReport

getRunningAttemptsCount

public int getRunningAttemptsCount()

Specified by:

getRunningAttemptsCount in interface TaskReport

addAllRunningAttempts

public void addAllRunningAttempts(List<TaskAttemptId> runningAttempts)

Specified by:

addAllRunningAttempts in interface TaskReport

addRunningAttempt

public void addRunningAttempt(TaskAttemptId runningAttempts)

Specified by:

addRunningAttempt in interface TaskReport

removeRunningAttempt

public void removeRunningAttempt(int index)

Specified by:

removeRunningAttempt in interface TaskReport

clearRunningAttempts

public void clearRunningAttempts()

Specified by:

clearRunningAttempts in interface TaskReport

getSuccessfulAttempt

public TaskAttemptId getSuccessfulAttempt()

Specified by:

getSuccessfulAttempt in interface TaskReport

setSuccessfulAttempt

public void setSuccessfulAttempt(TaskAttemptId successfulAttempt)

Specified by:

setSuccessfulAttempt in interface TaskReport

getDiagnosticsList

public List<String> getDiagnosticsList()

Specified by:

getDiagnosticsList in interface TaskReport

getDiagnostics

public String getDiagnostics(int index)

Specified by:

getDiagnostics in interface TaskReport

getDiagnosticsCount

public int getDiagnosticsCount()

Specified by:

getDiagnosticsCount in interface TaskReport

addAllDiagnostics

public void addAllDiagnostics(List<String> diagnostics)

Specified by:

addAllDiagnostics in interface TaskReport

addDiagnostics

public void addDiagnostics(String diagnostics)

Specified by:

addDiagnostics in interface TaskReport

removeDiagnostics

public void removeDiagnostics(int index)

Specified by:

removeDiagnostics in interface TaskReport

clearDiagnostics

public void clearDiagnostics()

Specified by:

clearDiagnostics in interface TaskReport