datafu.hourglass.mapreduce
Class ObjectProcessor

java.lang.Object
  datafu.hourglass.mapreduce.ObjectProcessor

Direct Known Subclasses:

ObjectMapper, ObjectReducer

public abstract class ObjectProcessor
extends java.lang.Object

Base class for ObjectMapper and ObjectReducer.

Author:

"Matthew Hayes"

Constructor Summary

ObjectProcessor()

Method Summary

void	close()
org.apache.hadoop.mapreduce.TaskInputOutputContext<java.lang.Object,java.lang.Object,java.lang.Object,java.lang.Object>	getContext()
void	setContext(org.apache.hadoop.mapreduce.TaskInputOutputContext<java.lang.Object,java.lang.Object,java.lang.Object,java.lang.Object> context)

Methods inherited from class java.lang.Object

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

Constructor Detail

ObjectProcessor

public ObjectProcessor()

Method Detail

getContext

public org.apache.hadoop.mapreduce.TaskInputOutputContext<java.lang.Object,java.lang.Object,java.lang.Object,java.lang.Object> getContext()

setContext

public void setContext(org.apache.hadoop.mapreduce.TaskInputOutputContext<java.lang.Object,java.lang.Object,java.lang.Object,java.lang.Object> context)

close

public void close()
           throws java.io.IOException,
                  java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException