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

Class ReduceAnnotatedDGraph

java.lang.Object

org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.io.NullWritable,HadoopAnnotatedDGraph,org.apache.hadoop.io.NullWritable,HadoopAnnotatedDGraph>

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

public class ReduceAnnotatedDGraph
extends org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.io.NullWritable,HadoopAnnotatedDGraph,org.apache.hadoop.io.NullWritable,HadoopAnnotatedDGraph>

Reduce annotated dependency graph class for Hadoop. The application takes several annotated dependency graphs and "reduce" them into a single one by adding up the matrix values. It uses the 'read' method of the AnnotatedDGraph class to read and combine the input graphs. It uses the 'write' method of the of the AnnotatedDGraph class to write the result.

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

Method Summary

Methods

Modifier and Type	Method and Description
void	cleanup(org.apache.hadoop.mapreduce.Reducer.Context context)
void	reduce(org.apache.hadoop.io.NullWritable key, java.lang.Iterable<HadoopAnnotatedDGraph> values, org.apache.hadoop.mapreduce.Reducer.Context context) INPUT Text = Null Value = Hadoop Graphs OUTPUT Key = Null Value = Hadoop Annotated 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

ReduceAnnotatedDGraph

public ReduceAnnotatedDGraph()

Method Detail

reduce

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

INPUT Text = Null Value = Hadoop Graphs OUTPUT Key = Null Value = Hadoop Annotated Dependency Graph

Overrides:

reduce in class org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.io.NullWritable,HadoopAnnotatedDGraph,org.apache.hadoop.io.NullWritable,HadoopAnnotatedDGraph>

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.NullWritable,HadoopAnnotatedDGraph,org.apache.hadoop.io.NullWritable,HadoopAnnotatedDGraph>

cleanup

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

Overrides:

cleanup in class org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.io.NullWritable,HadoopAnnotatedDGraph,org.apache.hadoop.io.NullWritable,HadoopAnnotatedDGraph>