org.apache.giraph.aggregators.matrix.dense

Class IntDenseMatrixSumAggregator

java.lang.Object

org.apache.giraph.aggregators.matrix.MatrixSumAggregator

org.apache.giraph.aggregators.matrix.dense.IntDenseMatrixSumAggregator

public class IntDenseMatrixSumAggregator
extends MatrixSumAggregator

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

Constructor Summary

Constructors

Constructor and Description
IntDenseMatrixSumAggregator(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, int v, WorkerAggregatorUsage worker) Add the given value to the entry specified.
IntDenseMatrix	getMatrix(int numRows, AggregatorUsage aggUser) Read the aggregated values of the matrix.
void	register(int numRows, MasterAggregatorUsage master) Register the int vector aggregators, one for each row of the matrix.
void	setMatrix(IntDenseMatrix 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

IntDenseMatrixSumAggregator

public IntDenseMatrixSumAggregator(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 int 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,
                      int 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(IntDenseMatrix matrix,
                      MasterAggregatorUsage master)

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

Parameters:

matrix - the matrix to set the values

master - the master

getMatrix

public IntDenseMatrix 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 int matrix