Package | Description |
---|---|
org.apache.giraph.benchmark |
Package of benchmarks for performance testing and optimization
|
org.apache.giraph.comm.aggregators |
Package for classes which are used to handle aggregators.
|
org.apache.giraph.master |
Package of all the master related things.
|
org.apache.giraph.reducers |
Package of Giraph reducers.
|
org.apache.giraph.reducers.impl |
Package of Giraph reducers.
|
Modifier and Type | Class and Description |
---|---|
static class |
ReducersBenchmark.TestLongSumReducer
LongSumReducer
|
Modifier and Type | Method and Description |
---|---|
void |
OwnerAggregatorServerData.registerReducer(String name,
ReduceOperation<Object,org.apache.hadoop.io.Writable> reduceOp)
Register a reducer which current worker owns.
|
Modifier and Type | Class and Description |
---|---|
class |
AggregatorReduceOperation<A extends org.apache.hadoop.io.Writable>
Translates aggregation operation to reduce operations.
|
Modifier and Type | Method and Description |
---|---|
<S,R extends org.apache.hadoop.io.Writable> |
MasterAggregatorHandler.registerReducer(String name,
ReduceOperation<S,R> reduceOp) |
<S,R extends org.apache.hadoop.io.Writable> |
MasterGlobalCommHandler.registerReducer(String name,
ReduceOperation<S,R> reduceOp) |
<S,R extends org.apache.hadoop.io.Writable> |
MasterGlobalCommUsageAggregators.registerReducer(String name,
ReduceOperation<S,R> reduceOp)
Register reducer to be reduced in the next worker computation,
using given name and operations.
|
<S,R extends org.apache.hadoop.io.Writable> |
MasterCompute.registerReducer(String name,
ReduceOperation<S,R> reduceOp) |
<S,R extends org.apache.hadoop.io.Writable> |
MasterAggregatorHandler.registerReducer(String name,
ReduceOperation<S,R> reduceOp,
R globalInitialValue) |
<S,R extends org.apache.hadoop.io.Writable> |
MasterGlobalCommHandler.registerReducer(String name,
ReduceOperation<S,R> reduceOp,
R globalInitialValue) |
<S,R extends org.apache.hadoop.io.Writable> |
MasterGlobalCommUsageAggregators.registerReducer(String name,
ReduceOperation<S,R> reduceOp,
R globalInitialValue)
Register reducer to be reduced in the next worker computation, using
given name and operations, starting globally from globalInitialValue.
|
<S,R extends org.apache.hadoop.io.Writable> |
MasterCompute.registerReducer(String name,
ReduceOperation<S,R> reduceOp,
R globalInitialValue) |
Modifier and Type | Class and Description |
---|---|
class |
ReduceSameTypeOperation<R extends org.apache.hadoop.io.Writable>
ReduceOperation object when single object being reduced is of
same type as reduced value.
|
Modifier and Type | Method and Description |
---|---|
ReduceOperation<S,R> |
Reducer.getReduceOp() |
Constructor and Description |
---|
Reducer(ReduceOperation<S,R> reduceOp)
Constructor
|
Reducer(ReduceOperation<S,R> reduceOp,
R currentValue)
Constructor
|
Modifier and Type | Class and Description |
---|---|
class |
AndReduce
ReduceOperation for calculating the AND function over boolean values.
|
class |
KryoWrappedReduceOperation<S,R>
Reduce operation which wraps reduced value in KryoWritableWrapper,
so we don't need to worry about it being writable
|
class |
LongXorReduce
ReduceOperation that XORs (^) values together.
|
class |
MaxPairReducer<L extends org.apache.hadoop.io.Writable,R extends org.apache.hadoop.io.WritableComparable>
Aggregating PairWritable<L, R>, by taking pair with
largest second value.
|
class |
MaxReduce<T extends org.apache.hadoop.io.WritableComparable>
Reducer for calculating max of values
|
class |
MinReduce<T extends org.apache.hadoop.io.WritableComparable>
Reducer for calculating min of values
|
class |
OrReduce
ReduceOperation for calculating the OR function over boolean values.
|
class |
PairReduce<S1,R1 extends org.apache.hadoop.io.Writable,S2,R2 extends org.apache.hadoop.io.Writable>
Combines two individual reducers, to create a single reducer of pairs that
reduces each of them individually.
|
class |
SumReduce<T extends org.apache.hadoop.io.Writable>
Reducer for calculating sum of values
|
Constructor and Description |
---|
PairReduce(ReduceOperation<S1,R1> reduce1,
ReduceOperation<S2,R2> reduce2)
Constructor
|
PairReduce(ReduceOperation<S1,R1> reduce1,
ReduceOperation<S2,R2> reduce2)
Constructor
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.