aboutsummaryrefslogtreecommitdiff
path: root/exec/java-exec/src/main/java/org/apache/drill/exec/expr/EvaluationVisitor.java
diff options
context:
space:
mode:
authorHanifi Gunes <hgunes@maprtech.com>2015-03-23 19:38:23 -0700
committerMehant Baid <mehantr@gmail.com>2015-03-30 10:27:02 -0700
commit0fbcddba14405ec94d51b0ba3512925168efb433 (patch)
tree8f7a377dccf05596f9f30fd0ad76a067358a75da /exec/java-exec/src/main/java/org/apache/drill/exec/expr/EvaluationVisitor.java
parent96d51bdedbeab2f95075ca5e40cdc7b65b1c8e99 (diff)
DRILL-2375: implement reader reset mechanism and reset reader before accessing it during projection
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/expr/EvaluationVisitor.java')
-rw-r--r--exec/java-exec/src/main/java/org/apache/drill/exec/expr/EvaluationVisitor.java1
1 files changed, 1 insertions, 0 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/expr/EvaluationVisitor.java b/exec/java-exec/src/main/java/org/apache/drill/exec/expr/EvaluationVisitor.java
index a5758fba9..c20ff1420 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/expr/EvaluationVisitor.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/expr/EvaluationVisitor.java
@@ -373,6 +373,7 @@ public class EvaluationVisitor {
JBlock eval = generator.getEvalBlock().block();
// position to the correct value.
+ eval.add(expr.invoke("reset"));
eval.add(expr.invoke("setPosition").arg(indexVariable));
int listNum = 0;