pegasus.mapreduce.graphgen

Class RandomGenerator.RandomGeneratorMapper

java.lang.Object

org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.IntWritable,pegasus.mapreduce.graphgen.RandomGenerator.RegionSlot,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable>

pegasus.mapreduce.graphgen.RandomGenerator.RandomGeneratorMapper

Enclosing class:

RandomGenerator

public static class RandomGenerator.RandomGeneratorMapper
extends org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.IntWritable,pegasus.mapreduce.graphgen.RandomGenerator.RegionSlot,org.apache.hadoop.io.LongWritable,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
RandomGeneratorMapper()

Method Summary

Modifier and Type	Method and Description
protected void	map(org.apache.hadoop.io.IntWritable key, pegasus.mapreduce.graphgen.RandomGenerator.RegionSlot rs, org.apache.hadoop.mapreduce.Mapper.Context context) The map function of the random graph generator.
protected void	setup(org.apache.hadoop.mapreduce.Mapper.Context context) Setup before execution

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

RandomGeneratorMapper

public RandomGeneratorMapper()

Method Detail

setup

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

Setup before execution

Overrides:

setup in class org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.IntWritable,pegasus.mapreduce.graphgen.RandomGenerator.RegionSlot,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable>

Parameters:

context - of hadoop

Throws:

java.io.IOException - by hadoop

java.lang.InterruptedException - by hadoop

map

protected void map(org.apache.hadoop.io.IntWritable key,
                   pegasus.mapreduce.graphgen.RandomGenerator.RegionSlot rs,
                   org.apache.hadoop.mapreduce.Mapper.Context context)
            throws java.io.IOException,
                   java.lang.InterruptedException

The map function of the random graph generator.

Overrides:

map in class org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.IntWritable,pegasus.mapreduce.graphgen.RandomGenerator.RegionSlot,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable>

Parameters:

key - task id.

rs - a region slot that contains regions to process here.

context - of hadoop

Throws:

java.io.IOException - by hadoop

java.lang.InterruptedException - by hadoop