diff options
author | Amit Hadke <amit.hadke@gmail.com> | 2015-10-07 18:23:21 -0700 |
---|---|---|
committer | Jacques Nadeau <jacques@apache.org> | 2015-11-04 20:55:54 -0800 |
commit | 2bc16a90b4883b2b2e3213f5e7a46ff1ea78bd98 (patch) | |
tree | a74cf223fcd8b9ff117eb24e5b0657f6899ec445 /exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/JoinUtils.java | |
parent | 39582bd60c9eaaaa9b16aba4f099d434e927e7e5 (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.java | 5 |
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; |