pegasus.mapreduce.diameter

Class DiameterComputation.DiameterMapper

java.lang.Object

org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.LongWritable,OV>

pegasus.mapreduce.common.computation.ComputationMapper<IntArrayWritable,BitStrings,BitStrings,IntDoublePairWritable>

pegasus.mapreduce.diameter.DiameterComputation.DiameterMapper

Enclosing class:

DiameterComputation

public static class DiameterComputation.DiameterMapper
extends ComputationMapper<IntArrayWritable,BitStrings,BitStrings,IntDoublePairWritable>

Nested Class Summary

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

org.apache.hadoop.mapreduce.Mapper.Context

Constructor Summary

Constructors

Constructor and Description
DiameterMapper()

Method Summary

Modifier and Type	Method and Description
protected void	applyOp(int vecBlockId, VectorCache<BitStrings> vecResult, VectorCache<BitStrings> vecIntermediate)
protected void	combine2Op(int matBlockId, MatrixCache<IntArrayWritable> matrix, VectorCache<BitStrings> vecInput, VectorCache<BitStrings> vecOutput)
protected void	combineAllOp(int matBlockId, org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.IntWritable,BitStrings> vecInput, VectorCache<BitStrings> vecOutput)
protected VectorCache<BitStrings>	createIntermediateVectorCache(int numBlocks, long numVertices)
protected MatrixCache<IntArrayWritable>	createMatrixCache(java.lang.String blockName, org.apache.hadoop.conf.Configuration conf, int numCols, int numRows)
protected VectorCache<BitStrings>	createVectorCache(int numBlocks, int blockId, long numVertices)
protected IntDoublePairWritable	finalizeOp(int id, BitStrings vec)
protected java.lang.Class<BitStrings>	intermediateVectorValueClass()
protected java.lang.Class<IntArrayWritable>	matrixValueClass()
protected java.lang.Class<BitStrings>	vectorValueClass()
protected void	writeOutputVecOp(int vecBlockId, VectorCache<BitStrings> vector)

Methods inherited from class pegasus.mapreduce.common.computation.ComputationMapper

cleanupComputation, computationContext, currentIteration, currentVector, maxIterations, notifyChanged, numBlocks, numVertices, reportStats, run, setEstimatedSize, setupComputation, statusMessage, writeIntermediateVecOp

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

cleanup, map, setup

Methods inherited from class java.lang.Object

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

Constructor Detail

DiameterMapper

public DiameterMapper()

Method Detail

createVectorCache

protected VectorCache<BitStrings> createVectorCache(int numBlocks,
                                                    int blockId,
                                                    long numVertices)

Specified by:

createVectorCache in class ComputationMapper<IntArrayWritable,BitStrings,BitStrings,IntDoublePairWritable>

createIntermediateVectorCache

protected VectorCache<BitStrings> createIntermediateVectorCache(int numBlocks,
                                                                long numVertices)

Specified by:

createIntermediateVectorCache in class ComputationMapper<IntArrayWritable,BitStrings,BitStrings,IntDoublePairWritable>

createMatrixCache

protected MatrixCache<IntArrayWritable> createMatrixCache(java.lang.String blockName,
                                                          org.apache.hadoop.conf.Configuration conf,
                                                          int numCols,
                                                          int numRows)
                                                   throws java.io.IOException

Specified by:

createMatrixCache in class ComputationMapper<IntArrayWritable,BitStrings,BitStrings,IntDoublePairWritable>

Throws:

java.io.IOException

vectorValueClass

protected java.lang.Class<BitStrings> vectorValueClass()

Specified by:

vectorValueClass in class ComputationMapper<IntArrayWritable,BitStrings,BitStrings,IntDoublePairWritable>

intermediateVectorValueClass

protected java.lang.Class<BitStrings> intermediateVectorValueClass()

Specified by:

intermediateVectorValueClass in class ComputationMapper<IntArrayWritable,BitStrings,BitStrings,IntDoublePairWritable>

matrixValueClass

protected java.lang.Class<IntArrayWritable> matrixValueClass()

Specified by:

matrixValueClass in class ComputationMapper<IntArrayWritable,BitStrings,BitStrings,IntDoublePairWritable>

combine2Op

protected void combine2Op(int matBlockId,
                          MatrixCache<IntArrayWritable> matrix,
                          VectorCache<BitStrings> vecInput,
                          VectorCache<BitStrings> vecOutput)
                   throws java.lang.Exception

Overrides:

combine2Op in class ComputationMapper<IntArrayWritable,BitStrings,BitStrings,IntDoublePairWritable>

Throws:

java.lang.Exception

combineAllOp

protected void combineAllOp(int matBlockId,
                            org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.IntWritable,BitStrings> vecInput,
                            VectorCache<BitStrings> vecOutput)
                     throws java.lang.Exception

Overrides:

combineAllOp in class ComputationMapper<IntArrayWritable,BitStrings,BitStrings,IntDoublePairWritable>

Throws:

java.lang.Exception

applyOp

protected void applyOp(int vecBlockId,
                       VectorCache<BitStrings> vecResult,
                       VectorCache<BitStrings> vecIntermediate)
                throws java.lang.Exception

Overrides:

applyOp in class ComputationMapper<IntArrayWritable,BitStrings,BitStrings,IntDoublePairWritable>

Throws:

java.lang.Exception

finalizeOp

protected IntDoublePairWritable finalizeOp(int id,
                                           BitStrings vec)
                                    throws java.lang.Exception

Overrides:

finalizeOp in class ComputationMapper<IntArrayWritable,BitStrings,BitStrings,IntDoublePairWritable>

Throws:

java.lang.Exception

writeOutputVecOp

protected void writeOutputVecOp(int vecBlockId,
                                VectorCache<BitStrings> vector)
                         throws java.lang.Exception

Overrides:

writeOutputVecOp in class ComputationMapper<IntArrayWritable,BitStrings,BitStrings,IntDoublePairWritable>

Throws:

java.lang.Exception