de.hpi.fgis.voidgen.hadoop.tasks.clusterinformation
Class ClusterInfoPatternStep1MapperTask2
java.lang.Object
org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text,StringIntPair,org.apache.hadoop.io.Text>
de.hpi.fgis.voidgen.hadoop.tasks.clusterinformation.ClusterInfoPatternStep1MapperTask2
public class ClusterInfoPatternStep1MapperTask2
- extends org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text,StringIntPair,org.apache.hadoop.io.Text>
For every input quadruple where subject and object are URLs
the subject and object URLs are processed.
For each part of each URL (separated by '/' or ':')
a key-value pair is emitted.
Input
- Key: ignored
- Value: Text describing an RDF quadruple
Output
- Key: a pair of URL host or schema and the position of the current URL part within the complete URL
- Value: the current URL part
- 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(org.apache.hadoop.io.LongWritable key,
org.apache.hadoop.io.Text 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 |
ClusterInfoPatternStep1MapperTask2
public ClusterInfoPatternStep1MapperTask2()
map
public void map(org.apache.hadoop.io.LongWritable key,
org.apache.hadoop.io.Text value,
org.apache.hadoop.mapreduce.Mapper.Context context)
throws java.io.IOException,
java.lang.InterruptedException
- Overrides:
map
in class org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text,StringIntPair,org.apache.hadoop.io.Text>
- Throws:
java.io.IOException
java.lang.InterruptedException