abdullah alamoudi has submitted this change and it was merged. Change subject: Add Another Signature to Send Messages to CC ......................................................................
Add Another Signature to Send Messages to CC The existing interface to send messages from NC to CC expects a byte[]. The new method takes a Serializable and serialize it. Change-Id: I0ec4e0898c341723f29af32043cec8c042377ed9 Reviewed-on: https://asterix-gerrit.ics.uci.edu/727 Tested-by: Jenkins <[email protected]> Reviewed-by: Murtadha Hubail <[email protected]> --- M hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/context/IHyracksTaskContext.java M hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/Task.java M hyracks/hyracks-test-support/src/main/java/org/apache/hyracks/test/support/TestTaskContext.java 3 files changed, 15 insertions(+), 0 deletions(-) Approvals: Murtadha Hubail: Looks good to me, approved Jenkins: Verified diff --git a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/context/IHyracksTaskContext.java b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/context/IHyracksTaskContext.java index 3076a32..58adccb 100644 --- a/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/context/IHyracksTaskContext.java +++ b/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/context/IHyracksTaskContext.java @@ -18,6 +18,7 @@ */ package org.apache.hyracks.api.context; +import java.io.Serializable; import java.util.concurrent.ExecutorService; import org.apache.hyracks.api.dataflow.TaskAttemptId; @@ -45,4 +46,6 @@ public void setSharedObject(Object sharedObject); public Object getSharedObject(); + + public void sendApplicationMessageToCC(Serializable message, DeploymentId deploymentId) throws Exception; } diff --git a/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/Task.java b/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/Task.java index 7855945..134154c 100644 --- a/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/Task.java +++ b/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/Task.java @@ -18,6 +18,7 @@ */ package org.apache.hyracks.control.nc; +import java.io.Serializable; import java.nio.ByteBuffer; import java.util.ArrayList; import java.util.HashMap; @@ -51,6 +52,7 @@ import org.apache.hyracks.api.job.profiling.counters.ICounterContext; import org.apache.hyracks.api.partitions.PartitionId; import org.apache.hyracks.api.resources.IDeallocatable; +import org.apache.hyracks.api.util.JavaSerializationUtils; import org.apache.hyracks.control.common.job.PartitionState; import org.apache.hyracks.control.common.job.profiling.counters.Counter; import org.apache.hyracks.control.common.job.profiling.om.PartitionProfile; @@ -387,6 +389,11 @@ } @Override + public void sendApplicationMessageToCC(Serializable message, DeploymentId deploymentId) throws Exception { + this.ncs.sendApplicationMessageToCC(JavaSerializationUtils.serialize(message), deploymentId); + } + + @Override public void setSharedObject(Object sharedObject) { this.sharedObject = sharedObject; } diff --git a/hyracks/hyracks-test-support/src/main/java/org/apache/hyracks/test/support/TestTaskContext.java b/hyracks/hyracks-test-support/src/main/java/org/apache/hyracks/test/support/TestTaskContext.java index f796812..ee2bff5 100644 --- a/hyracks/hyracks-test-support/src/main/java/org/apache/hyracks/test/support/TestTaskContext.java +++ b/hyracks/hyracks-test-support/src/main/java/org/apache/hyracks/test/support/TestTaskContext.java @@ -18,6 +18,7 @@ */ package org.apache.hyracks.test.support; +import java.io.Serializable; import java.nio.ByteBuffer; import java.util.HashMap; import java.util.Map; @@ -138,6 +139,10 @@ } @Override + public void sendApplicationMessageToCC(Serializable message, DeploymentId deploymentId) throws Exception { + } + + @Override public ExecutorService getExecutorService() { return null; } -- To view, visit https://asterix-gerrit.ics.uci.edu/727 To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings Gerrit-MessageType: merged Gerrit-Change-Id: I0ec4e0898c341723f29af32043cec8c042377ed9 Gerrit-PatchSet: 2 Gerrit-Project: hyracks Gerrit-Branch: master Gerrit-Owner: abdullah alamoudi <[email protected]> Gerrit-Reviewer: Jenkins <[email protected]> Gerrit-Reviewer: Murtadha Hubail <[email protected]> Gerrit-Reviewer: abdullah alamoudi <[email protected]>
