| 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.