pegasus.mapreduce.cc

Class PALargeStarOpt.ColorLargeStarReducer

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.PALargeStarOpt.ColorLargeStarReducer

Enclosing class:

PALargeStarOpt

public static class PALargeStarOpt.ColorLargeStarReducer
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
ColorLargeStarReducer()

Method Summary

Modifier and Type	Method and Description
protected void	cleanup(org.apache.hadoop.mapreduce.Reducer.Context context)
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 reduce function of PALargeStarOpt
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

ColorLargeStarReducer

public ColorLargeStarReducer()

Method Detail

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 -

Throws:

java.io.IOException

java.lang.InterruptedException

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 reduce function of PALargeStarOpt

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

cleanup

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

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>

Throws:

java.io.IOException

java.lang.InterruptedException