diff options
author | Sorabh Hamirwasia <shamirwasia@maprtech.com> | 2018-06-29 10:27:55 -0700 |
---|---|---|
committer | Parth Chandra <parthc@apache.org> | 2018-07-02 14:06:38 -0700 |
commit | 069c3049f1a500e5ae0b47caeebc5856ab182b73 (patch) | |
tree | 8c44e7ddb0e9bdf0dadd6ba9a7e400aaaa02cb8a /exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/HashJoinBatch.java | |
parent | 208733b52ec40fd49e6bd424782f7c71aabef7e3 (diff) |
DRILL-6561: Lateral excluding the columns from output container provided by projection push into rules
This closes #1356
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/HashJoinBatch.java')
-rw-r--r-- | exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/HashJoinBatch.java | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/HashJoinBatch.java b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/HashJoinBatch.java index 047c59705..345d18200 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/HashJoinBatch.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/HashJoinBatch.java @@ -19,6 +19,7 @@ package org.apache.drill.exec.physical.impl.join; import java.io.IOException; import java.util.ArrayList; +import java.util.HashSet; import java.util.List; import java.util.Set; @@ -67,9 +68,6 @@ import org.apache.drill.exec.vector.ValueVector; import org.apache.drill.exec.vector.complex.AbstractContainerVector; import org.apache.calcite.rel.core.JoinRelType; -import static org.apache.drill.exec.record.JoinBatchMemoryManager.LEFT_INDEX; -import static org.apache.drill.exec.record.JoinBatchMemoryManager.RIGHT_INDEX; - /** * This class implements the runtime execution for the Hash-Join operator * supporting INNER, LEFT OUTER, RIGHT OUTER, and FULL OUTER joins @@ -892,7 +890,8 @@ public class HashJoinBatch extends AbstractBinaryRecordBatch<HashJoinPOP> { logger.debug("BATCH_STATS, configured output batch size: {}, allocated memory {}, avail mem factor {}, output batch size: {}", configuredBatchSize, allocator.getLimit(), avail_mem_factor, outputBatchSize); - batchMemoryManager = new JoinBatchMemoryManager(outputBatchSize, left, right); + batchMemoryManager = new JoinBatchMemoryManager(outputBatchSize, left, right, new HashSet<>()); + logger.debug("BATCH_STATS, configured output batch size: {}", configuredBatchSize); } /** |