org.apache.giraph.comm

Interface WorkerClient<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 Known Implementing Classes:

NettyWorkerClient

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

Public interface for workers to establish connections and send aggregated requests.

Method Summary

Modifier and Type	Method and Description
void	authenticate() Authenticates, as client, with another BSP worker, as server.
void	closeConnections() Closes all connections.
FlowControl	getFlowControl()
PartitionOwner	getVertexPartitionOwner(I vertexId) Lookup PartitionOwner for a vertex.
void	openConnections() Make sure that all the connections to workers and master have been established.
void	sendWritableRequest(int destTaskId, WritableRequest request) Send a request to a remote server (should be already connected)
void	setup(boolean authenticate) Setup the client.
void	waitAllRequests() Wait until all the outstanding requests are completed.

Method Detail

setup

void setup(boolean authenticate)

Setup the client.

Parameters:

authenticate - whether to SASL authenticate with server or not: set by giraph.authenticate configuration option.

getVertexPartitionOwner

PartitionOwner getVertexPartitionOwner(I vertexId)

Lookup PartitionOwner for a vertex.

Parameters:

vertexId - id to look up.

Returns:

PartitionOwner holding the vertex.

openConnections

void openConnections()

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

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

waitAllRequests

void waitAllRequests()

Wait until all the outstanding requests are completed.

closeConnections

void closeConnections()
               throws IOException

Closes all connections.

Throws:

IOException

authenticate

void authenticate()
           throws IOException

Authenticates, as client, with another BSP worker, as server.

Throws:

IOException

getFlowControl

FlowControl getFlowControl()

Returns:

the flow control used in sending requests