I
- vertex Id type.WM
- Worker message typepublic interface BlockWorkerContextSendApi<I extends org.apache.hadoop.io.WritableComparable,WM extends org.apache.hadoop.io.Writable> extends BlockWorkerContextApi<I>, WorkerAggregatorUsage
Modifier and Type | Method and Description |
---|---|
void |
sendMessageToWorker(WM message,
int workerIndex)
Send message to another worker
|
getTotalNumEdges, getTotalNumVertices, getWorkerCount
getConf
getMyWorkerIndex, getWorkerCount, getWorkerForVertex
getCounter, progress, setStatus
aggregate
getAggregatedValue
void sendMessageToWorker(WM message, int workerIndex)
message
- Message to sendworkerIndex
- Index of the worker to send the message toCopyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.