public interface IDriverMessenger
Modifier and Type | Method and Description |
---|---|
boolean |
broadcastToAllWorkers(Message message)
send a protocol buffer message to all workers in the job
|
boolean |
sendToWorker(Message message,
java.lang.Integer workerID)
send a protocol buffer message to a worker in the job
|
boolean |
sendToWorkerList(Message message,
java.util.List<java.lang.Integer> workerList)
send a protocol buffer message to a list of workers in the job
|
boolean broadcastToAllWorkers(Message message)
boolean sendToWorkerList(Message message, java.util.List<java.lang.Integer> workerList)
boolean sendToWorker(Message message, java.lang.Integer workerID)