org.apache.giraph.aggregators.matrix.dense

Class LongDenseMatrixSumAggregator

java.lang.Object

org.apache.giraph.aggregators.matrix.MatrixSumAggregator

org.apache.giraph.aggregators.matrix.dense.LongDenseMatrixSumAggregator

public class LongDenseMatrixSumAggregator
extends MatrixSumAggregator

The long dense matrix aggregator is used to register and aggregate long dense matrices.

Constructor Summary

Constructors

Constructor and Description
LongDenseMatrixSumAggregator(String name) Create a new matrix aggregator with the given prefix name for the vector aggregators.

Method Summary

Modifier and Type	Method and Description
void	aggregate(int i, int j, long v, WorkerAggregatorUsage worker) Add the given value to the entry specified.
LongDenseMatrix	getMatrix(int numRows, AggregatorUsage aggUser) Read the aggregated values of the matrix.
void	register(int numRows, MasterAggregatorUsage master) Register the long vector aggregators, one for each row of the matrix.
void	setMatrix(LongDenseMatrix matrix, MasterAggregatorUsage master) Set the values of the matrix to the master specified.

Methods inherited from class org.apache.giraph.aggregators.matrix.MatrixSumAggregator

getRowAggregatorName

Methods inherited from class java.lang.Object

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

Constructor Detail

LongDenseMatrixSumAggregator

public LongDenseMatrixSumAggregator(String name)

Create a new matrix aggregator with the given prefix name for the vector aggregators.

Parameters:

name - the prefix for the row vector aggregators

Method Detail

register

public void register(int numRows,
                     MasterAggregatorUsage master)
              throws InstantiationException,
                     IllegalAccessException

Register the long vector aggregators, one for each row of the matrix.

Parameters:

numRows - the number of rows

master - the master to register the aggregators

Throws:

InstantiationException

IllegalAccessException

aggregate

public void aggregate(int i,
                      int j,
                      long v,
                      WorkerAggregatorUsage worker)

Add the given value to the entry specified.

Parameters:

i - the row

j - the column

v - the value

worker - the worker to aggregate

setMatrix

public void setMatrix(LongDenseMatrix matrix,
                      MasterAggregatorUsage master)

Set the values of the matrix to the master specified. This is typically used in the master, to build an external LongMatrix and only set it at the end.

Parameters:

matrix - the matrix to set the values

master - the master

getMatrix

public LongDenseMatrix getMatrix(int numRows,
                                 AggregatorUsage aggUser)

Read the aggregated values of the matrix.

Parameters:

numRows - the number of rows

aggUser - the master or worker

Returns:

the long matrix