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

org.apache.crunch.io.impl
Class InputBundle

java.lang.Object
  org.apache.crunch.io.impl.InputBundle

All Implemented Interfaces:

Serializable

public class InputBundle
extends Object
implements Serializable

A combination of an InputFormat and any configuration information that InputFormat needs to run properly. InputBundles allow us to let different InputFormats pretend as if they are the only InputFormat that exists in a particular MapReduce job.

See Also:

Serialized Form

Constructor Summary

InputBundle(Class<? extends org.apache.hadoop.mapreduce.InputFormat> inputFormatClass)

Method Summary

org.apache.hadoop.conf.Configuration	configure(org.apache.hadoop.conf.Configuration conf)
boolean	equals(Object other)
static InputBundle	fromSerialized(String serialized)
Map<String,String>	getExtraConfiguration()
Class<? extends org.apache.hadoop.mapreduce.InputFormat>	getInputFormatClass()
String	getName()
int	hashCode()
String	serialize()
InputBundle	set(String key, String value)

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

InputBundle

public InputBundle(Class<? extends org.apache.hadoop.mapreduce.InputFormat> inputFormatClass)

Method Detail

fromSerialized

public static InputBundle fromSerialized(String serialized)

set

public InputBundle set(String key,
                       String value)

getInputFormatClass

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

getExtraConfiguration

public Map<String,String> getExtraConfiguration()

configure

public org.apache.hadoop.conf.Configuration configure(org.apache.hadoop.conf.Configuration conf)

serialize

public String serialize()

getName

public String getName()

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object other)

Overrides:

equals in class Object