org.apache.giraph.comm.netty

Class NettyWorkerServer<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

java.lang.Object

org.apache.giraph.comm.netty.NettyWorkerServer<I,V,E>

Type Parameters:

I - Vertex id

V - Vertex data

E - Edge data

All Implemented Interfaces:

Closeable, AutoCloseable, NetworkMetrics, WorkerServer<I,V,E>

public class NettyWorkerServer<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
extends Object
implements WorkerServer<I,V,E>

Netty worker server that implement WorkerServer and contains the actual ServerData.

Constructor Summary

Constructors

Constructor and Description
NettyWorkerServer(ImmutableClassesGiraphConfiguration<I,V,E> conf, CentralizedServiceWorker<I,V,E> service, org.apache.hadoop.mapreduce.Mapper.Context context, Thread.UncaughtExceptionHandler exceptionHandler) Constructor to start the server.

Method Summary

Modifier and Type	Method and Description
void	close() Shuts down.
long	getBytesReceived() Returns aggregate bytes received.
long	getBytesReceivedPerSuperstep() Returns bytes received in current superstep
String	getLocalHostOrIp() Get server host name or IP
InetSocketAddress	getMyAddress() Get server address
ServerData<I,V,E>	getServerData() Get server data
void	prepareSuperstep() Prepare incoming messages for computation, and resolve mutation requests.
void	resetBytesReceivedPerSuperstep() Resets the counter for bytes received per superstep.
void	setFlowControl(FlowControl flowControl) Inform this server about the flow control used in sending requests

Methods inherited from class java.lang.Object

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

Constructor Detail

NettyWorkerServer

public NettyWorkerServer(ImmutableClassesGiraphConfiguration<I,V,E> conf,
                         CentralizedServiceWorker<I,V,E> service,
                         org.apache.hadoop.mapreduce.Mapper.Context context,
                         Thread.UncaughtExceptionHandler exceptionHandler)

Constructor to start the server.

Parameters:

conf - Configuration

service - Service to get partition mappings

context - Mapper context

exceptionHandler - handle uncaught exceptions

Method Detail

getMyAddress

public InetSocketAddress getMyAddress()

Description copied from interface: WorkerServer

Get server address

Specified by:

getMyAddress in interface WorkerServer<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

Returns:

Address used by this server

getLocalHostOrIp

public String getLocalHostOrIp()

Description copied from interface: WorkerServer

Get server host name or IP

Specified by:

getLocalHostOrIp in interface WorkerServer<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

Returns:

server host name or IP

prepareSuperstep

public void prepareSuperstep()

Description copied from interface: WorkerServer

Prepare incoming messages for computation, and resolve mutation requests.

Specified by:

prepareSuperstep in interface WorkerServer<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

getServerData

public ServerData<I,V,E> getServerData()

Description copied from interface: WorkerServer

Get server data

Specified by:

getServerData in interface WorkerServer<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

Returns:

Server data

close

public void close()

Description copied from interface: WorkerServer

Shuts down.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface WorkerServer<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

setFlowControl

public void setFlowControl(FlowControl flowControl)

Description copied from interface: WorkerServer

Inform this server about the flow control used in sending requests

Specified by:

setFlowControl in interface WorkerServer<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

Parameters:

flowControl - reference to the flow control policy

getBytesReceivedPerSuperstep

public long getBytesReceivedPerSuperstep()

Description copied from interface: NetworkMetrics

Returns bytes received in current superstep

Specified by:

getBytesReceivedPerSuperstep in interface NetworkMetrics

Returns:

Number of bytes.

resetBytesReceivedPerSuperstep

public void resetBytesReceivedPerSuperstep()

Description copied from interface: NetworkMetrics

Resets the counter for bytes received per superstep. This will be called by the component that defines when a superstep is done.

Specified by:

resetBytesReceivedPerSuperstep in interface NetworkMetrics

getBytesReceived

public long getBytesReceived()

Description copied from interface: NetworkMetrics

Returns aggregate bytes received.

Specified by:

getBytesReceived in interface NetworkMetrics

Returns:

Number of bytes