org.apache.giraph.block_app.reducers.collect

Class ShardedReducerHandle.ShardedBroadcastHandle

java.lang.Object

org.apache.giraph.block_app.reducers.collect.ShardedReducerHandle.ShardedBroadcastHandle

All Implemented Interfaces:

BroadcastHandle<R>

Direct Known Subclasses:

CollectShardedPrimitiveReducerHandle.CollectShardedPrimitiveBroadcastHandle, CollectShardedReducerHandle.CollectShardedBroadcastHandle, CollectShardedTuplesOfPrimitivesReducerHandle.CollectShardedTuplesOfPrimitivesBroadcastHandle

Enclosing class:

ShardedReducerHandle<S,R>

public class ShardedReducerHandle.ShardedBroadcastHandle
extends Object
implements BroadcastHandle<R>

Broadcast for ShardedReducerHandle

Field Summary

Fields

Modifier and Type	Field and Description
protected BroadcastArrayHandle<KryoWritableWrapper<R>>	broadcasts

Constructor Summary

Constructors

Constructor and Description
ShardedBroadcastHandle(BroadcastArrayHandle<KryoWritableWrapper<R>> broadcasts)

Method Summary

Modifier and Type	Method and Description
R	createBroadcastResult(WorkerBroadcastUsage worker)
R	getBroadcast(WorkerBroadcastUsage worker) Get broadcasted value

Methods inherited from class java.lang.Object

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

Field Detail

broadcasts

protected final BroadcastArrayHandle<KryoWritableWrapper<R>> broadcasts

Constructor Detail

ShardedBroadcastHandle

public ShardedBroadcastHandle(BroadcastArrayHandle<KryoWritableWrapper<R>> broadcasts)

Method Detail

createBroadcastResult

public R createBroadcastResult(WorkerBroadcastUsage worker)

getBroadcast

public final R getBroadcast(WorkerBroadcastUsage worker)

Description copied from interface: BroadcastHandle

Get broadcasted value

Specified by:

getBroadcast in interface BroadcastHandle<R>