nemo-notifications mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From GitBox <>
Subject [GitHub] sanha commented on a change in pull request #193: [NEMO-338] SkewSamplingPass
Date Tue, 19 Feb 2019 10:29:22 GMT
sanha commented on a change in pull request #193: [NEMO-338] SkewSamplingPass

 File path: common/src/main/java/org/apache/nemo/common/ir/
 @@ -151,73 +176,153 @@ public void insert(final StreamVertex streamVertex, final IREdge edgeToStreamize
    *        shuffleEdge - messageAggregatorVertex - broadcastEdge - dst
    * (the "Before" relationships are unmodified)
+   * This preserves semantics as the results of the inserted message vertices are never consumed
by the original IRDAG.
+   *
    * @param messageBarrierVertex to insert.
    * @param messageAggregatorVertex to insert.
    * @param mbvOutputEncoder to use.
    * @param mbvOutputDecoder to use.
    * @param edgesToGetStatisticsOf to examine.
+   * @param edgesToOptimize to optimize.
   public void insert(final MessageBarrierVertex messageBarrierVertex,
 Review comment:
   The inner `BiFunction` (`messageFunction`) of the `messageBarrierVertex` is only used in
this method.
   Why don't we receive the `BiFunction` instead of `MessageBarrierVertex`?

This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:

With regards,
Apache Git Services

View raw message