com.asakusafw.runtime.stage

Class StageInput

java.lang.Object

com.asakusafw.runtime.stage.StageInput

public class StageInput
extends Object

Represents a stage input.

Since:

0.1.0

Version:

0.7.1

Constructor Summary

Constructors

Constructor and Description
StageInput(String pathString, Class<? extends org.apache.hadoop.mapreduce.InputFormat> formatClass, Class<? extends org.apache.hadoop.mapreduce.Mapper> mapperClass) Creates a new instance without any attributes.
StageInput(String pathString, Class<? extends org.apache.hadoop.mapreduce.InputFormat> formatClass, Class<? extends org.apache.hadoop.mapreduce.Mapper> mapperClass, Map<String,String> attributes) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object obj)
Map<String,String>	getAttributes() Returns the input attributes.
Class<? extends org.apache.hadoop.mapreduce.InputFormat<?,?>>	getFormatClass() Returns the input format class for handling this input.
Class<? extends org.apache.hadoop.mapreduce.Mapper<?,?,?,?>>	getMapperClass() Returns the mapper class for handling this input.
String	getPathString() Returns the path expression for the input.
int	hashCode()

Methods inherited from class java.lang.Object

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

Constructor Detail

StageInput

public StageInput(String pathString,
                  Class<? extends org.apache.hadoop.mapreduce.InputFormat> formatClass,
                  Class<? extends org.apache.hadoop.mapreduce.Mapper> mapperClass)

Creates a new instance without any attributes.

Parameters:

pathString - path to the input (may includes variables)

formatClass - input format class

mapperClass - mapper class to process input data

Throws:

IllegalArgumentException - if some parameters were null

StageInput

public StageInput(String pathString,
                  Class<? extends org.apache.hadoop.mapreduce.InputFormat> formatClass,
                  Class<? extends org.apache.hadoop.mapreduce.Mapper> mapperClass,
                  Map<String,String> attributes)

Creates a new instance.

Parameters:

pathString - path to the input (may includes variables)

formatClass - input format class

mapperClass - mapper class to process input data

attributes - input attributes

Throws:

IllegalArgumentException - if some parameters were null

Since:

0.2.5

Method Detail

getPathString

public String getPathString()

Returns the path expression for the input.

Returns:

the path expression

getFormatClass

public Class<? extends org.apache.hadoop.mapreduce.InputFormat<?,?>> getFormatClass()

Returns the input format class for handling this input.

Returns:

the input format class

getMapperClass

public Class<? extends org.apache.hadoop.mapreduce.Mapper<?,?,?,?>> getMapperClass()

Returns the mapper class for handling this input.

Returns:

the mapper class

getAttributes

public Map<String,String> getAttributes()

Returns the input attributes.

Returns:

the attributes

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object