org.openimaj.hadoop.mapreduce

Class SingleStagedJob

java.lang.Object

org.apache.hadoop.conf.Configured

org.openimaj.hadoop.mapreduce.StageRunner

org.openimaj.hadoop.mapreduce.SingleStagedJob

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, org.apache.hadoop.util.Tool

public class SingleStagedJob
extends StageRunner

Constructor Summary

Constructors

Constructor and Description
SingleStagedJob(org.apache.hadoop.fs.Path[] inputs, org.apache.hadoop.fs.Path output)
SingleStagedJob(Stage<?,?,?,?,?,?,?,?> s, org.apache.hadoop.fs.Path[] inputs, org.apache.hadoop.fs.Path output)

Method Summary

Modifier and Type	Method and Description
void	args(String[] args)
org.apache.hadoop.fs.Path[]	inputs()
org.apache.hadoop.fs.Path	output()
void	setStage(Stage<?,?,?,?,?,?,?,?> stage)
Stage<?,?,?,?,?,?,?,?>	stage()

Methods inherited from class org.openimaj.hadoop.mapreduce.StageRunner

run, runMain, shouldWait

Methods inherited from class org.apache.hadoop.conf.Configured

getConf, setConf

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.conf.Configurable

getConf, setConf

Constructor Detail

SingleStagedJob

public SingleStagedJob(org.apache.hadoop.fs.Path[] inputs,
                       org.apache.hadoop.fs.Path output)

SingleStagedJob

public SingleStagedJob(Stage<?,?,?,?,?,?,?,?> s,
                       org.apache.hadoop.fs.Path[] inputs,
                       org.apache.hadoop.fs.Path output)

Method Detail

output

public org.apache.hadoop.fs.Path output()

Specified by:

output in class StageRunner

Returns:

the output fed to the stage

inputs

public org.apache.hadoop.fs.Path[] inputs()

Specified by:

inputs in class StageRunner

Returns:

the inputs fed to the stage

args

public void args(String[] args)

Specified by:

args in class StageRunner

Parameters:

args - arguments handed to the Tool.run(String[]). Given before outputs, inputs or stages are asked for.

stage

public Stage<?,?,?,?,?,?,?,?> stage()

Specified by:

stage in class StageRunner

Returns:

the stage which should be ran

setStage

public void setStage(Stage<?,?,?,?,?,?,?,?> stage)