pegasus.mapreduce.cc

Class PASmallStarOpt.PASmallStarReducer

java.lang.Object

org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable>

pegasus.mapreduce.cc.PASmallStarOpt.PASmallStarReducer

Enclosing class:

PASmallStarOpt

public static class PASmallStarOpt.PASmallStarReducer
extends org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable>

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

Method Summary

Modifier and Type	Method and Description
protected void	cleanup(org.apache.hadoop.mapreduce.Reducer.Context context) cleanup after execution.
protected void	reduce(org.apache.hadoop.io.LongWritable key, java.lang.Iterable<org.apache.hadoop.io.LongWritable> values, org.apache.hadoop.mapreduce.Reducer.Context context) the reudce function of PASmallStarOpt
protected void	setup(org.apache.hadoop.mapreduce.Reducer.Context context) setup before execution

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

PASmallStarReducer

public PASmallStarReducer()

Method Detail

cleanup

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

cleanup after execution. It closes the output stream.

Overrides:

cleanup in class org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable,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

setup

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

setup before execution

Overrides:

setup in class org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable,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

reduce

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

the reudce function of PASmallStarOpt

Overrides:

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

Parameters:

key - source node

values - destination nodes

context - of hadoop

Throws:

java.io.IOException - by hadoop

java.lang.InterruptedException - by hadoop