Search Java Classes and Packages
#Org.apache.giraph.comm.aggregators Classes and Interfaces - 8 results found.
| Name | Description | Type | Package | Framework |
| AggregatorUtils | Class | org.apache.giraph.comm.aggregators | Giraph | |
| AllAggregatorServerData | Accepts aggregators and their values from previous superstep from master and workers which own aggregators. | Class | org.apache.giraph.comm.aggregators | Giraph |
| 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 | Class | org.apache.giraph.comm.aggregators | Giraph |
| CountingOutputStream | Wrapper for output stream which keeps the place in the beginning for the count of objects which were written to it | Class | org.apache.giraph.comm.aggregators | Giraph |
| GlobalCommValueOutputStream | reduced values in the form of pair (name, type, value) There are two modes: | Class | org.apache.giraph.comm.aggregators | Giraph |
| OwnerAggregatorServerData | Class for holding aggregators which current worker owns, and aggregating partial aggregator values from workers. | Class | org.apache.giraph.comm.aggregators | Giraph |
| SendGlobalCommCache | Takes and serializes global communication values and keeps them grouped by owner partition id, to be sent in bulk. | Class | org.apache.giraph.comm.aggregators | Giraph |
| WorkerAggregatorRequestProcessor | Interface | org.apache.giraph.comm.aggregators | Giraph | |