de.hpi.fgis.voidgen.hadoop.tasks.clusterinformation
Class ClusterInfoStep1Mapper
java.lang.Object
org.apache.hadoop.mapreduce.Mapper<RDFQuadruple,org.apache.hadoop.io.NullWritable,StringStringPair,org.apache.hadoop.io.Text>
de.hpi.fgis.voidgen.hadoop.tasks.clusterinformation.ClusterInfoStep1Mapper
public class ClusterInfoStep1Mapper
- extends org.apache.hadoop.mapreduce.Mapper<RDFQuadruple,org.apache.hadoop.io.NullWritable,StringStringPair,org.apache.hadoop.io.Text>
Takes RDF quadruples and outputs key-value pairs
for each quadruple.
Input
- Key: RDF quadruple where subject and object cluster are set
- Value: ignored
Output
- Key: pair of
cluster identifier and
predicate
- Value: subject of the 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(RDFQuadruple key,
org.apache.hadoop.io.NullWritable 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 |
ClusterInfoStep1Mapper
public ClusterInfoStep1Mapper()
map
public void map(RDFQuadruple key,
org.apache.hadoop.io.NullWritable value,
org.apache.hadoop.mapreduce.Mapper.Context context)
throws java.io.IOException,
java.lang.InterruptedException
- Overrides:
map
in class org.apache.hadoop.mapreduce.Mapper<RDFQuadruple,org.apache.hadoop.io.NullWritable,StringStringPair,org.apache.hadoop.io.Text>
- Throws:
java.io.IOException
java.lang.InterruptedException