org.apache.giraph.aggregators.matrix.dense

Class FloatDenseMatrixSumAggregator

java.lang.Object

org.apache.giraph.aggregators.matrix.MatrixSumAggregator

org.apache.giraph.aggregators.matrix.dense.FloatDenseMatrixSumAggregator

public class FloatDenseMatrixSumAggregator
extends MatrixSumAggregator

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

Constructor Summary

Constructors

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

FloatDenseMatrixSumAggregator

public FloatDenseMatrixSumAggregator(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 float 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,
                      float 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(FloatDenseMatrix matrix,
                      MasterAggregatorUsage master)

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

Parameters:

matrix - the matrix to set the values

master - the master

getMatrix

public FloatDenseMatrix 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 float matrix