sanha commented on a change in pull request #193: [NEMO-338] SkewSamplingPass
URL: https://github.com/apache/incubator-nemo/pull/193#discussion_r257965344
##########
File path: common/src/main/java/org/apache/nemo/common/ir/IRDAG.java
##########
@@ -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:
[email protected]
With regards,
Apache Git Services
