org.apache.giraph.block_app.reducers.array

Class ArrayOfHandles.ArrayOfBroadcasts<T>

java.lang.Object

org.apache.giraph.block_app.reducers.array.ArrayOfHandles<BroadcastHandle<T>>

org.apache.giraph.block_app.reducers.array.ArrayOfHandles.ArrayOfBroadcasts<T>

Type Parameters:

T - Handle type

All Implemented Interfaces:

ArrayHandle<BroadcastHandle<T>>, BroadcastArrayHandle<T>

Enclosing class:

ArrayOfHandles<H>

public static class ArrayOfHandles.ArrayOfBroadcasts<T>
extends ArrayOfHandles<BroadcastHandle<T>>
implements BroadcastArrayHandle<T>

BroadcastArrayHandle implemented as an array of separate broadcast 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
ArrayOfBroadcasts(int count, Int2ObjFunction<BroadcastHandle<T>> broadcastHandleFactory)
ArrayOfBroadcasts(int count, Supplier<BroadcastHandle<T>> broadcastHandleFactory)

Method Summary

Modifier and Type	Method and Description
int	getBroadcastedSize(WorkerBroadcastUsage worker) Number of elements that were broadcasted.

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

ArrayOfBroadcasts

public ArrayOfBroadcasts(int count,
                         Int2ObjFunction<BroadcastHandle<T>> broadcastHandleFactory)

ArrayOfBroadcasts

public ArrayOfBroadcasts(int count,
                         Supplier<BroadcastHandle<T>> broadcastHandleFactory)

Method Detail

getBroadcastedSize

public int getBroadcastedSize(WorkerBroadcastUsage worker)

Description copied from interface: BroadcastArrayHandle

Number of elements that were broadcasted.

Specified by:

getBroadcastedSize in interface BroadcastArrayHandle<T>