org.apache.oozie.action.hadoop
Class StreamingMain

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

public class StreamingMain
extends MapReduceMain

Field Summary

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

HADOOP_JOBS

Constructor Summary

StreamingMain()

Method Summary

static void	main(String[] args)
static void	setStreaming(org.apache.hadoop.conf.Configuration conf, String mapper, String reducer, String recordReader, String[] recordReaderMapping, String[] env)
protected org.apache.hadoop.mapred.RunningJob	submitJob(org.apache.hadoop.conf.Configuration actionConf)

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

addActionConf, createJobClient, getStrings, run, setStrings

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

StreamingMain

public StreamingMain()

Method Detail

main

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

Throws:

Exception

submitJob

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

Overrides:

submitJob in class MapReduceMain

Throws:

Exception

setStreaming

public static void setStreaming(org.apache.hadoop.conf.Configuration conf,
                                String mapper,
                                String reducer,
                                String recordReader,
                                String[] recordReaderMapping,
                                String[] env)