org.apache.hadoop.tools.rumen

类 TaskInfo

java.lang.Object

org.apache.hadoop.tools.rumen.TaskInfo

public class TaskInfo
extends Object

构造器概要

构造器

构造器和说明
TaskInfo(long bytesIn, int recsIn, long bytesOut, int recsOut, long maxMemory)
TaskInfo(long bytesIn, int recsIn, long bytesOut, int recsOut, long maxMemory, ResourceUsageMetrics metrics)

方法概要

方法

限定符和类型	方法和说明
long	getInputBytes()
int	getInputRecords()
long	getOutputBytes()
int	getOutputRecords()
ResourceUsageMetrics	getResourceUsageMetrics()
long	getTaskMemory()

从类继承的方法 java.lang.Object

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

构造器详细资料

TaskInfo

public TaskInfo(long bytesIn,
        int recsIn,
        long bytesOut,
        int recsOut,
        long maxMemory)

TaskInfo

public TaskInfo(long bytesIn,
        int recsIn,
        long bytesOut,
        int recsOut,
        long maxMemory,
        ResourceUsageMetrics metrics)

方法详细资料

getInputBytes

public long getInputBytes()

返回:

Raw bytes read from the FileSystem into the task. Note that this may not always match the input bytes to the task.

getInputRecords

public int getInputRecords()

返回:

Number of records input to this task.

getOutputBytes

public long getOutputBytes()

返回:

Raw bytes written to the destination FileSystem. Note that this may not match output bytes.

getOutputRecords

public int getOutputRecords()

返回:

Number of records output from this task.

getTaskMemory

public long getTaskMemory()

返回:

Memory used by the task leq the heap size.

getResourceUsageMetrics

public ResourceUsageMetrics getResourceUsageMetrics()

返回:

Resource usage metrics