public class AllAggregatorServerData extends Object
Constructor and Description |
---|
AllAggregatorServerData(org.apache.hadoop.util.Progressable progressable,
ImmutableClassesGiraphConfiguration conf)
Constructor
|
Modifier and Type | Method and Description |
---|---|
void |
fillNextSuperstepMapsWhenReady(Set<Integer> workerIds,
Map<String,org.apache.hadoop.io.Writable> broadcastedMapToFill,
Map<String,Reducer<Object,org.apache.hadoop.io.Writable>> reducerMapToFill)
This function will wait until all aggregator requests from workers have
arrived, and fill the maps for next superstep when ready.
|
Iterable<byte[]> |
getDataFromMasterWhenReady(MasterInfo masterInfo)
This function will wait until all aggregator requests from master have
arrived, and return that data afterwards.
|
void |
receivedRequestCountFromMaster(long requestCount,
int taskId)
Notify this object about the total number of requests which should
arrive from master.
|
void |
receivedRequestCountFromWorker(long requestCount,
int taskId)
Notify this object about the total number of requests which should
arrive from one of the workers.
|
void |
receivedRequestFromMaster(byte[] data)
Notify this object that an aggregator request from master has been
received.
|
void |
receivedRequestFromWorker()
Notify this object that an aggregator request from some worker has been
received.
|
void |
receiveValueFromMaster(String name,
GlobalCommType type,
org.apache.hadoop.io.Writable value)
Received value through global communication from master.
|
public AllAggregatorServerData(org.apache.hadoop.util.Progressable progressable, ImmutableClassesGiraphConfiguration conf)
progressable
- Progressable used to report progressconf
- Configurationpublic void receiveValueFromMaster(String name, GlobalCommType type, org.apache.hadoop.io.Writable value)
name
- Nametype
- Global communication typevalue
- Object valuepublic void receivedRequestFromMaster(byte[] data)
data
- Byte request with data received from masterpublic void receivedRequestCountFromMaster(long requestCount, int taskId)
requestCount
- Number of requests which should arrivetaskId
- Task id of masterpublic void receivedRequestFromWorker()
public void receivedRequestCountFromWorker(long requestCount, int taskId)
requestCount
- Number of requests which should arrivetaskId
- Task id of that workerpublic Iterable<byte[]> getDataFromMasterWhenReady(MasterInfo masterInfo)
masterInfo
- Master infopublic void fillNextSuperstepMapsWhenReady(Set<Integer> workerIds, Map<String,org.apache.hadoop.io.Writable> broadcastedMapToFill, Map<String,Reducer<Object,org.apache.hadoop.io.Writable>> reducerMapToFill)
workerIds
- All workers in the job apart from the current onebroadcastedMapToFill
- Broadcast map to fill outreducerMapToFill
- Registered reducer map to fill out.Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.