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.

Constructor Summary

Constructors

Constructor and Description
ObjectProcessor()

Method Summary

Modifier and Type	Method and Description
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