org.apache.giraph.block_app.framework.api

Interface BlockWorkerContextSendApi<I extends org.apache.hadoop.io.WritableComparable,WM extends org.apache.hadoop.io.Writable>

Type Parameters:

I - vertex Id type.

WM - Worker message type

All Superinterfaces:

AggregatorUsage, BlockApi, BlockConfApi, BlockWorkerContextApi<I>, StatusReporter, WorkerAggregatorUsage, WorkerIndexUsage<I>

public interface BlockWorkerContextSendApi<I extends org.apache.hadoop.io.WritableComparable,WM extends org.apache.hadoop.io.Writable>
extends BlockWorkerContextApi<I>, WorkerAggregatorUsage

Block computation API available for worker send methods. Interface to the WorkerContext methods.

Method Summary

Modifier and Type	Method and Description
void	sendMessageToWorker(WM message, int workerIndex) Send message to another worker

Methods inherited from interface org.apache.giraph.block_app.framework.api.BlockApi

getTotalNumEdges, getTotalNumVertices, getWorkerCount

Methods inherited from interface org.apache.giraph.block_app.framework.api.BlockConfApi

getConf

Methods inherited from interface org.apache.giraph.worker.WorkerIndexUsage

getMyWorkerIndex, getWorkerCount, getWorkerForVertex

Methods inherited from interface org.apache.giraph.block_app.framework.api.StatusReporter

getCounter, progress, setStatus

Methods inherited from interface org.apache.giraph.worker.WorkerAggregatorUsage

aggregate

Methods inherited from interface org.apache.giraph.aggregators.AggregatorUsage

getAggregatedValue

Method Detail

sendMessageToWorker

void sendMessageToWorker(WM message,
                         int workerIndex)

Send message to another worker

Parameters:

message - Message to send

workerIndex - Index of the worker to send the message to