pegasus.mapreduce.triangle

Class EdgeOrder.EOStep2Mapper

java.lang.Object

org.apache.hadoop.mapreduce.Mapper<LongPairWritable,org.apache.hadoop.io.IntWritable,LongPairWritable,org.apache.hadoop.io.IntWritable>

pegasus.mapreduce.triangle.EdgeOrder.EOStep2Mapper

Enclosing class:

EdgeOrder

public static class EdgeOrder.EOStep2Mapper
extends org.apache.hadoop.mapreduce.Mapper<LongPairWritable,org.apache.hadoop.io.IntWritable,LongPairWritable,org.apache.hadoop.io.IntWritable>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.Mapper

org.apache.hadoop.mapreduce.Mapper.Context

Constructor Summary

Constructors

Constructor and Description
EOStep2Mapper()

Method Summary

Modifier and Type	Method and Description
protected void	map(LongPairWritable pair, org.apache.hadoop.io.IntWritable uDeg, org.apache.hadoop.mapreduce.Mapper.Context context) The map function of the second step

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

Constructor Detail

EOStep2Mapper

public EOStep2Mapper()

Method Detail

map

protected void map(LongPairWritable pair,
                   org.apache.hadoop.io.IntWritable uDeg,
                   org.apache.hadoop.mapreduce.Mapper.Context context)
            throws java.io.IOException,
                   java.lang.InterruptedException

The map function of the second step

Overrides:

map in class org.apache.hadoop.mapreduce.Mapper<LongPairWritable,org.apache.hadoop.io.IntWritable,LongPairWritable,org.apache.hadoop.io.IntWritable>

Parameters:

pair - an edge. The high 32 bits are of a source vertex and thelow 32 bits are of a destination vertex.

uDeg - The degree of the source vertex

context - of hadoop

Throws:

java.io.IOException - by hadoop

java.lang.InterruptedException - by hadoop