de.hpi.fgis.voidgen.hadoop.tasks.joining
Class Join2QuadrupleInputMapper
java.lang.Object
org.apache.hadoop.mapred.MapReduceBase
de.hpi.fgis.voidgen.hadoop.tasks.joining.Join2QuadrupleInputMapper
- All Implemented Interfaces:
- java.io.Closeable, org.apache.hadoop.mapred.JobConfigurable, org.apache.hadoop.mapred.Mapper<StringIntPair,RDFQuadruple,StringIntPair,RDFQuadruple>
public class Join2QuadrupleInputMapper
- extends org.apache.hadoop.mapred.MapReduceBase
- implements org.apache.hadoop.mapred.Mapper<StringIntPair,RDFQuadruple,StringIntPair,RDFQuadruple>
Identity mapper for reading output of join step 1
and pipes the quadruples, annotated with the
subject cluster, to the reducer.
Input
- Key: a pair of
node of a cluster and
an integer describing the type of the value
('2' for input RDFQuadruple with subject cluster set)
- Value: An RDFQuadruple where the nodes of the quadruple and the subject cluster are set.
Output is equal to input.
- Author:
- Dandy Fenz, Hasso Plattner Institute at University of Potsdam, Germany, Matthias Pohl, Hasso Plattner Institute at University of Potsdam, Germany, Johannes Gosda, Hasso Plattner Institute at University of Potsdam, Germany
Methods inherited from class org.apache.hadoop.mapred.MapReduceBase |
close, configure |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.apache.hadoop.mapred.JobConfigurable |
configure |
Methods inherited from interface java.io.Closeable |
close |
Join2QuadrupleInputMapper
public Join2QuadrupleInputMapper()
map
public void map(StringIntPair key,
RDFQuadruple value,
org.apache.hadoop.mapred.OutputCollector<StringIntPair,RDFQuadruple> output,
org.apache.hadoop.mapred.Reporter reporter)
throws java.io.IOException
- Specified by:
map
in interface org.apache.hadoop.mapred.Mapper<StringIntPair,RDFQuadruple,StringIntPair,RDFQuadruple>
- Throws:
java.io.IOException