|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object cascading.stats.CascadingStats cascading.stats.StepStats cascading.flow.hadoop.HadoopStepStats
public abstract class HadoopStepStats
Class HadoopStepStats ...
Nested Class Summary | |
---|---|
static class |
HadoopStepStats.HadoopTaskStats
Class HadoopTaskStats ... |
Nested classes/interfaces inherited from class cascading.stats.CascadingStats |
---|
CascadingStats.Status |
Constructor Summary | |
---|---|
protected |
HadoopStepStats(String stepName)
|
Method Summary | |
---|---|
void |
captureDetail()
Method captureDetail will recursively capture details about nested systems. |
void |
captureJobStats()
|
Collection |
getChildren()
|
Collection<String> |
getCounterGroups()
Method getCounterGroups returns all the available counter group names. |
Collection<String> |
getCounterGroupsMatching(String regex)
Method getCounterGroupsMatching returns all the available counter group names that match the given regular expression. |
Collection<String> |
getCountersFor(String group)
Method getCountersFor returns all the counter names for the give group name. |
long |
getCounterValue(Enum counter)
Method getCounter returns the current value for the given counter Enum. |
long |
getCounterValue(String group,
String counter)
Method getCounter returns the current value for the given group and counter. |
protected abstract JobClient |
getJobClient()
|
String |
getJobID()
|
int |
getNumMapTasks()
|
int |
getNumReducerTasks()
|
protected abstract RunningJob |
getRunningJob()
|
ArrayList<HadoopStepStats.HadoopTaskStats> |
getTaskStats()
|
void |
setNumMapTasks(int numMapTasks)
|
void |
setNumReducerTasks(int numReducerTasks)
|
Methods inherited from class cascading.stats.StepStats |
---|
toString |
Methods inherited from class cascading.stats.CascadingStats |
---|
getCountersFor, getCurrentDuration, getDuration, getFinishedTime, getID, getName, getStartTime, getStatsString, getStatus, isFailed, isFinished, isPending, isRunning, isSkipped, isStopped, isSuccessful, markFailed, markRunning, markSkipped, markStartTime, markStopped, markSuccessful |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
protected HadoopStepStats(String stepName)
Method Detail |
---|
public ArrayList<HadoopStepStats.HadoopTaskStats> getTaskStats()
public int getNumMapTasks()
public void setNumMapTasks(int numMapTasks)
public int getNumReducerTasks()
public void setNumReducerTasks(int numReducerTasks)
public String getJobID()
protected abstract JobClient getJobClient()
protected abstract RunningJob getRunningJob()
public Collection<String> getCounterGroups()
CascadingStats
getCounterGroups
in class CascadingStats
public Collection<String> getCounterGroupsMatching(String regex)
CascadingStats
getCounterGroupsMatching
in class CascadingStats
regex
- of type String
public Collection<String> getCountersFor(String group)
CascadingStats
getCountersFor
in class CascadingStats
public long getCounterValue(Enum counter)
CascadingStats
getCounterValue
in class CascadingStats
counter
- of type Enum
public long getCounterValue(String group, String counter)
CascadingStats
getCounterValue
in class CascadingStats
group
- of type Stringcounter
- of type String
public void captureJobStats()
public Collection getChildren()
getChildren
in class CascadingStats
public void captureDetail()
CascadingStats
captureDetail
in class CascadingStats
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |