de.hpi.fgis.voidgen.hadoop.tasks.ksimilarity
Class KSimStep2Reducer
java.lang.Object
org.apache.hadoop.mapreduce.Reducer<StringArrayWritableComparable,org.apache.hadoop.io.IntWritable,StringArrayWritableComparable,org.apache.hadoop.io.IntWritable>
de.hpi.fgis.voidgen.hadoop.tasks.ksimilarity.KSimStep2Reducer
public class KSimStep2Reducer
- extends org.apache.hadoop.mapreduce.Reducer<StringArrayWritableComparable,org.apache.hadoop.io.IntWritable,StringArrayWritableComparable,org.apache.hadoop.io.IntWritable>
Counts the appearances of each pair of subjects
to get the total number of links between each
pair of subjects.
Input
- Key: a set of strings describing the connectedness
of two subjects (in detail subject-context pairs)
because of sharing the same predicate-object pair.
- Value: a '1' indicating that there is
one connection between both subjects.
Output
- Key: set of strings describing a fuzzy linked pair
- Value: the number of links between the subject
- Author:
- Eyk Kny, 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.Reducer |
org.apache.hadoop.mapreduce.Reducer.Context |
Method Summary |
protected void |
reduce(StringArrayWritableComparable key,
java.lang.Iterable<org.apache.hadoop.io.IntWritable> values,
org.apache.hadoop.mapreduce.Reducer.Context output)
|
Methods inherited from class org.apache.hadoop.mapreduce.Reducer |
cleanup, run, setup |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
KSimStep2Reducer
public KSimStep2Reducer()
reduce
protected void reduce(StringArrayWritableComparable key,
java.lang.Iterable<org.apache.hadoop.io.IntWritable> values,
org.apache.hadoop.mapreduce.Reducer.Context output)
throws java.io.IOException,
java.lang.InterruptedException
- Overrides:
reduce
in class org.apache.hadoop.mapreduce.Reducer<StringArrayWritableComparable,org.apache.hadoop.io.IntWritable,StringArrayWritableComparable,org.apache.hadoop.io.IntWritable>
- Throws:
java.io.IOException
java.lang.InterruptedException