de.hpi.fgis.voidgen.hadoop.tasks.clustering2
Class ClosureStep1RDFInputMapper
java.lang.Object
org.apache.hadoop.mapreduce.Mapper<KEYIN,VALUEIN,Step1Pair,ClusterId>
de.hpi.fgis.voidgen.hadoop.closure.Step1MapperBase<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text>
de.hpi.fgis.voidgen.hadoop.tasks.clustering2.ClosureStep1RDFInputMapper
public class ClosureStep1RDFInputMapper
- extends Step1MapperBase<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text>
The Mapper for the first step of the transitive
closure generation. This Mapper uses input files
that contain one RDF quadruple per input line.
Notice: if an input tuple will not be accepted
by the filter, the nodes within that tuple
will also not appear as clusters after transitive
closure generation.
Input
- Key: line number
- Value: an RDF quadruple
Output see Step1MapperBase
- 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)
|
protected void |
setup(org.apache.hadoop.mapreduce.Mapper.Context context)
|
Methods inherited from class org.apache.hadoop.mapreduce.Mapper |
cleanup, run |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ClosureStep1RDFInputMapper
public ClosureStep1RDFInputMapper()
setup
protected void setup(org.apache.hadoop.mapreduce.Mapper.Context context)
throws java.io.IOException,
java.lang.InterruptedException
- Overrides:
setup
in class org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text,Step1Pair,ClusterId>
- Throws:
java.io.IOException
java.lang.InterruptedException
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,Step1Pair,ClusterId>
- Throws:
java.io.IOException
java.lang.InterruptedException