de.hpi.fgis.voidgen.hadoop.closure
Class Step1MapperBase<KEYIN,VALUEIN>

java.lang.Object
  extended by org.apache.hadoop.mapreduce.Mapper<KEYIN,VALUEIN,Step1Pair,ClusterId>
      extended by de.hpi.fgis.voidgen.hadoop.closure.Step1MapperBase<KEYIN,VALUEIN>
Type Parameters:
KEYIN - the input key class
VALUEIN - the input value class
Direct Known Subclasses:
ClosureStep1RDFInputMapper, Step1Mapper

public class Step1MapperBase<KEYIN,VALUEIN>
extends org.apache.hadoop.mapreduce.Mapper<KEYIN,VALUEIN,Step1Pair,ClusterId>

The Mapper for processing the input and creating the necessary key-value pairs for the next steps of transitive closure creation.

Input

Output

Author:
Johannes Gosda, Hasso Plattner Institute at University of Potsdam, Germany

Nested Class Summary
 
Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.Mapper
org.apache.hadoop.mapreduce.Mapper.Context
 
Constructor Summary
Step1MapperBase()
           
 
Method Summary
protected  ClusterId newClusterId(org.apache.hadoop.mapreduce.Mapper.Context context)
          Returns a new cluster identifier.
 
Methods inherited from class org.apache.hadoop.mapreduce.Mapper
cleanup, map, run, setup
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

Step1MapperBase

public Step1MapperBase()
Method Detail

newClusterId

protected ClusterId newClusterId(org.apache.hadoop.mapreduce.Mapper.Context context)
Returns a new cluster identifier. The cluster identifier is composed by the current task attempt and an internal ID generated within the instance of this class.

Parameters:
context - The context of the current task.
Returns:
A new unique cluster identifier.