public abstract class ObjectProcessor
extends java.lang.Object
ObjectMapper
and ObjectReducer
.Constructor and Description |
---|
ObjectProcessor() |
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) |
public org.apache.hadoop.mapreduce.TaskInputOutputContext<java.lang.Object,java.lang.Object,java.lang.Object,java.lang.Object> getContext()
public void setContext(org.apache.hadoop.mapreduce.TaskInputOutputContext<java.lang.Object,java.lang.Object,java.lang.Object,java.lang.Object> context)
public void close() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException