|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object datafu.hourglass.mapreduce.ObjectProcessor datafu.hourglass.mapreduce.ObjectMapper datafu.hourglass.mapreduce.CollapsingMapper
public class CollapsingMapper
The mapper used by AbstractPartitionCollapsingIncrementalJob
and its derived classes.
An implementation of Mapper
is used for the
map operation, which produces key and intermediate value pairs from the input.
Constructor Summary | |
---|---|
CollapsingMapper()
|
Method Summary | |
---|---|
Mapper<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord> |
getMapper()
Gets the mapper. |
boolean |
getReuseOutput()
Gets whether previous output is being reused. |
PartitionCollapsingSchemas |
getSchemas()
Gets the Avro schemas. |
void |
map(java.lang.Object inputObj,
org.apache.hadoop.mapreduce.MapContext<java.lang.Object,java.lang.Object,java.lang.Object,java.lang.Object> context)
|
void |
setContext(org.apache.hadoop.mapreduce.TaskInputOutputContext<java.lang.Object,java.lang.Object,java.lang.Object,java.lang.Object> context)
|
void |
setMapper(Mapper<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord> mapper)
Sets the mapper. |
void |
setReuseOutput(boolean reuseOutput)
Sets whether previous output is being reused. |
void |
setSchemas(PartitionCollapsingSchemas schemas)
Sets the Avro schemas. |
Methods inherited from class datafu.hourglass.mapreduce.ObjectProcessor |
---|
close, getContext |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public CollapsingMapper()
Method Detail |
---|
public void map(java.lang.Object inputObj, 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
map
in class ObjectMapper
java.io.IOException
java.lang.InterruptedException
public boolean getReuseOutput()
public void setReuseOutput(boolean reuseOutput)
reuseOutput
- true if previous output is reusedpublic void setContext(org.apache.hadoop.mapreduce.TaskInputOutputContext<java.lang.Object,java.lang.Object,java.lang.Object,java.lang.Object> context)
setContext
in class ObjectProcessor
public Mapper<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord> getMapper()
public void setMapper(Mapper<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord> mapper)
mapper
- public void setSchemas(PartitionCollapsingSchemas schemas)
schemas
- public PartitionCollapsingSchemas getSchemas()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |