Package org.apache.giraph.comm.aggregators

Package for classes which are used to handle aggregators.

See: Description

Interface Summary

Interface	Description
WorkerAggregatorRequestProcessor	Aggregates worker aggregator requests and sends them off

Class Summary

Class	Description
AggregatorUtils	Class for aggregator constants and utility methods
AllAggregatorServerData	Accepts aggregators and their values from previous superstep from master and workers which own aggregators.
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
GlobalCommValueOutputStream	Implementation of CountingOutputStream which allows writing of reduced values in the form of pair (name, type, value) There are two modes: - when class of the value is written into the stream.
OwnerAggregatorServerData	Class for holding aggregators which current worker owns, and aggregating partial aggregator values from workers.
SendGlobalCommCache	Takes and serializes global communication values and keeps them grouped by owner partition id, to be sent in bulk.

Package org.apache.giraph.comm.aggregators Description

Package for classes which are used to handle aggregators.