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

Class ReducersForPieceHandler.ReduceHandleImpl<S,R extends org.apache.hadoop.io.Writable>

java.lang.Object

org.apache.giraph.block_app.framework.piece.global_comm.internal.ReducersForPieceHandler.ReduceHandleImpl<S,R>

Type Parameters:

S - Single value type

R - Reduced value type

All Implemented Interfaces:

VertexSenderObserver, ReducerHandle<S,R>

Direct Known Subclasses:

ReducersForPieceHandler.GlobalReduceHandle, ReducersForPieceHandler.LocalReduceHandle

Enclosing class:

ReducersForPieceHandler

public abstract class ReducersForPieceHandler.ReduceHandleImpl<S,R extends org.apache.hadoop.io.Writable>
extends Object
implements ReducerHandle<S,R>, VertexSenderObserver

Parent implementation of ReducerHandle

Field Summary

Fields

Modifier and Type	Field and Description
protected ReduceOperation<S,R>	reduceOp

Method Summary

Modifier and Type	Method and Description
BroadcastHandle<R>	broadcastValue(BlockMasterApi master) Broadcast reduced value from master
String	getName()
R	getReducedValue(MasterGlobalCommUsage master) Get reduced value

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.giraph.block_app.framework.piece.global_comm.ReducerHandle

reduce

Methods inherited from interface org.apache.giraph.block_app.framework.piece.global_comm.internal.VertexSenderObserver

vertexSenderWorkerPostprocess, vertexSenderWorkerPreprocess

Field Detail

reduceOp

protected final ReduceOperation<S,R extends org.apache.hadoop.io.Writable> reduceOp

Method Detail

getName

public String getName()

getReducedValue

public R getReducedValue(MasterGlobalCommUsage master)

Description copied from interface: ReducerHandle

Get reduced value

Specified by:

getReducedValue in interface ReducerHandle<S,R extends org.apache.hadoop.io.Writable>

broadcastValue

public BroadcastHandle<R> broadcastValue(BlockMasterApi master)

Description copied from interface: ReducerHandle

Broadcast reduced value from master

Specified by:

broadcastValue in interface ReducerHandle<S,R extends org.apache.hadoop.io.Writable>

Returns:

Handle to the broadcasted value.