de.hpi.fgis.voidgen.hadoop.tasks.clustering2
Class FilterClusterOutputMapper
java.lang.Object
org.apache.hadoop.mapreduce.Mapper<ClusterId,NodeXOrId,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
de.hpi.fgis.voidgen.hadoop.tasks.clustering2.FilterClusterOutputMapper
public class FilterClusterOutputMapper
- extends org.apache.hadoop.mapreduce.Mapper<ClusterId,NodeXOrId,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
Reads the output of the transitive closure
job and emits all pairs
of cluster identifier and vertex
ignoring pairs of two cluster identifier.
Input
- Key: cluster identifier
- Value: either the textual representation of a vertex
or an other cluster identifier
Output
- Key: textual representation of the cluster identifier
- Value: textual representation of a vertex
- 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.Mapper |
org.apache.hadoop.mapreduce.Mapper.Context |
Method Summary |
void |
map(ClusterId key,
NodeXOrId 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 |
FilterClusterOutputMapper
public FilterClusterOutputMapper()
map
public void map(ClusterId key,
NodeXOrId value,
org.apache.hadoop.mapreduce.Mapper.Context context)
throws java.io.IOException,
java.lang.InterruptedException
- Overrides:
map
in class org.apache.hadoop.mapreduce.Mapper<ClusterId,NodeXOrId,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
- Throws:
java.io.IOException
java.lang.InterruptedException