public class CollectShardedPrimitiveReducerHandle.CollectShardedPrimitiveBroadcastHandle extends ShardedReducerHandle.ShardedBroadcastHandle
broadcasts
Constructor and Description |
---|
CollectShardedPrimitiveBroadcastHandle(BroadcastArrayHandle<KryoWritableWrapper<WArrayList<S>>> broadcasts) |
Modifier and Type | Method and Description |
---|---|
WArrayList<S> |
createBroadcastResult(WorkerBroadcastUsage worker) |
getBroadcast
public CollectShardedPrimitiveBroadcastHandle(BroadcastArrayHandle<KryoWritableWrapper<WArrayList<S>>> broadcasts)
public WArrayList<S> createBroadcastResult(WorkerBroadcastUsage worker)
createBroadcastResult
in class ShardedReducerHandle.ShardedBroadcastHandle
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.