Package 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

@Public
@Stable
public class CLI
extends Configured
implements Tool

Interprets the map reduce cli options

Field Summary

Fields

Modifier and Type	Field	Description
protected Cluster	cluster
static String	dataPattern
static String	headerPattern

Constructor Summary

Constructors

Constructor	Description
CLI()
CLI(Configuration conf)

Method Summary

Modifier and Type	Method	Description
void	displayJobList(JobStatus[] jobs)
void	displayJobList(JobStatus[] jobs, PrintWriter writer)
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 Details

cluster

protected Cluster cluster

headerPattern

@Private
public static String headerPattern

dataPattern

@Private
public static String dataPattern

Constructor Details

CLI

public CLI()

CLI

public CLI(Configuration conf)

Method Details

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 - command 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

displayJobList

@Private
public void displayJobList(JobStatus[] jobs,
 PrintWriter writer)

main

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

Throws:

Exception