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.