com.cloudera.crunch.type
Class DataBridge

java.lang.Object
  com.cloudera.crunch.type.DataBridge

public class DataBridge
extends Object

Data structures for transitioning to the DoFns that make up a Crunch MapReduce task from the raw serialization input from the Hadoop MapReduce framework and back again.

Constructor Summary

DataBridge(Class<?> keyClass, Class<?> valueClass, Converter converter, MapFn inputMapFn, MapFn outputMapFn)

Method Summary

boolean	equals(Object obj)
Converter	getConverter()
MapFn	getInputMapFn()
MapFn	getOutputMapFn()
int	hashCode()

Methods inherited from class java.lang.Object

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

Constructor Detail

DataBridge

public DataBridge(Class<?> keyClass,
                  Class<?> valueClass,
                  Converter converter,
                  MapFn inputMapFn,
                  MapFn outputMapFn)

Method Detail

getConverter

public Converter getConverter()

getInputMapFn

public MapFn getInputMapFn()

getOutputMapFn

public MapFn getOutputMapFn()

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object