pegasus.mapreduce.subgraph

Class PrePartition.PGMapper

java.lang.Object

org.apache.hadoop.mapreduce.Mapper<java.lang.Object,org.apache.hadoop.io.Text,org.apache.hadoop.io.ShortWritable,org.apache.hadoop.io.LongWritable>

pegasus.mapreduce.subgraph.PrePartition.PGMapper

Enclosing class:

PrePartition

public static class PrePartition.PGMapper
extends org.apache.hadoop.mapreduce.Mapper<java.lang.Object,org.apache.hadoop.io.Text,org.apache.hadoop.io.ShortWritable,org.apache.hadoop.io.LongWritable>

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
PGMapper()

Method Summary

Modifier and Type	Method and Description
protected void	cleanup(org.apache.hadoop.mapreduce.Mapper.Context context) Cleanup after execution.
protected void	map(java.lang.Object key, org.apache.hadoop.io.Text value, org.apache.hadoop.mapreduce.Mapper.Context context) The map function of pre-partitioning
protected void	setup(org.apache.hadoop.mapreduce.Mapper.Context context) setup before execution.

Methods inherited from class org.apache.hadoop.mapreduce.Mapper

run

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PGMapper

public PGMapper()

Method Detail

setup

protected void setup(org.apache.hadoop.mapreduce.Mapper.Context context)
              throws java.io.IOException,
                     java.lang.InterruptedException

setup before execution. set the number of colors.

Overrides:

setup in class org.apache.hadoop.mapreduce.Mapper<java.lang.Object,org.apache.hadoop.io.Text,org.apache.hadoop.io.ShortWritable,org.apache.hadoop.io.LongWritable>

Parameters:

context - of hadoop

Throws:

java.io.IOException - by hadoop

java.lang.InterruptedException - by hadoop

map

protected void map(java.lang.Object key,
                   org.apache.hadoop.io.Text value,
                   org.apache.hadoop.mapreduce.Mapper.Context context)
            throws java.io.IOException,
                   java.lang.InterruptedException

The map function of pre-partitioning

Overrides:

map in class org.apache.hadoop.mapreduce.Mapper<java.lang.Object,org.apache.hadoop.io.Text,org.apache.hadoop.io.ShortWritable,org.apache.hadoop.io.LongWritable>

Parameters:

key - not used

value - an edge as a text

context - of hadoop

Throws:

java.io.IOException - by hadoop

java.lang.InterruptedException - by hadoop

cleanup

protected void cleanup(org.apache.hadoop.mapreduce.Mapper.Context context)
                throws java.io.IOException,
                       java.lang.InterruptedException

Cleanup after execution. To find the global maximum vertex id, it outputs maximum vertex id in each partition.

Overrides:

cleanup in class org.apache.hadoop.mapreduce.Mapper<java.lang.Object,org.apache.hadoop.io.Text,org.apache.hadoop.io.ShortWritable,org.apache.hadoop.io.LongWritable>

Parameters:

context - of hadoop

Throws:

java.io.IOException - by hadoop

java.lang.InterruptedException - by hadoop