de.hpi.fgis.voidgen.hadoop.tasks.ksimilarity
Class KSimStep2Mapper

java.lang.Object
  extended by org.apache.hadoop.mapreduce.Mapper<StringStringPair,StringStringPair,StringArrayWritableComparable,org.apache.hadoop.io.IntWritable>
      extended by de.hpi.fgis.voidgen.hadoop.tasks.ksimilarity.KSimStep2Mapper

public class KSimStep2Mapper
extends org.apache.hadoop.mapreduce.Mapper<StringStringPair,StringStringPair,StringArrayWritableComparable,org.apache.hadoop.io.IntWritable>

Aggregates via map-side join all subjects sharing the same predicate-object pair. Emits each connected pair of subjects (cross product of the subjects sharing the same predicate-object pair) The map input data is prepared as necessary for a map-side join.

Input

Output

Author:
Eyk Kny, Hasso Plattner Institute at University of Potsdam, Germany, 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
KSimStep2Mapper()
           
 
Method Summary
protected  void map(StringStringPair key, StringStringPair value, org.apache.hadoop.mapreduce.Mapper.Context context)
           
 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
 

Constructor Detail

KSimStep2Mapper

public KSimStep2Mapper()
Method Detail

setup

public void setup(org.apache.hadoop.mapreduce.Mapper.Context context)
Overrides:
setup in class org.apache.hadoop.mapreduce.Mapper<StringStringPair,StringStringPair,StringArrayWritableComparable,org.apache.hadoop.io.IntWritable>

map

protected void map(StringStringPair key,
                   StringStringPair value,
                   org.apache.hadoop.mapreduce.Mapper.Context context)
            throws java.io.IOException,
                   java.lang.InterruptedException
Overrides:
map in class org.apache.hadoop.mapreduce.Mapper<StringStringPair,StringStringPair,StringArrayWritableComparable,org.apache.hadoop.io.IntWritable>
Throws:
java.io.IOException
java.lang.InterruptedException