nemo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jeongy...@apache.org
Subject [incubator-nemo] branch 717-TGE updated: added comments
Date Fri, 16 Mar 2018 07:30:55 GMT
This is an automated email from the ASF dual-hosted git repository.

jeongyoon pushed a commit to branch 717-TGE
in repository https://gitbox.apache.org/repos/asf/incubator-nemo.git


The following commit(s) were added to refs/heads/717-TGE by this push:
     new 89049d9  added comments
89049d9 is described below

commit 89049d9e83e67e5780a15e6afc203b51ce1e38f4
Author: Jeongyoon Eo <jeongyoon0807@gmail.com>
AuthorDate: Fri Mar 16 16:30:44 2018 +0900

    added comments
---
 .../executor/datatransfer/TaskDataHandler.java     | 29 ++++++++++++++++++----
 1 file changed, 24 insertions(+), 5 deletions(-)

diff --git a/runtime/executor/src/main/java/edu/snu/nemo/runtime/executor/datatransfer/TaskDataHandler.java
b/runtime/executor/src/main/java/edu/snu/nemo/runtime/executor/datatransfer/TaskDataHandler.java
index 2e5fdae..255fa9e 100644
--- a/runtime/executor/src/main/java/edu/snu/nemo/runtime/executor/datatransfer/TaskDataHandler.java
+++ b/runtime/executor/src/main/java/edu/snu/nemo/runtime/executor/datatransfer/TaskDataHandler.java
@@ -86,40 +86,59 @@ public final class TaskDataHandler {
   }
 
   /**
-   * Get OutputCollector
-   * @return
+   * Get OutputCollector of this task.
+   * @return OutputCollector of this task.
    */
   public OutputCollectorImpl getOutputCollector() {
     return outputCollector;
   }
 
+  /**
+   * Get OutputWriters of this task.
+   * @return OutputWriters of this task.
+   */
   public List<OutputWriter> getOutputWriters() {
     return outputWriters;
   }
 
+  /**
+   * Set a DAG of children tasks' DataHandlers.
+   */
   public void setChildrenDataHandler(final List<TaskDataHandler> childrenDataHandler)
{
     children = childrenDataHandler;
   }
 
-  // Add OutputCollectors of parent tasks.
+  /**
+   * Add OutputCollector of a parent task.
+   */
   public void addInputFromThisStages(final OutputCollectorImpl input) {
     inputFromThisStage.add(input);
   }
 
+  /**
+   * Add InputReader that contains side input from other TaskGroup.
+   */
   public void addSideInputFromOtherStages(final InputReader sideInputReader) {
     sideInputFromOtherStages.add(sideInputReader);
   }
 
+  /**
+   * Add parent OutputCollector that contains side input from the parent task.
+   */
   public void addSideInputFromThisStage(final OutputCollectorImpl ocAsSideInput) {
     sideInputFromThisStage.add(ocAsSideInput);
   }
 
-  // Set OutputCollector of this task.
-  // Mark if the data from this OutputCollector is used as side input.
+  /**
+   * Set OutputCollector of this task.
+   */
   public void setOutputCollector(final OutputCollectorImpl oc) {
     outputCollector = oc;
   }
 
+  /**
+   * Add OutputWriter of this task.
+   */
   public void addOutputWriters(final OutputWriter outputWriter) {
     outputWriters.add(outputWriter);
   }

-- 
To stop receiving notification emails like this one, please contact
jeongyoon@apache.org.

Mime
View raw message