org.apache.crunch

Class PipelineResult.StageResult

java.lang.Object

org.apache.crunch.PipelineResult.StageResult

Enclosing class:

PipelineResult

public static class PipelineResult.StageResult
extends Object

Constructor Summary

Constructors

Constructor and Description
StageResult(String stageName, org.apache.hadoop.mapreduce.Counters counters)
StageResult(String stageName, org.apache.hadoop.mapreduce.Counters counters, long startTimeMsec, long endTimeMsec)
StageResult(String stageName, String stageId, org.apache.hadoop.mapreduce.Counters counters, long startTimeMsec, long jobStartTimeMsec, long jobEndTimeMsec, long endTimeMsec)

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.mapreduce.Counter	findCounter(Enum<?> key) Deprecated. The Counter class changed incompatibly between Hadoop 1 and 2 (from a class to an interface) so user programs should avoid this method and use getCounterValue(Enum) and/or getCounterDisplayName(Enum).
String	getCounterDisplayName(Enum<?> key)
String	getCounterDisplayName(String groupName, String counterName)
Map<String,Set<String>>	getCounterNames()
org.apache.hadoop.mapreduce.Counters	getCounters() Deprecated. The Counter class changed incompatibly between Hadoop 1 and 2 (from a class to an interface) so user programs should avoid this method and use getCounterNames().
long	getCounterValue(Enum<?> key)
long	getCounterValue(String groupName, String counterName)
long	getEndTimeMsec()
long	getJobEndTimeMsec()
long	getJobStartTimeMsec()
String	getStageId()
String	getStageName()
long	getStartTimeMsec()

Methods inherited from class java.lang.Object

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

Constructor Detail

StageResult

public StageResult(String stageName,
                   org.apache.hadoop.mapreduce.Counters counters)

StageResult

public StageResult(String stageName,
                   org.apache.hadoop.mapreduce.Counters counters,
                   long startTimeMsec,
                   long endTimeMsec)

StageResult

public StageResult(String stageName,
                   String stageId,
                   org.apache.hadoop.mapreduce.Counters counters,
                   long startTimeMsec,
                   long jobStartTimeMsec,
                   long jobEndTimeMsec,
                   long endTimeMsec)

Method Detail

getStageName

public String getStageName()

getStageId

public String getStageId()

getStartTimeMsec

public long getStartTimeMsec()

Returns:

the overall start time for this stage, that is, the time at which any pre-job hooks were started.

getJobStartTimeMsec

public long getJobStartTimeMsec()

Returns:

the time that the work for this stage was submitted to the cluster for execution, if applicable.

getJobEndTimeMsec

public long getJobEndTimeMsec()

Returns:

the time that the work for this stage finished processing on the cluster, if applicable.

getEndTimeMsec

public long getEndTimeMsec()

Returns:

the overall end time for this stage, that is, the time at which any post-job hooks completed.

getCounters

@Deprecated
public org.apache.hadoop.mapreduce.Counters getCounters()

Deprecated. The Counter class changed incompatibly between Hadoop 1 and 2 (from a class to an interface) so user programs should avoid this method and use getCounterNames().

getCounterNames

public Map<String,Set<String>> getCounterNames()

Returns:

a map of group names to counter names.

findCounter

@Deprecated
public org.apache.hadoop.mapreduce.Counter findCounter(Enum<?> key)

Deprecated. The Counter class changed incompatibly between Hadoop 1 and 2 (from a class to an interface) so user programs should avoid this method and use getCounterValue(Enum) and/or getCounterDisplayName(Enum).

getCounterValue

public long getCounterValue(String groupName,
                            String counterName)

getCounterDisplayName

public String getCounterDisplayName(String groupName,
                                    String counterName)

getCounterValue

public long getCounterValue(Enum<?> key)

getCounterDisplayName

public String getCounterDisplayName(Enum<?> key)