de.hpi.fgis.voidgen.hadoop.tasks.clusterinformation
Class ClusterInfoStep1MapperTask2
java.lang.Object
org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text,StringStringPair,org.apache.hadoop.io.Text>
de.hpi.fgis.voidgen.hadoop.tasks.clusterinformation.ClusterInfoStep1MapperTask2
public class ClusterInfoStep1MapperTask2
- extends org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text,StringStringPair,org.apache.hadoop.io.Text>
This Mapper reads quadruple files where each line contains an RDF quadruple in N-Quad format.
For each quadruple a key-value pair is emitted.
Input
- Key: is ignored
- Value: a Text object describing a RDF quadruple
Output
- Key: a pair of
a generated cluster ID (the authority or schema of the URI) and
the predicate of the quadruple
- Value: the subject of this quadruple.
- 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
Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.Mapper |
org.apache.hadoop.mapreduce.Mapper.Context |
Method Summary |
void |
map(org.apache.hadoop.io.LongWritable key,
org.apache.hadoop.io.Text value,
org.apache.hadoop.mapreduce.Mapper.Context context)
|
Methods inherited from class org.apache.hadoop.mapreduce.Mapper |
cleanup, run, setup |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ClusterInfoStep1MapperTask2
public ClusterInfoStep1MapperTask2()
map
public void map(org.apache.hadoop.io.LongWritable key,
org.apache.hadoop.io.Text value,
org.apache.hadoop.mapreduce.Mapper.Context context)
throws java.io.IOException,
java.lang.InterruptedException
- Overrides:
map
in class org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text,StringStringPair,org.apache.hadoop.io.Text>
- Throws:
java.io.IOException
java.lang.InterruptedException