org.apache.giraph.master

Interface MasterGlobalCommUsageAggregators

All Known Subinterfaces:

BlockMasterApi, MasterGlobalCommUsage

All Known Implementing Classes:

AggregatorsBenchmark.AggregatorsBenchmarkMasterCompute, AggregatorsTestComputation.AggregatorsTestMasterCompute, BlockMasterCompute, DefaultMasterCompute, MasterAggregatorHandler, MasterCompute, MasterGlobalCommHandler, PageRankWithKryoSimpleWritable.PageRankWithKryoMasterCompute, RandomMessageBenchmark.RandomMessageBenchmarkMasterCompute, RandomWalkVertexMasterCompute, ReducersBenchmark.ReducersBenchmarkMasterCompute, SccPhaseMasterCompute, SimpleCheckpoint.SimpleCheckpointVertexMasterCompute, SimpleMasterComputeComputation.SimpleMasterCompute, SimplePageRankComputation.SimplePageRankMasterCompute, VerifyMessage.VerifyMessageMasterCompute

public interface MasterGlobalCommUsageAggregators

Master compute can access reduce and broadcast methods through this interface, from masterCompute method.

Method Summary

Modifier and Type	Method and Description
void	broadcast(String name, org.apache.hadoop.io.Writable value) Broadcast given value to all workers for next computation.
<R extends org.apache.hadoop.io.Writable> R	getReduced(String name) Get reduced value from previous worker computation.
<S,R extends org.apache.hadoop.io.Writable> void	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> void	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.

Method Detail

registerReducer

<S,R extends org.apache.hadoop.io.Writable> void registerReducer(String name,
                                                                 ReduceOperation<S,R> reduceOp)

Register reducer to be reduced in the next worker computation, using given name and operations.

Type Parameters:

S - Single value type

R - Reduced value type

Parameters:

name - Name of the reducer

reduceOp - Reduce operations

registerReducer

<S,R extends org.apache.hadoop.io.Writable> void 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. (globalInitialValue is reduced only once, each worker will still start from neutral initial value)

Type Parameters:

S - Single value type

R - Reduced value type

Parameters:

name - Name of the reducer

reduceOp - Reduce operations

globalInitialValue - Global initial value

getReduced

<R extends org.apache.hadoop.io.Writable> R getReduced(String name)

Get reduced value from previous worker computation.

Type Parameters:

R - Reduced value type

Parameters:

name - Name of the reducer

Returns:

Reduced value

broadcast

void broadcast(String name,
               org.apache.hadoop.io.Writable value)

Broadcast given value to all workers for next computation.

Parameters:

name - Name of the broadcast object

value - Value