MapReduceCommands extends ConfigurationAware implements ExecutionProcessor { public void init() { try { jobClient = new JobClient(new JobConf(getHadoopConfiguration())); } catch (IOException ex) { LOG.severe("Cannot create job client" + ex.getMessage()); } }  @Override ParseResult beforeInvocation(ParseResult invocationContext); void init(); @CliCommand(value = PREFIX + "submit", help = "Submit a Map Reduce job defined in the job file") void submit(@CliOption(key = { "jobfile" }, mandatory = true, help = "the configuration file for MR job") final String jobFile); @CliCommand(value = PREFIX + "status", help = "Query Map Reduce job status.") void status(@CliOption(key = { "jobid" }, mandatory = true, help = "the job Id") final String jobid); @CliCommand(value = PREFIX + "counter", help = "Print the counter value of the MR job") void counter(
			@CliOption(key = { "jobid" }, mandatory = true, help = "the job Id") final String jobid, 
			@CliOption(key = { "groupname" }, mandatory = true, help = "the job Id") final String groupName,
			@CliOption(key = { "countername" }, mandatory = true, help = "the job Id") final String counterName); @CliCommand(value = PREFIX + "kill", help = "Kill the Map Reduce job") void kill(@CliOption(key = { "jobid" }, mandatory = true, help = "the job Id") final String jobid); @CliCommand(value = PREFIX + "events", help = "Print the events' detail received by jobtracker for the given range") void events(
			@CliOption(key = { "jobid" }, mandatory = true, help = "the job Id") final String jobid, 
			@CliOption(key = { "from" }, mandatory = true, help = "from event number") final String from, 
			@CliOption(key = { "number" }, mandatory = true, help = "total number of events") final String number); @CliCommand(value = PREFIX + "history", help = "Print job details, failed and killed job details") void history(@CliOption(key = { "all" }, mandatory = false, specifiedDefaultValue = "true", unspecifiedDefaultValue = "false", help = "Whether print all information") final boolean all, 
			@CliOption(key = { "" }, mandatory = true, help = "job output directory") final String outputDir); @CliCommand(value = PREFIX + "list", help = "List the Map Reduce jobs") void list(@CliOption(key = { "all" }, mandatory = false, specifiedDefaultValue = "true", unspecifiedDefaultValue = "false", help = "Whether list all jobs") final boolean all); @CliCommand(value = "mr task kill", help = "Kill the Map Reduce task") void killTask(@CliOption(key = { "taskid" }, mandatory = true, help = "the task Id") final String taskid); @CliCommand(value = "mr task fail", help = "Fail the Map Reduce task") void failTask(@CliOption(key = { "taskid" }, mandatory = true, help = "the task Id") final String taskid); @CliCommand(value = PREFIX + "set priority", help = "Change the priority of the job") void setPriority(
			@CliOption(key = { "jobid" }, mandatory = true, help = "the job Id") final String jobid, 
			@CliOption(key = { "priority" }, mandatory = true, help = "the job priority") final JobPriority priority); @CliCommand(value = "mr jar", help = "Run Map Reduce job in the jar") void jar(
			@CliOption(key = { "jarfile" }, mandatory = true, help = "jar file name") final String jarFileName, 
			@CliOption(key = "mainclass", mandatory = true, help = "main class name") final String mainClassName, 
			@CliOption(key = "args", mandatory = false, help = "input path") final String args); void runJar(final String jarFileName, final String mainClassName, final String args); void writeHadoopConfiguration(File configDir, Configuration config);  }
@Test public void testInit() { mrCmds.init(); }