org.apache.giraph.block_app.framework.piece.global_comm

Class ReducerAndBroadcastWrapperHandle<S,R>

java.lang.Object

org.apache.giraph.block_app.framework.piece.global_comm.ReducerAndBroadcastWrapperHandle<S,R>

Type Parameters:

S - Single value type

R - Reduced value type

public class ReducerAndBroadcastWrapperHandle<S,R>
extends Object

Handle that wraps both reducerHandle and broadcastHandle, so callers don't need to have two fields.

Constructor Summary

Constructors

Constructor and Description
ReducerAndBroadcastWrapperHandle()

Method Summary

Modifier and Type	Method and Description
void	broadcastValue(BlockMasterApi master) Broadcast reduced value from master
R	getBroadcast(WorkerBroadcastUsage worker) Get broadcasted value
R	getReducedValue(MasterGlobalCommUsage master) Get reduced value
void	reduce(S valueToReduce) Reduce single value
void	registeredReducer(ReducerHandle<S,R> reducerHandle) Set reducer handle to just registered handle

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ReducerAndBroadcastWrapperHandle

public ReducerAndBroadcastWrapperHandle()

Method Detail

registeredReducer

public void registeredReducer(ReducerHandle<S,R> reducerHandle)

Set reducer handle to just registered handle

reduce

public void reduce(S valueToReduce)

Reduce single value

getReducedValue

public R getReducedValue(MasterGlobalCommUsage master)

Get reduced value

broadcastValue

public void broadcastValue(BlockMasterApi master)

Broadcast reduced value from master

getBroadcast

public R getBroadcast(WorkerBroadcastUsage worker)

Get broadcasted value