de.hpi.fgis.voidgen.hadoop.tasks.joining
Class Join1QuadrupleInputMapper
java.lang.Object
org.apache.hadoop.mapred.MapReduceBase
de.hpi.fgis.voidgen.hadoop.tasks.joining.Join1QuadrupleInputMapper
- All Implemented Interfaces:
- java.io.Closeable, org.apache.hadoop.mapred.JobConfigurable, org.apache.hadoop.mapred.Mapper<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text,StringIntPair,RDFQuadruple>
public class Join1QuadrupleInputMapper
- extends org.apache.hadoop.mapred.MapReduceBase
- implements org.apache.hadoop.mapred.Mapper<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text,StringIntPair,RDFQuadruple>
Reads the input RDF quadruples an prepares them
for joining with the cluster identifier of the
nodes of the quadruples.
Input
- Key: ignored
- Value: textual representation of an RDFQuadruple
Output
- Key: a pair of
node of a cluster and
an integer describing the type of the value
('1' for a parsed RDFQuadruple)
- Value: a parsed RDFQuadruple
- 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
Method Summary |
void |
map(org.apache.hadoop.io.LongWritable key,
org.apache.hadoop.io.Text value,
org.apache.hadoop.mapred.OutputCollector<StringIntPair,RDFQuadruple> output,
org.apache.hadoop.mapred.Reporter reporter)
|
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 |
Join1QuadrupleInputMapper
public Join1QuadrupleInputMapper()
map
public void map(org.apache.hadoop.io.LongWritable key,
org.apache.hadoop.io.Text 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<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text,StringIntPair,RDFQuadruple>
- Throws:
java.io.IOException