de.hpi.fgis.voidgen.hadoop.tasks.joining
Class ClusterInputMapper
java.lang.Object
org.apache.hadoop.mapred.MapReduceBase
de.hpi.fgis.voidgen.hadoop.tasks.joining.ClusterInputMapper
- All Implemented Interfaces:
- java.io.Closeable, org.apache.hadoop.mapred.JobConfigurable, org.apache.hadoop.mapred.Mapper<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,StringIntPair,RDFQuadruple>
public class ClusterInputMapper
- extends org.apache.hadoop.mapred.MapReduceBase
- implements org.apache.hadoop.mapred.Mapper<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,StringIntPair,RDFQuadruple>
Swapping key and value of the clustering output
and adapt the format to further steps.
Input
- Key: textual representation of the cluster identifier
- Value: textual representation of a vertex
Output
- Key: a pair of
node of a cluster and
an integer describing the type of the value
('0' for RDFQuadruple where only the subject cluster is set.)
- Value: An RDFQuadruple where only the subject cluster is set.
- 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
Method Summary |
void |
map(org.apache.hadoop.io.Text key,
org.apache.hadoop.io.Text value,
org.apache.hadoop.mapred.OutputCollector<StringIntPair,RDFQuadruple> output,
org.apache.hadoop.mapred.Reporter reporter)
|
Methods inherited from class org.apache.hadoop.mapred.MapReduceBase |
close, configure |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.apache.hadoop.mapred.JobConfigurable |
configure |
Methods inherited from interface java.io.Closeable |
close |
ClusterInputMapper
public ClusterInputMapper()
map
public void map(org.apache.hadoop.io.Text key,
org.apache.hadoop.io.Text value,
org.apache.hadoop.mapred.OutputCollector<StringIntPair,RDFQuadruple> output,
org.apache.hadoop.mapred.Reporter reporter)
throws java.io.IOException
- Specified by:
map
in interface org.apache.hadoop.mapred.Mapper<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,StringIntPair,RDFQuadruple>
- Throws:
java.io.IOException