pegasus.mapreduce.subgraph

Class PSE.SubgraphEnumerationMapper

java.lang.Object

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

pegasus.mapreduce.subgraph.PSE.SubgraphEnumerationMapper

Enclosing class:

PSE

public static class PSE.SubgraphEnumerationMapper
extends org.apache.hadoop.mapreduce.Mapper<java.lang.Object,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.NullWritable>

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

Method Summary

Modifier and Type	Method and Description
static long	availableMemoryBytes(boolean gc)
protected void	map(java.lang.Object key, org.apache.hadoop.io.Text value, org.apache.hadoop.mapreduce.Mapper.Context context) The map function of PSE
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

SubgraphEnumerationMapper

public SubgraphEnumerationMapper()

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<java.lang.Object,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.NullWritable>

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 PSE

Overrides:

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

Parameters:

key - meaning less

value - problem

context - of hadoop

Throws:

java.io.IOException - by hadoop

java.lang.InterruptedException - by hadoop

availableMemoryBytes

public static long availableMemoryBytes(boolean gc)