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.block_app.framework.api |
Interfaces representing full API to the underlying graph processing system.
|
org.apache.giraph.block_app.framework.api.giraph |
Giraph implementation of graph processing system API used by
Blocks Framework.
|
org.apache.giraph.examples |
Package of Giraph examples.
|
org.apache.giraph.examples.scc |
Classes for Strongly Connected Components computation.
|
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 | Interface and Description |
---|---|
interface |
BlockMasterApi
Block computation API available for the master methods.
|
Modifier and Type | Class and Description |
---|---|
class |
BlockMasterCompute<S>
MasterCompute class which executes block computation.
|
Modifier and Type | Class and Description |
---|---|
static class |
AggregatorsTestComputation.AggregatorsTestMasterCompute
Master compute which uses aggregators.
|
static class |
PageRankWithKryoSimpleWritable.PageRankWithKryoMasterCompute
Master compute associated with
PageRankWithKryoSimpleWritable . |
class |
RandomWalkVertexMasterCompute
Master compute associated with
RandomWalkComputation . |
static class |
SimpleCheckpoint.SimpleCheckpointVertexMasterCompute
Master compute associated with
SimpleCheckpoint . |
static class |
SimpleMasterComputeComputation.SimpleMasterCompute
MasterCompute used with
SimpleMasterComputeComputation . |
static class |
SimplePageRankComputation.SimplePageRankMasterCompute
Master compute associated with
SimplePageRankComputation . |
static class |
VerifyMessage.VerifyMessageMasterCompute
Master compute associated with
VerifyMessage.VerifyMessageComputation . |
Modifier and Type | Class and Description |
---|---|
class |
SccPhaseMasterCompute
This master compute keeps track of what phase is being currently executed by
the Strongly Connected Components computation.
|
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.