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.

Author:

"Matthew Hayes"

Constructor Summary

ObjectMapper()

Method Summary

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