pegasus.mapreduce.cc

Class PALargeStarOpt.ColorLargeStarCombiner

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.ColorLargeStarCombiner

Enclosing class:

PALargeStarOpt

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

Method Summary

Modifier and Type	Method and Description
protected void	reduce(org.apache.hadoop.io.LongWritable _u, java.lang.Iterable<org.apache.hadoop.io.LongWritable> values, org.apache.hadoop.mapreduce.Reducer.Context context) the combiner 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

cleanup, run

Methods inherited from class java.lang.Object

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

Constructor Detail

ColorLargeStarCombiner

public ColorLargeStarCombiner()

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 - of hadoop

Throws:

java.io.IOException - by hadoop

java.lang.InterruptedException - by hadoop

reduce

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

the combiner 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:

_u - source node

values - destination nodes

context - of hadoop

Throws:

java.io.IOException - by hadoop

java.lang.InterruptedException - by hadoop