de.hpi.fgis.voidgen.hadoop.tasks.linksets
Class LinkSetsReducer
java.lang.Object
org.apache.hadoop.mapreduce.Reducer<StringStringPair,org.apache.hadoop.io.IntWritable,StringStringPair,org.apache.hadoop.io.IntWritable>
de.hpi.fgis.voidgen.hadoop.tasks.linksets.LinkSetsReducer
public class LinkSetsReducer
- extends org.apache.hadoop.mapreduce.Reducer<StringStringPair,org.apache.hadoop.io.IntWritable,StringStringPair,org.apache.hadoop.io.IntWritable>
Aggregates all values of a key and counts
the appearances of the key.
Input
- Key: pair of subject- and object-identifier
- Value: number of appearances of the key
Output
- Key: pair of subject- and object-identifier
- Value: number of appearances of the key
- 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.Reducer |
org.apache.hadoop.mapreduce.Reducer.Context |
Method Summary |
void |
reduce(StringStringPair key,
java.lang.Iterable<org.apache.hadoop.io.IntWritable> values,
org.apache.hadoop.mapreduce.Reducer.Context context)
|
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 |
LinkSetsReducer
public LinkSetsReducer()
reduce
public void reduce(StringStringPair key,
java.lang.Iterable<org.apache.hadoop.io.IntWritable> values,
org.apache.hadoop.mapreduce.Reducer.Context context)
throws java.io.IOException,
java.lang.InterruptedException
- Overrides:
reduce
in class org.apache.hadoop.mapreduce.Reducer<StringStringPair,org.apache.hadoop.io.IntWritable,StringStringPair,org.apache.hadoop.io.IntWritable>
- Throws:
java.io.IOException
java.lang.InterruptedException