aboutsummaryrefslogtreecommitdiff
path: root/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/JoinUtils.java
diff options
context:
space:
mode:
authorAmit Hadke <amit.hadke@gmail.com>2015-10-07 18:23:21 -0700
committerJacques Nadeau <jacques@apache.org>2015-11-04 20:55:54 -0800
commit2bc16a90b4883b2b2e3213f5e7a46ff1ea78bd98 (patch)
treea74cf223fcd8b9ff117eb24e5b0657f6899ec445 /exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/JoinUtils.java
parent39582bd60c9eaaaa9b16aba4f099d434e927e7e5 (diff)
DRILL-3793: New MergeJoin and add RecordIterator interface
This closes #190
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/JoinUtils.java')
-rw-r--r--exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/JoinUtils.java5
1 files changed, 3 insertions, 2 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/JoinUtils.java b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/JoinUtils.java
index d39df8f17..2476a838a 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/JoinUtils.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/JoinUtils.java
@@ -37,6 +37,7 @@ import org.apache.drill.common.types.TypeProtos;
import org.apache.drill.exec.expr.ExpressionTreeMaterializer;
import org.apache.drill.exec.ops.FragmentContext;
import org.apache.drill.exec.record.RecordBatch;
+import org.apache.drill.exec.record.VectorAccessible;
import org.apache.drill.exec.resolver.TypeCastRules;
import java.util.LinkedList;
@@ -162,8 +163,8 @@ public class JoinUtils {
* @param rightBatch right input record batch
* @param context fragment context
*/
- public static void addLeastRestrictiveCasts(LogicalExpression[] leftExpressions, RecordBatch leftBatch,
- LogicalExpression[] rightExpressions, RecordBatch rightBatch,
+ public static void addLeastRestrictiveCasts(LogicalExpression[] leftExpressions, VectorAccessible leftBatch,
+ LogicalExpression[] rightExpressions, VectorAccessible rightBatch,
FragmentContext context) {
assert rightExpressions.length == leftExpressions.length;