Package org.apache.giraph.comm.requests

Examples of org.apache.giraph.comm.requests.SendWorkerToWorkerMessageRequest.doRequest()


   */
  public void sendMessageToWorker(Writable message, int workerIndex) {
    SendWorkerToWorkerMessageRequest request =
        new SendWorkerToWorkerMessageRequest(message);
    if (workerIndex == myWorkerIndex) {
      request.doRequest(serviceWorker.getServerData());
    } else {
      serviceWorker.getWorkerClient().sendWritableRequest(
          workerList.get(workerIndex).getTaskId(), request);
    }
  }
View Full Code Here

TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.