org.apache.giraph.block_app.reducers.array

Class ArrayOfHandles.ArrayOfReducers<S,R>

java.lang.Object

org.apache.giraph.block_app.reducers.array.ArrayOfHandles<ReducerHandle<S,R>>

org.apache.giraph.block_app.reducers.array.ArrayOfHandles.ArrayOfReducers<S,R>

Type Parameters:

S - Handle type

R - Reduce value type

All Implemented Interfaces:

ArrayHandle<ReducerHandle<S,R>>, ReducerArrayHandle<S,R>

Enclosing class:

ArrayOfHandles<H>

public static class ArrayOfHandles.ArrayOfReducers<S,R>
extends ArrayOfHandles<ReducerHandle<S,R>>
implements ReducerArrayHandle<S,R>

ReducerArrayHandle implemented as an array of separate reducer handles.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.giraph.block_app.reducers.array.ArrayOfHandles

ArrayOfHandles.ArrayOfBroadcasts<T>, ArrayOfHandles.ArrayOfReducers<S,R>

Field Summary

Fields inherited from class org.apache.giraph.block_app.reducers.array.ArrayOfHandles

handles

Constructor Summary

Constructors

Constructor and Description
ArrayOfReducers(int count, Int2ObjFunction<ReducerHandle<S,R>> reduceHandleFactory)
ArrayOfReducers(int count, Supplier<ReducerHandle<S,R>> reduceHandleFactory)

Method Summary

Modifier and Type	Method and Description
BroadcastArrayHandle<R>	broadcastValue(BlockMasterApi master) Broadcast whole array of reducers to master
int	getReducedSize(BlockMasterApi master) Number of elements that were reduced.

Methods inherited from class org.apache.giraph.block_app.reducers.array.ArrayOfHandles

get, getStaticSize

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.array.ArrayHandle

get, getStaticSize

Constructor Detail

ArrayOfReducers

public ArrayOfReducers(int count,
                       Supplier<ReducerHandle<S,R>> reduceHandleFactory)

ArrayOfReducers

public ArrayOfReducers(int count,
                       Int2ObjFunction<ReducerHandle<S,R>> reduceHandleFactory)

Method Detail

getReducedSize

public int getReducedSize(BlockMasterApi master)

Description copied from interface: ReducerArrayHandle

Number of elements that were reduced.

Specified by:

getReducedSize in interface ReducerArrayHandle<S,R>

broadcastValue

public BroadcastArrayHandle<R> broadcastValue(BlockMasterApi master)

Description copied from interface: ReducerArrayHandle

Broadcast whole array of reducers to master

Specified by:

broadcastValue in interface ReducerArrayHandle<S,R>

Returns:

Handle to the broadcasted array.