de.hpi.fgis.voidgen.hadoop.tasks.ksimilarity
Class KSimStep2Reducer

java.lang.Object
  extended by org.apache.hadoop.mapreduce.Reducer<StringArrayWritableComparable,org.apache.hadoop.io.IntWritable,StringArrayWritableComparable,org.apache.hadoop.io.IntWritable>
      extended by 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

Output

Author:
Eyk Kny, Hasso Plattner Institute at University of Potsdam, Germany, Johannes Gosda, Hasso Plattner Institute at University of Potsdam, Germany

Nested Class Summary
 
Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.Reducer
org.apache.hadoop.mapreduce.Reducer.Context
 
Constructor Summary
KSimStep2Reducer()
           
 
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
 

Constructor Detail

KSimStep2Reducer

public KSimStep2Reducer()
Method Detail

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