@InterfaceAudience.Public @InterfaceStability.Stable public class CLI extends Configured implements Tool
Constructor and Description |
---|
CLI() |
CLI(Configuration conf) |
Modifier and Type | Method and Description |
---|---|
void |
displayJobList(JobStatus[] jobs) |
protected void |
displayTasks(Job job,
String type,
String state)
Display the information about a job's tasks, of a particular type and
in a particular state
|
protected long |
getCounter(Counters counters,
String counterGroupName,
String counterName) |
protected static String |
getTaskLogURL(TaskAttemptID taskId,
String baseUrl) |
static void |
main(String[] argv) |
int |
run(String[] argv)
Execute the command with the given arguments.
|
getConf, setConf
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getConf, setConf
protected Cluster cluster
public CLI()
public CLI(Configuration conf)
public int run(String[] argv) throws Exception
Tool
protected long getCounter(Counters counters, String counterGroupName, String counterName) throws IOException
IOException
protected static String getTaskLogURL(TaskAttemptID taskId, String baseUrl)
protected void displayTasks(Job job, String type, String state) throws IOException, InterruptedException
job
- the jobtype
- the type of the task (map/reduce/setup/cleanup)state
- the state of the task
(pending/running/completed/failed/killed)IOException
InterruptedException
public void displayJobList(JobStatus[] jobs) throws IOException, InterruptedException
IOException
InterruptedException
Copyright © 2019 Apache Software Foundation. All rights reserved.