Github user vrozov commented on a diff in the pull request:
https://github.com/apache/drill/pull/1110#discussion_r167626024
--- Diff:
exec/java-exec/src/main/java/org/apache/drill/exec/planner/physical/ExchangePrel.java
---
@@ -34,4 +37,14 @@ public ExchangePrel(RelOptCluster cluster, RelTraitSet
traits, RelNode child) {
return logicalVisitor.visitExchange(this, value);
}
+ /**
+ * The derived classes can override this method to create relevant mux
exchanges.
+ * If this method is not overrided the default behaviour is to clone
itself.
+ * @param child input to the new muxPrel or new Exchange node.
+ * @param options options manager to check if mux is enabled.
+ */
+ public Prel getMuxPrel(Prel child, OptionManager options) {
--- End diff --
Consider renaming to `constructMuxPrel`.
---
