From 069c3049f1a500e5ae0b47caeebc5856ab182b73 Mon Sep 17 00:00:00 2001 From: Sorabh Hamirwasia Date: Fri, 29 Jun 2018 10:27:55 -0700 Subject: DRILL-6561: Lateral excluding the columns from output container provided by projection push into rules This closes #1356 --- .../org/apache/drill/exec/physical/impl/join/HashJoinBatch.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/HashJoinBatch.java') 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 { 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); } /** -- cgit v1.2.3