cascading.stats.hadoop

Class HadoopSliceStats

java.lang.Object

cascading.stats.FlowSliceStats<HadoopSliceStats.Kind>

cascading.stats.hadoop.HadoopSliceStats

All Implemented Interfaces:

ProvidesCounters

public class HadoopSliceStats
extends FlowSliceStats<HadoopSliceStats.Kind>
implements ProvidesCounters

Class HadoopTaskStats tracks individual task stats.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	HadoopSliceStats.HadoopAttempt
static class	HadoopSliceStats.Kind

Nested classes/interfaces inherited from class cascading.stats.FlowSliceStats

FlowSliceStats.FlowSliceAttempt

Method Summary

Methods

Modifier and Type	Method and Description
void	addAttempt(TaskCompletionEvent event)
java.util.Map<java.lang.Integer,FlowSliceStats.FlowSliceAttempt>	getAttempts()
java.util.Collection<java.lang.String>	getCounterGroups()
java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.Long>>	getCounters()
java.util.Collection<java.lang.String>	getCountersFor(java.lang.Class<? extends java.lang.Enum> group)
java.util.Collection<java.lang.String>	getCountersFor(java.lang.String group)
long	getCounterValue(java.lang.Enum counter)
long	getCounterValue(java.lang.String group, java.lang.String name)
java.lang.String[]	getDiagnostics()
java.lang.String	getID()
HadoopSliceStats.Kind	getKind()
long	getLastSuccessfulCounterFetchTime()
CascadingStats.Status	getParentStatus()
long	getProcessFinishTime()
java.lang.String	getProcessNodeID()
float	getProcessProgress()
java.lang.String	getProcessSliceID()
long	getProcessStartTime()
java.lang.String	getProcessStatus()
java.lang.String	getProcessStepID()
float	getProgress()
CascadingStats.Status	getStatus()
int	getTaskIDNum()
protected TaskReport	getTaskReport()
void	setLastFetch(long lastFetch)
java.lang.String	toString()
void	update(CascadingStats.Status parentStatus, HadoopSliceStats.Kind kind, TaskReport taskReport, long lastFetch)

Methods inherited from class cascading.stats.FlowSliceStats

getProcessID, getProcessPendingTime, getProcessRunTime, getProcessSubmitTime

Methods inherited from class java.lang.Object

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

Method Detail

update

public void update(CascadingStats.Status parentStatus,
          HadoopSliceStats.Kind kind,
          TaskReport taskReport,
          long lastFetch)

getID

public java.lang.String getID()

Specified by:

getID in class FlowSliceStats<HadoopSliceStats.Kind>

getKind

public HadoopSliceStats.Kind getKind()

Specified by:

getKind in class FlowSliceStats<HadoopSliceStats.Kind>

getProcessSliceID

public java.lang.String getProcessSliceID()

Specified by:

getProcessSliceID in class FlowSliceStats<HadoopSliceStats.Kind>

getTaskIDNum

public int getTaskIDNum()

getProcessNodeID

public java.lang.String getProcessNodeID()

Specified by:

getProcessNodeID in class FlowSliceStats<HadoopSliceStats.Kind>

getProcessStepID

public java.lang.String getProcessStepID()

Specified by:

getProcessStepID in class FlowSliceStats<HadoopSliceStats.Kind>

getTaskReport

protected TaskReport getTaskReport()

getProgress

public float getProgress()

getProcessStatus

public java.lang.String getProcessStatus()

Specified by:

getProcessStatus in class FlowSliceStats<HadoopSliceStats.Kind>

getProcessProgress

public float getProcessProgress()

Specified by:

getProcessProgress in class FlowSliceStats<HadoopSliceStats.Kind>

getProcessStartTime

public long getProcessStartTime()

Specified by:

getProcessStartTime in class FlowSliceStats<HadoopSliceStats.Kind>

getProcessFinishTime

public long getProcessFinishTime()

Specified by:

getProcessFinishTime in class FlowSliceStats<HadoopSliceStats.Kind>

getParentStatus

public CascadingStats.Status getParentStatus()

getStatus

public CascadingStats.Status getStatus()

Specified by:

getStatus in class FlowSliceStats<HadoopSliceStats.Kind>

getDiagnostics

public java.lang.String[] getDiagnostics()

Specified by:

getDiagnostics in class FlowSliceStats<HadoopSliceStats.Kind>

getCounters

public java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.Long>> getCounters()

Specified by:

getCounters in class FlowSliceStats<HadoopSliceStats.Kind>

getAttempts

public java.util.Map<java.lang.Integer,FlowSliceStats.FlowSliceAttempt> getAttempts()

Specified by:

getAttempts in class FlowSliceStats<HadoopSliceStats.Kind>

setLastFetch

public void setLastFetch(long lastFetch)

getLastSuccessfulCounterFetchTime

public long getLastSuccessfulCounterFetchTime()

Specified by:

getLastSuccessfulCounterFetchTime in interface ProvidesCounters

getCounterGroups

public java.util.Collection<java.lang.String> getCounterGroups()

Specified by:

getCounterGroups in interface ProvidesCounters

getCountersFor

public java.util.Collection<java.lang.String> getCountersFor(java.lang.String group)

Specified by:

getCountersFor in interface ProvidesCounters

getCountersFor

public java.util.Collection<java.lang.String> getCountersFor(java.lang.Class<? extends java.lang.Enum> group)

Specified by:

getCountersFor in interface ProvidesCounters

getCounterValue

public long getCounterValue(java.lang.Enum counter)

Specified by:

getCounterValue in interface ProvidesCounters

getCounterValue

public long getCounterValue(java.lang.String group,
                   java.lang.String name)

Specified by:

getCounterValue in interface ProvidesCounters

addAttempt

public void addAttempt(TaskCompletionEvent event)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object