org.apache.oozie.action.hadoop
Class MapReduceMain

java.lang.Object
  org.apache.oozie.action.hadoop.LauncherMain
      org.apache.oozie.action.hadoop.MapReduceMain

Direct Known Subclasses:

PipesMain, StreamingMain

public class MapReduceMain
extends LauncherMain

Field Summary

Fields inherited from class org.apache.oozie.action.hadoop.LauncherMain

HADOOP_JOBS

Constructor Summary

MapReduceMain()

Method Summary

protected void	addActionConf(org.apache.hadoop.mapred.JobConf jobConf, org.apache.hadoop.conf.Configuration actionConf)
protected org.apache.hadoop.mapred.JobClient	createJobClient(org.apache.hadoop.mapred.JobConf jobConf)
static String[]	getStrings(org.apache.hadoop.conf.Configuration conf, String key)
static void	main(String[] args)
protected void	run(String[] args)
static void	setStrings(org.apache.hadoop.conf.Configuration conf, String key, String[] values)
protected org.apache.hadoop.mapred.RunningJob	submitJob(org.apache.hadoop.conf.Configuration actionConf)

Methods inherited from class org.apache.oozie.action.hadoop.LauncherMain

getHadoopJobIds, logMasking, run

Methods inherited from class java.lang.Object

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

Constructor Detail

MapReduceMain

public MapReduceMain()

Method Detail

main

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

Throws:

Exception

run

protected void run(String[] args)
            throws Exception

Specified by:

run in class LauncherMain

Throws:

Exception

addActionConf

protected void addActionConf(org.apache.hadoop.mapred.JobConf jobConf,
                             org.apache.hadoop.conf.Configuration actionConf)

submitJob

protected org.apache.hadoop.mapred.RunningJob submitJob(org.apache.hadoop.conf.Configuration actionConf)
                                                 throws Exception

Throws:

Exception

createJobClient

protected org.apache.hadoop.mapred.JobClient createJobClient(org.apache.hadoop.mapred.JobConf jobConf)
                                                      throws IOException

Throws:

IOException

setStrings

public static void setStrings(org.apache.hadoop.conf.Configuration conf,
                              String key,
                              String[] values)

getStrings

public static String[] getStrings(org.apache.hadoop.conf.Configuration conf,
                                  String key)