org.apache.giraph.comm.netty

Class NettyMasterClient

java.lang.Object

org.apache.giraph.comm.netty.NettyMasterClient

All Implemented Interfaces:

MasterClient

public class NettyMasterClient
extends Object
implements MasterClient

Netty implementation of MasterClient

Constructor Summary

Constructors

Constructor and Description
NettyMasterClient(org.apache.hadoop.mapreduce.Mapper.Context context, ImmutableClassesGiraphConfiguration configuration, CentralizedServiceMaster<?,?,?> service, Thread.UncaughtExceptionHandler exceptionHandler) Constructor

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 sendType, org.apache.hadoop.io.Writable object) Sends aggregator to its owner
void	sendWritableRequest(int destTaskId, WritableRequest request) Send a request to a remote server (should be already connected)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NettyMasterClient

public NettyMasterClient(org.apache.hadoop.mapreduce.Mapper.Context context,
                         ImmutableClassesGiraphConfiguration configuration,
                         CentralizedServiceMaster<?,?,?> service,
                         Thread.UncaughtExceptionHandler exceptionHandler)

Constructor

Parameters:

context - Context from mapper

configuration - Configuration

service - Centralized service

exceptionHandler - handler for uncaught exception. Will terminate job.

Method Detail

openConnections

public void openConnections()

Description copied from interface: MasterClient

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

Specified by:

openConnections in interface MasterClient

sendToOwner

public void sendToOwner(String name,
                        GlobalCommType sendType,
                        org.apache.hadoop.io.Writable object)
                 throws IOException

Description copied from interface: MasterClient

Sends aggregator to its owner

Specified by:

sendToOwner in interface MasterClient

Parameters:

name - Name of the object

sendType - Global communication type

object - Object value

Throws:

IOException

finishSendingValues

public void finishSendingValues()
                         throws IOException

Description copied from interface: MasterClient

Flush aggregated values cache.

Specified by:

finishSendingValues in interface MasterClient

Throws:

IOException

flush

public void flush()

Description copied from interface: MasterClient

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

Specified by:

flush in interface MasterClient

sendWritableRequest

public void sendWritableRequest(int destTaskId,
                                WritableRequest request)

Description copied from interface: MasterClient

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

Specified by:

sendWritableRequest in interface MasterClient

Parameters:

destTaskId - Destination worker id

request - Request to send

closeConnections

public void closeConnections()

Description copied from interface: MasterClient

Closes all connections.

Specified by:

closeConnections in interface MasterClient

getFlowControl

public FlowControl getFlowControl()

Description copied from interface: MasterClient

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

Specified by:

getFlowControl in interface MasterClient

Returns:

reference to the flow control policy