datafu.hourglass.mapreduce

Class ObjectMapper

java.lang.Object

datafu.hourglass.mapreduce.ObjectProcessor

datafu.hourglass.mapreduce.ObjectMapper

Direct Known Subclasses:

CollapsingMapper, PartitioningMapper

public abstract class ObjectMapper
extends ObjectProcessor

Defines the interface for a mapper implementation that DelegatingMapper delegates to.

Constructor Summary

Constructors

Constructor and Description
ObjectMapper()

Method Summary

Methods

Modifier and Type	Method and Description
abstract void	map(java.lang.Object input, org.apache.hadoop.mapreduce.MapContext<java.lang.Object,java.lang.Object,java.lang.Object,java.lang.Object> context)

Methods inherited from class datafu.hourglass.mapreduce.ObjectProcessor

close, getContext, setContext

Methods inherited from class java.lang.Object

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

Constructor Detail

ObjectMapper

public ObjectMapper()

Method Detail

map

public abstract void map(java.lang.Object input,
       org.apache.hadoop.mapreduce.MapContext<java.lang.Object,java.lang.Object,java.lang.Object,java.lang.Object> context)
                  throws java.io.IOException,
                         java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException