Github user asfgit closed the pull request at:
https://github.com/apache/drill/pull/1110
---
Github user HanumathRao commented on a diff in the pull request:
https://github.com/apache/drill/pull/1110#discussion_r168338663
--- Diff:
exec/java-exec/src/main/java/org/apache/drill/exec/planner/physical/SingleMergeExchangePrel.java
---
@@ -93,6 +94,21 @@ public
Github user amansinha100 commented on a diff in the pull request:
https://github.com/apache/drill/pull/1110#discussion_r168044397
--- Diff:
exec/java-exec/src/main/java/org/apache/drill/exec/planner/physical/SingleMergeExchangePrel.java
---
@@ -93,6 +94,21 @@ public
Github user HanumathRao commented on a diff in the pull request:
https://github.com/apache/drill/pull/1110#discussion_r168021043
--- Diff:
exec/java-exec/src/main/java/org/apache/drill/exec/physical/config/AbstractMuxExchange.java
---
@@ -92,24 +92,19 @@ public Sender
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/drill/pull/1110#discussion_r167988964
--- Diff:
exec/java-exec/src/main/java/org/apache/drill/exec/physical/config/AbstractMuxExchange.java
---
@@ -92,24 +92,19 @@ public Sender getSender(int
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/drill/pull/1110#discussion_r167960149
--- Diff:
exec/java-exec/src/main/java/org/apache/drill/exec/physical/config/UnorderedMuxExchange.java
---
@@ -37,14 +37,8 @@ public
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/drill/pull/1110#discussion_r167954543
--- Diff:
exec/java-exec/src/main/java/org/apache/drill/exec/physical/config/UnorderedMuxExchange.java
---
@@ -37,14 +37,8 @@ public
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/drill/pull/1110#discussion_r167953826
--- Diff:
exec/java-exec/src/main/java/org/apache/drill/exec/physical/config/AbstractMuxExchange.java
---
@@ -90,6 +92,24 @@ public Sender getSender(int
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/drill/pull/1110#discussion_r167956002
--- Diff:
exec/java-exec/src/main/java/org/apache/drill/exec/planner/physical/visitor/InsertLocalExchangeVisitor.java
---
@@ -20,133 +20,41 @@
import
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/drill/pull/1110#discussion_r167586208
--- Diff:
exec/java-exec/src/main/java/org/apache/drill/exec/physical/base/AbstractExchange.java
---
@@ -119,7 +119,7 @@ public final void
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/drill/pull/1110#discussion_r167625240
--- Diff:
exec/java-exec/src/main/java/org/apache/drill/exec/physical/config/OrderedMuxExchange.java
---
@@ -0,0 +1,64 @@
+/**
+ * Licensed to the
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/drill/pull/1110#discussion_r167587159
--- Diff:
exec/java-exec/src/main/java/org/apache/drill/exec/physical/config/OrderedMuxExchange.java
---
@@ -0,0 +1,64 @@
+/**
+ * Licensed to the
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/drill/pull/1110#discussion_r167616026
--- Diff:
exec/java-exec/src/main/java/org/apache/drill/exec/physical/config/OrderedMuxExchange.java
---
@@ -0,0 +1,64 @@
+/**
+ * Licensed to the
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/drill/pull/1110#discussion_r167589289
--- Diff:
exec/java-exec/src/main/java/org/apache/drill/exec/planner/physical/HashToRandomExchangePrel.java
---
@@ -112,6 +120,73 @@ public RelWriter
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
Github user amansinha100 commented on a diff in the pull request:
https://github.com/apache/drill/pull/1110#discussion_r167447863
--- Diff:
exec/java-exec/src/test/java/org/apache/drill/exec/physical/impl/TestOrderedMuxExchange.java
---
@@ -0,0 +1,116 @@
+/**
+ * Licensed
Github user amansinha100 commented on a diff in the pull request:
https://github.com/apache/drill/pull/1110#discussion_r167447232
--- Diff:
exec/java-exec/src/main/java/org/apache/drill/exec/planner/physical/visitor/InsertLocalExchangeVisitor.java
---
@@ -20,133 +20,34 @@
Github user amansinha100 commented on a diff in the pull request:
https://github.com/apache/drill/pull/1110#discussion_r167448218
--- Diff:
exec/java-exec/src/main/java/org/apache/drill/exec/physical/config/OrderedMuxExchange.java
---
@@ -0,0 +1,64 @@
+/**
+ * Licensed to
Github user amansinha100 commented on a diff in the pull request:
https://github.com/apache/drill/pull/1110#discussion_r167448543
--- Diff:
exec/java-exec/src/test/java/org/apache/drill/exec/physical/impl/TestOrderedMuxExchange.java
---
@@ -0,0 +1,116 @@
+/**
+ * Licensed
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/drill/pull/1110#discussion_r167092037
--- Diff:
exec/java-exec/src/test/java/org/apache/drill/exec/physical/impl/xsort/TestSortSpillWithException.java
---
@@ -59,6 +59,7 @@ public static void
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/drill/pull/1110#discussion_r167089878
--- Diff:
exec/java-exec/src/main/java/org/apache/drill/exec/physical/base/PhysicalVisitor.java
---
@@ -55,10 +56,10 @@
public RETURN
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/drill/pull/1110#discussion_r167088606
--- Diff:
exec/java-exec/src/main/java/org/apache/drill/exec/planner/physical/visitor/PrelVisitor.java
---
@@ -35,7 +38,9 @@
public RETURN
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/drill/pull/1110#discussion_r167091413
--- Diff:
exec/java-exec/src/main/java/org/apache/drill/exec/physical/config/OrderedMuxExchange.java
---
@@ -0,0 +1,58 @@
+/**
+ * Licensed to the
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/drill/pull/1110#discussion_r167090991
--- Diff:
exec/java-exec/src/main/java/org/apache/drill/exec/physical/config/OrderedMuxExchange.java
---
@@ -0,0 +1,58 @@
+/**
+ * Licensed to the
GitHub user HanumathRao opened a pull request:
https://github.com/apache/drill/pull/1110
DRILL-6115: SingleMergeExchange is not scaling up when many minor fraâ¦
â¦gments are allocated for a query.
Currently a singlemerge exchange is merging all the fragment streams on
25 matches
Mail list logo
