de.hpi.fgis.voidgen.hadoop.tasks.distinctclustering
Class TypeStatisticsMapper
java.lang.Object
org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text,StringIntPair,StringIntPair>
de.hpi.fgis.voidgen.hadoop.tasks.distinctclustering.TypeStatisticsMapper
public class TypeStatisticsMapper
- extends org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text,StringIntPair,StringIntPair>
Reads RDF quadruples and outputs for each
quadruple where the predicate is rdf:type
the subjects of this type and an integer
for counting the appearances of the predicate.
Input
- Key: ignored
- Value: textual representation of an RDF quadruple
Output
- Key: pair of
the object of the quadruple (the type) and
a '0'
- Value: pair of
the String value of '1' and
a '0'
- Key2: pair of
the object of the quadruple (the type) and
a '1'
- Value2: pair of
the subject of the quadruple
a '1'
- Author:
- Martin Linkhorst, 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 |
TypeStatisticsMapper
public TypeStatisticsMapper()
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,StringIntPair,StringIntPair>
- Throws:
java.io.IOException
java.lang.InterruptedException