public static class CollectShardedTuplesOfPrimitivesReducerHandle.CollectShardedTuplesOfPrimitivesReduceBroadcast extends Object
Constructor and Description |
---|
CollectShardedTuplesOfPrimitivesReduceBroadcast() |
Modifier and Type | Method and Description |
---|---|
void |
broadcastValue(BlockMasterApi master)
Broadcast reduced value from master
|
List<Object> |
createSingleValue() |
List<WArrayList> |
getBroadcast(WorkerBroadcastUsage worker)
Get broadcasted value
|
List<WArrayList> |
getReducedValue(MasterGlobalCommUsage master)
Get reduced value
|
void |
reduce(List<Object> valueToReduce)
Reduce single value
|
void |
registeredReducer(CreateReducersApi reduceApi,
Class<?>... valueClasses)
Set reducer handle to just registered handle
|
public CollectShardedTuplesOfPrimitivesReduceBroadcast()
public void registeredReducer(CreateReducersApi reduceApi, Class<?>... valueClasses)
public List<WArrayList> getReducedValue(MasterGlobalCommUsage master)
public void broadcastValue(BlockMasterApi master)
public List<WArrayList> getBroadcast(WorkerBroadcastUsage worker)
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.