org.apache.giraph.comm.aggregators

Interface WorkerAggregatorRequestProcessor

All Known Implementing Classes:

NettyWorkerAggregatorRequestProcessor

public interface WorkerAggregatorRequestProcessor

Aggregates worker aggregator requests and sends them off

Method Summary

Modifier and Type	Method and Description
void	distributeReducedValues(Iterable<byte[]> reducedDataList) Sends reduced values to all other workers
void	flush() Flush aggregated values cache.
boolean	sendReducedValue(String name, org.apache.hadoop.io.Writable reducedValue) Sends worker reduced value to the owner of reducer
void	sendReducedValuesToMaster(byte[] data) Sends reduced values to the master.

Method Detail

sendReducedValue

boolean sendReducedValue(String name,
                         org.apache.hadoop.io.Writable reducedValue)
                  throws IOException

Sends worker reduced value to the owner of reducer

Parameters:

name - Name of the reducer

reducedValue - Reduced partial value

Returns:

True if reduced value will be sent, false if this worker is the owner of the reducer

Throws:

IOException

flush

void flush()
    throws IOException

Flush aggregated values cache.

Throws:

IOException

sendReducedValuesToMaster

void sendReducedValuesToMaster(byte[] data)
                        throws IOException

Sends reduced values to the master. This worker is the owner of these reducers.

Parameters:

data - Serialized reduced values data

Throws:

IOException

distributeReducedValues

void distributeReducedValues(Iterable<byte[]> reducedDataList)
                      throws IOException

Sends reduced values to all other workers

Parameters:

reducedDataList - Serialized reduced values data split into chunks

Throws:

IOException