pegasus.mapreduce.common.prepartitioning

Class GraphPrepartitioningReducer<IV,OV>

java.lang.Object

org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.io.LongWritable,IV,org.apache.hadoop.io.IntWritable,OV>

pegasus.mapreduce.common.prepartitioning.GraphPrepartitioningReducer<IV,OV>

Direct Known Subclasses:

UnweightedGraphPrepartitioning.PrepartitioningReducer, WeightedGraphPrepartitioning.PrepartitioningReducer

public class GraphPrepartitioningReducer<IV,OV>
extends org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.io.LongWritable,IV,org.apache.hadoop.io.IntWritable,OV>

Nested Class Summary

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

org.apache.hadoop.mapreduce.Reducer.Context

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.NullWritable>	dvWriter
protected long	maxVertex
protected int	numBlocks
protected int[]	numDenseCols
protected int[]	numDenseRows
protected int[]	numSparseCols
protected int[]	numSparseRows
protected org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.NullWritable>	svWriter

Constructor Summary

Constructors

Constructor and Description
GraphPrepartitioningReducer()

Method Summary

Modifier and Type	Method and Description
protected void	cleanup(org.apache.hadoop.mapreduce.Reducer.Context context)
protected void	setup(org.apache.hadoop.mapreduce.Reducer.Context context)

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

reduce, run

Methods inherited from class java.lang.Object

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

Field Detail

maxVertex

protected long maxVertex

numBlocks

protected int numBlocks

numSparseCols

protected int[] numSparseCols

numSparseRows

protected int[] numSparseRows

numDenseCols

protected int[] numDenseCols

numDenseRows

protected int[] numDenseRows

svWriter

protected org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.NullWritable> svWriter

dvWriter

protected org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.NullWritable> dvWriter

Constructor Detail

GraphPrepartitioningReducer

public GraphPrepartitioningReducer()

Method Detail

setup

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

Overrides:

setup in class org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.io.LongWritable,IV,org.apache.hadoop.io.IntWritable,OV>

Throws:

java.io.IOException

java.lang.InterruptedException

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,IV,org.apache.hadoop.io.IntWritable,OV>

Throws:

java.io.IOException

java.lang.InterruptedException