Package | Description |
---|---|
org.apache.giraph.aggregators |
Package of Giraph aggregators.
|
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.block_app.framework.api |
Interfaces representing full API to the underlying graph processing system.
|
org.apache.giraph.block_app.migration |
Migration utility for transforming standard Giraph applications, into
Block Applications.
|
org.apache.giraph.examples |
Package of Giraph examples.
|
org.apache.giraph.master |
Package of all the master related things.
|
Modifier and Type | Class and Description |
---|---|
class |
BasicAggregator<A extends org.apache.hadoop.io.Writable>
Abstract class for
Aggregator . |
class |
BooleanAndAggregator
Aggregator for calculating the AND function over boolean values.
|
class |
BooleanOrAggregator
Aggregator for calculating the OR function over boolean values.
|
class |
BooleanOverwriteAggregator
Aggregator that stores a value that is overwritten once another value is
aggregated.
|
class |
DoubleMaxAggregator
Aggregator for getting max double value.
|
class |
DoubleMinAggregator
Aggregator for getting min double value.
|
class |
DoubleOverwriteAggregator
Aggregator that stores a value that is overwritten once another value is
aggregated.
|
class |
DoubleProductAggregator
Aggregator for calculating products of double values.
|
class |
DoubleSumAggregator
Aggregator for summing up double values.
|
class |
FloatMaxAggregator
Aggregator for getting max float value.
|
class |
FloatMinAggregator
Aggregator for getting min float value.
|
class |
FloatOverwriteAggregator
Aggregator that stores a value that is overwritten once another value is
aggregated.
|
class |
FloatProductAggregator
Aggregator for calculating products of float values.
|
class |
FloatSumAggregator
Aggregator for summing up float values.
|
class |
IntMaxAggregator
Aggregator for getting max integer value.
|
class |
IntMinAggregator
Aggregator for getting min integer value.
|
class |
IntOverwriteAggregator
Aggregator that stores a value that is overwritten once another value is
aggregated.
|
class |
IntProductAggregator
Aggregator for calculating products of long and integer values.
|
class |
IntSumAggregator
Aggregator for summing up integer values.
|
class |
LongMaxAggregator
Aggregator for getting max long value.
|
class |
LongMinAggregator
Aggregator for getting min long value.
|
class |
LongOverwriteAggregator
Aggregator that stores a value that is overwritten once another value is
aggregated.
|
class |
LongProductAggregator
Aggregator for calculating products of long values.
|
class |
LongSumAggregator
Aggregator for summing up long values.
|
class |
TextAppendAggregator
Aggregator with
Text as its value which keeps appending text to it |
Modifier and Type | Class and Description |
---|---|
class |
DoubleDenseVectorSumAggregator
The double dense vector aggregator is used to aggregate double dense vectors.
|
class |
FloatDenseVectorSumAggregator
The float dense vector aggregator is used to aggregate float dense vectors.
|
class |
IntDenseVectorSumAggregator
The double dense vector aggregator is used to aggregate double dense
vectors.
|
class |
LongDenseVectorSumAggregator
The long dense vector aggregator is used to aggregate long dense vectors.
|
Modifier and Type | Class and Description |
---|---|
class |
DoubleSparseVectorSumAggregator
The double vector aggregator is used to aggregate double vectors.
|
class |
FloatSparseVectorSumAggregator
The float vector aggregator is used to aggregate float vectors.
|
class |
IntSparseVectorSumAggregator
The float vector aggregator is used to aggregate float vectors.
|
class |
LongSparseVectorSumAggregator
The long vector aggregator is used to aggregate long vectors.
|
Modifier and Type | Method and Description |
---|---|
<A extends org.apache.hadoop.io.Writable> |
BlockMasterApi.registerPersistentAggregator(String name,
Class<? extends Aggregator<A>> aggregatorClass)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
<A extends org.apache.hadoop.io.Writable> |
MigrationMasterCompute.registerAggregator(String name,
Class<? extends Aggregator<A>> aggregatorClass) |
<A extends org.apache.hadoop.io.Writable> |
MigrationMasterCompute.registerPersistentAggregator(String name,
Class<? extends Aggregator<A>> aggregatorClass) |
Modifier and Type | Class and Description |
---|---|
static class |
PageRankWithKryoSimpleWritable.DoubleMaxWrapperAggregator
Aggregator for getting max double value
|
static class |
PageRankWithKryoSimpleWritable.DoubleMinWrapperAggregator
Aggregator for getting min double value.
|
Modifier and Type | Method and Description |
---|---|
Class<? extends Aggregator<A>> |
AggregatorReduceOperation.getAggregatorClass() |
Modifier and Type | Method and Description |
---|---|
<A extends org.apache.hadoop.io.Writable> |
AggregatorToGlobalCommTranslation.registerAggregator(String name,
Class<? extends Aggregator<A>> aggregatorClass) |
<A extends org.apache.hadoop.io.Writable> |
MasterAggregatorUsage.registerAggregator(String name,
Class<? extends Aggregator<A>> aggregatorClass)
Register an aggregator in preSuperstep() and/or preApplication().
|
<A extends org.apache.hadoop.io.Writable> |
MasterCompute.registerAggregator(String name,
Class<? extends Aggregator<A>> aggregatorClass) |
<A extends org.apache.hadoop.io.Writable> |
AggregatorToGlobalCommTranslation.registerPersistentAggregator(String name,
Class<? extends Aggregator<A>> aggregatorClass) |
<A extends org.apache.hadoop.io.Writable> |
MasterAggregatorUsage.registerPersistentAggregator(String name,
Class<? extends Aggregator<A>> aggregatorClass)
Register persistent aggregator in preSuperstep() and/or
preApplication().
|
<A extends org.apache.hadoop.io.Writable> |
MasterCompute.registerPersistentAggregator(String name,
Class<? extends Aggregator<A>> aggregatorClass) |
Constructor and Description |
---|
AggregatorBroadcast(Class<? extends Aggregator<A>> aggregatorClass,
A value)
Constructor
|
AggregatorReduceOperation(Class<? extends Aggregator<A>> aggregatorClass,
ImmutableClassesGiraphConfiguration<?,?,?> conf)
Constructor
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.