Package | Description |
---|---|
org.apache.giraph.aggregators.matrix.dense |
Package of dense matrix aggregator.
|
org.apache.giraph.aggregators.matrix.sparse |
Package of sparce matrix aggregator.
|
org.apache.giraph.benchmark |
Package of benchmarks for performance testing and optimization
|
org.apache.giraph.master |
Package of all the master related things.
|
org.apache.giraph.utils |
Package of all generic utility classes.
|
Modifier and Type | Method and Description |
---|---|
void |
FloatDenseMatrixSumAggregator.register(int numRows,
MasterAggregatorUsage master)
Register the float vector aggregators, one for each row of the matrix.
|
void |
LongDenseMatrixSumAggregator.register(int numRows,
MasterAggregatorUsage master)
Register the long vector aggregators, one for each row of the matrix.
|
void |
IntDenseMatrixSumAggregator.register(int numRows,
MasterAggregatorUsage master)
Register the int vector aggregators, one for each row of the matrix.
|
void |
DoubleDenseMatrixSumAggregator.register(int numRows,
MasterAggregatorUsage master)
Register the double vector aggregators, one for each row of the matrix.
|
void |
DoubleDenseMatrixSumAggregator.setMatrix(DoubleDenseMatrix matrix,
MasterAggregatorUsage master)
Set the values of the matrix to the master specified.
|
void |
FloatDenseMatrixSumAggregator.setMatrix(FloatDenseMatrix matrix,
MasterAggregatorUsage master)
Set the values of the matrix to the master specified.
|
void |
IntDenseMatrixSumAggregator.setMatrix(IntDenseMatrix matrix,
MasterAggregatorUsage master)
Set the values of the matrix to the master specified.
|
void |
LongDenseMatrixSumAggregator.setMatrix(LongDenseMatrix matrix,
MasterAggregatorUsage master)
Set the values of the matrix to the master specified.
|
Modifier and Type | Method and Description |
---|---|
void |
LongSparseMatrixSumAggregator.register(int numRows,
MasterAggregatorUsage master)
Register the long vector aggregators, one for each row of the matrix.
|
void |
FloatSparseMatrixSumAggregator.register(int numRows,
MasterAggregatorUsage master)
Register the float vector aggregators, one for each row of the matrix.
|
void |
DoubleSparseMatrixSumAggregator.register(int numRows,
MasterAggregatorUsage master)
Register the double vector aggregators, one for each row of the matrix.
|
void |
IntSparseMatrixSumAggregator.register(int numRows,
MasterAggregatorUsage master)
Register the int vector aggregators, one for each row of the matrix.
|
void |
DoubleSparseMatrixSumAggregator.setMatrix(DoubleSparseMatrix matrix,
MasterAggregatorUsage master)
Set the values of the matrix to the master specified.
|
void |
FloatSparseMatrixSumAggregator.setMatrix(FloatSparseMatrix matrix,
MasterAggregatorUsage master)
Set the values of the matrix to the master specified.
|
void |
IntSparseMatrixSumAggregator.setMatrix(IntSparseMatrix matrix,
MasterAggregatorUsage master)
Set the values of the matrix to the master specified.
|
void |
LongSparseMatrixSumAggregator.setMatrix(LongSparseMatrix matrix,
MasterAggregatorUsage master)
Set the values of the matrix to the master specified.
|
Modifier and Type | Class and Description |
---|---|
static class |
AggregatorsBenchmark.AggregatorsBenchmarkMasterCompute
MasterCompute class for AggregatorsBenchmark
|
static class |
RandomMessageBenchmark.RandomMessageBenchmarkMasterCompute
Master compute associated with
RandomMessageBenchmark . |
static class |
ReducersBenchmark.ReducersBenchmarkMasterCompute
MasterCompute class for ReducersBenchmark
|
Modifier and Type | Class and Description |
---|---|
class |
AggregatorToGlobalCommTranslation
Class that translates aggregator handling on the master to
reduce and broadcast operations supported by the MasterAggregatorHandler.
|
class |
DefaultMasterCompute
A dumb implementation of
MasterCompute . |
class |
MasterCompute
Interface for defining a master vertex that can perform centralized
computation between supersteps.
|
Modifier and Type | Method and Description |
---|---|
static void |
MasterLoggingAggregator.logAggregatedValue(MasterAggregatorUsage masterAggregatorUsage,
org.apache.hadoop.conf.Configuration conf)
Print value of master logging aggregator on the master log,
if the option for using it is set in the configuration.
|
static void |
MasterLoggingAggregator.registerAggregator(MasterAggregatorUsage masterAggregatorUsage,
org.apache.hadoop.conf.Configuration conf)
Register master logging aggregator,
if the option for using it is set in the configuration.
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.