org.processmining.BigData.common.GraphManagement.reduce.Hadoop

Class ReduceDGraph

java.lang.Object

org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.io.Text,HadoopGraph,org.apache.hadoop.io.NullWritable,HadoopDGraph>

org.processmining.BigData.common.GraphManagement.reduce.Hadoop.ReduceDGraph

public class ReduceDGraph
extends org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.io.Text,HadoopGraph,org.apache.hadoop.io.NullWritable,HadoopDGraph>

Reduce dependency graph class for Hadoop. The application takes several graphs (DFG, L2L and LD) and "reduce" them into a single one by adding up the matrix values. It uses the 'read' method of the Graph class to read and combine the input graphs. It uses the 'write' method of the of the Graph class to write the result. When the DFG, L2L and LD are reduced, it creates a Dependency Graph using the information in these matrix.

Author:

shernandez

Nested Class Summary

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

org.apache.hadoop.mapreduce.Reducer.Context

Constructor Summary

Constructors

Constructor and Description
ReduceDGraph()

Method Summary

Methods

Modifier and Type	Method and Description
void	cleanup(org.apache.hadoop.mapreduce.Reducer.Context context)
void	reduce(org.apache.hadoop.io.Text key, java.lang.Iterable<HadoopGraph> values, org.apache.hadoop.mapreduce.Reducer.Context context) INPUT Text = Graph key (DFG, L2L, LD) Value = Hadoop Graphs OUTPUT Key = Null Value = Hadoop Dependency Graph
void	setup(org.apache.hadoop.mapreduce.Reducer.Context context)

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

run

Methods inherited from class java.lang.Object

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

Constructor Detail

ReduceDGraph

public ReduceDGraph()

Method Detail

reduce

public void reduce(org.apache.hadoop.io.Text key,
          java.lang.Iterable<HadoopGraph> values,
          org.apache.hadoop.mapreduce.Reducer.Context context)
            throws java.io.IOException,
                   java.lang.InterruptedException

INPUT Text = Graph key (DFG, L2L, LD) Value = Hadoop Graphs OUTPUT Key = Null Value = Hadoop Dependency Graph

Overrides:

reduce in class org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.io.Text,HadoopGraph,org.apache.hadoop.io.NullWritable,HadoopDGraph>

Throws:

java.io.IOException

java.lang.InterruptedException

setup

public void setup(org.apache.hadoop.mapreduce.Reducer.Context context)

Overrides:

setup in class org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.io.Text,HadoopGraph,org.apache.hadoop.io.NullWritable,HadoopDGraph>

cleanup

public void cleanup(org.apache.hadoop.mapreduce.Reducer.Context context)

Overrides:

cleanup in class org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.io.Text,HadoopGraph,org.apache.hadoop.io.NullWritable,HadoopDGraph>