This project has retired. For details please refer to its Attic page.

org.apache.oozie.action.hadoop
Class PipesMain

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

public class PipesMain
extends MapReduceMain

Constructor Summary

PipesMain()

Method Summary

static void	main(String[] args)
static void	setPipes(org.apache.hadoop.conf.Configuration conf, String map, String reduce, String inputFormat, String partitioner, String writer, String program, org.apache.hadoop.fs.Path appPath)
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

logMasking, run

Methods inherited from class java.lang.Object

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

Constructor Detail

PipesMain

public PipesMain()

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

setPipes

public static void setPipes(org.apache.hadoop.conf.Configuration conf,
                            String map,
                            String reduce,
                            String inputFormat,
                            String partitioner,
                            String writer,
                            String program,
                            org.apache.hadoop.fs.Path appPath)