Package | Description |
---|---|
org.apache.giraph.comm.aggregators |
Package for classes which are used to handle aggregators.
|
Modifier and Type | Method and Description |
---|---|
void |
AllAggregatorServerData.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.
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.