| Package | Description | 
|---|---|
| org.apache.giraph.comm | Package of communication related objects, IPC service. | 
| org.apache.giraph.comm.aggregators | Package for classes which are used to handle aggregators. | 
| org.apache.giraph.comm.netty | Package for netty implementations. | 
| org.apache.giraph.worker | Package of all the worker related things | 
| Class and Description | 
|---|
| AllAggregatorServerData Accepts aggregators and their values from previous superstep from master
 and workers which own aggregators. | 
| OwnerAggregatorServerData Class for holding aggregators which current worker owns,
 and aggregating partial aggregator values from workers. | 
| Class and Description | 
|---|
| CountingCache Cache which counts the number of flushes per task id (destination worker
 id), so we know how many requests were sent to the worker | 
| CountingOutputStream Wrapper for output stream which keeps the place in the beginning for the
 count of objects which were written to it | 
| Class and Description | 
|---|
| WorkerAggregatorRequestProcessor Aggregates worker aggregator requests and sends them off | 
| Class and Description | 
|---|
| WorkerAggregatorRequestProcessor Aggregates worker aggregator requests and sends them off | 
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.