de.hpi.fgis.voidgen.hadoop.tasks.clustering1
Class Task2ClusteringReducer
java.lang.Object
org.apache.hadoop.mapreduce.Reducer<StringStringPair,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
de.hpi.fgis.voidgen.hadoop.tasks.clustering1.Task2ClusteringReducer
public class Task2ClusteringReducer
- extends org.apache.hadoop.mapreduce.Reducer<StringStringPair,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
Aggregates over all keys and outputs each unique key once.
Input
- Key: a pair of
cluster identifier and
subject or object of an RDF quadruple
- Value: ignored
Output
- Key: textual representation of a cluster
- Value: textual representation of a subject or object
- 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.NullWritable> 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 |
Task2ClusteringReducer
public Task2ClusteringReducer()
reduce
public void reduce(StringStringPair key,
java.lang.Iterable<org.apache.hadoop.io.NullWritable> 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.NullWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
- Throws:
java.io.IOException
java.lang.InterruptedException