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