org.apache.giraph.comm

Interface MasterClient

All Known Implementing Classes:

NettyMasterClient

public interface MasterClient

Interface for master to send messages to workers

Method Summary

Modifier and Type	Method and Description
void	closeConnections() Closes all connections.
void	finishSendingValues() Flush aggregated values cache.
void	flush() Flush all outgoing messages.
FlowControl	getFlowControl() Get the reference to the flow control policy used for sending requests
void	openConnections() Make sure that all the connections to workers have been established.
void	sendToOwner(String name, GlobalCommType type, org.apache.hadoop.io.Writable value) Sends aggregator to its owner
void	sendWritableRequest(int destTaskId, WritableRequest request) Send a request to a remote server (should be already connected)

Method Detail

openConnections

void openConnections()

Make sure that all the connections to workers have been established.

sendToOwner

void sendToOwner(String name,
                 GlobalCommType type,
                 org.apache.hadoop.io.Writable value)
          throws IOException

Sends aggregator to its owner

Parameters:

name - Name of the object

type - Global communication type

value - Object value

Throws:

IOException

finishSendingValues

void finishSendingValues()
                  throws IOException

Flush aggregated values cache.

Throws:

IOException

flush

void flush()

Flush all outgoing messages. This will synchronously ensure that all messages have been send and delivered prior to returning.

sendWritableRequest

void sendWritableRequest(int destTaskId,
                         WritableRequest request)

Send a request to a remote server (should be already connected)

Parameters:

destTaskId - Destination worker id

request - Request to send

closeConnections

void closeConnections()

Closes all connections.

getFlowControl

FlowControl getFlowControl()

Get the reference to the flow control policy used for sending requests

Returns:

reference to the flow control policy