org.apache.hadoop.mapreduce.tools

Class CLI

java.lang.Object

org.apache.hadoop.conf.Configured

org.apache.hadoop.mapreduce.tools.CLI

All Implemented Interfaces:

Configurable, Tool

Direct Known Subclasses:

JobClient

@InterfaceAudience.Public
 @InterfaceStability.Stable
public class CLI
extends Configured
implements Tool

Interprets the map reduce cli options

Field Summary

Fields

Modifier and Type	Field and Description
protected Cluster	cluster

Constructor Summary

Constructors

Constructor and Description
CLI()
CLI(Configuration conf)

Method Summary

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.

Methods inherited from class org.apache.hadoop.conf.Configured

getConf, setConf

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.conf.Configurable

getConf, setConf

Field Detail

cluster

protected Cluster cluster

Constructor Detail

CLI

public CLI()

CLI

public CLI(Configuration conf)

Method Detail

run

public int run(String[] argv)
        throws Exception

Description copied from interface: Tool

Execute the command with the given arguments.

Specified by:

run in interface Tool

Parameters:

argv - command specific arguments.

Returns:

exit code.

Throws:

Exception

getCounter

protected long getCounter(Counters counters,
                          String counterGroupName,
                          String counterName)
                   throws IOException

Throws:

IOException

getTaskLogURL

protected static String getTaskLogURL(TaskAttemptID taskId,
                                      String baseUrl)

displayTasks

protected void displayTasks(Job job,
                            String type,
                            String state)
                     throws IOException,
                            InterruptedException

Display the information about a job's tasks, of a particular type and in a particular state

Parameters:

job - the job

type - the type of the task (map/reduce/setup/cleanup)

state - the state of the task (pending/running/completed/failed/killed)

Throws:

IOException - when there is an error communicating with the master

InterruptedException

IllegalArgumentException - if an invalid type/state is passed

displayJobList

public void displayJobList(JobStatus[] jobs)
                    throws IOException,
                           InterruptedException

Throws:

IOException

InterruptedException

main

public static void main(String[] argv)
                 throws Exception

Throws:

Exception