org.apache.giraph.comm

Interface WorkerServer<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

Type Parameters:

I - Vertex id

V - Vertex value

E - Edge value

All Superinterfaces:

AutoCloseable, Closeable, NetworkMetrics

All Known Implementing Classes:

NettyWorkerServer

public interface WorkerServer<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
extends NetworkMetrics, Closeable

Interface for message communication server.

Method Summary

Modifier and Type	Method and Description
void	close() Shuts down.
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	setFlowControl(FlowControl flowControl) Inform this server about the flow control used in sending requests

Methods inherited from interface org.apache.giraph.comm.NetworkMetrics

getBytesReceived, getBytesReceivedPerSuperstep, resetBytesReceivedPerSuperstep

Method Detail

getMyAddress

InetSocketAddress getMyAddress()

Get server address

Returns:

Address used by this server

getLocalHostOrIp

String getLocalHostOrIp()

Get server host name or IP

Returns:

server host name or IP

prepareSuperstep

void prepareSuperstep()

Prepare incoming messages for computation, and resolve mutation requests.

getServerData

ServerData<I,V,E> getServerData()

Get server data

Returns:

Server data

close

void close()

Shuts down.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

setFlowControl

void setFlowControl(FlowControl flowControl)

Inform this server about the flow control used in sending requests

Parameters:

flowControl - reference to the flow control policy