pegasus.mapreduce.triangle

Class PTE.TriangleListingMapper

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.triangle.PTE.TriangleCountingMapper

pegasus.mapreduce.triangle.PTE.TriangleListingMapper

Enclosing class:

PTE

public static class PTE.TriangleListingMapper
extends PTE.TriangleCountingMapper

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

Method Summary

Modifier and Type	Method and Description
protected long	enumTri(int[][] ij, int[][] ik, int[][] jk, int i, int j, int k) Listing triangles.
protected void	setup(org.apache.hadoop.mapreduce.Mapper.Context context) setup before execution.

Methods inherited from class pegasus.mapreduce.triangle.PTE.TriangleCountingMapper

availableMemoryBytes, map

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

TriangleListingMapper

public TriangleListingMapper()

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 PTE.TriangleCountingMapper

Parameters:

context - of hadoop

Throws:

java.io.IOException - by hadoop

java.lang.InterruptedException - by hadoop

enumTri

protected long enumTri(int[][] ij,
                       int[][] ik,
                       int[][] jk,
                       int i,
                       int j,
                       int k)
                throws java.io.IOException,
                       java.lang.InterruptedException

Listing triangles. It finds all triangles (u, v, w) that the colors of the vertices u, v, and w are i, j, and k, respectively.

Overrides:

enumTri in class PTE.TriangleCountingMapper

Parameters:

ij - adjacency list of an edge set

ik - adjacency list of an edge set

jk - adjacency list of an edge set

i - the first node color

j - the second node color

k - the last node color

Returns:

the number of triangles of colors i, j, and k.

Throws:

java.io.IOException - by hadoop

java.lang.InterruptedException - by hadoop