org.apache.oozie.action.hadoop
Class MapReduceMain

java.lang.Object
  extended by org.apache.oozie.action.hadoop.LauncherMain
      extended by 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)


Copyright © 2013 Apache Software Foundation. All Rights Reserved.