Enable sv2 support for project operator. Currently, this will do copies for all vectors if their is incoming sv2.
Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/b879e42b Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/b879e42b Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/b879e42b Branch: refs/heads/master Commit: b879e42b7fc6947be59969dac8022844847e564e Parents: e036515 Author: Steven Phillips <sphill...@maprtech.com> Authored: Thu May 15 12:13:32 2014 -0700 Committer: Steven Phillips <sphill...@maprtech.com> Committed: Thu May 15 15:13:11 2014 -0700 ---------------------------------------------------------------------- .../drill/exec/physical/impl/project/ProjectRecordBatch.java | 2 +- .../java/org/apache/drill/exec/planner/physical/ProjectPrel.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/b879e42b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/project/ProjectRecordBatch.java ---------------------------------------------------------------------- diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/project/ProjectRecordBatch.java b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/project/ProjectRecordBatch.java index b94f403..fe19797 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/project/ProjectRecordBatch.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/project/ProjectRecordBatch.java @@ -234,7 +234,7 @@ public class ProjectRecordBatch extends AbstractSingleRecordBatch<Project>{ cg.rotateBlock(); cg.getEvalBlock()._return(JExpr.TRUE); - container.buildSchema(incoming.getSchema().getSelectionVectorMode()); + container.buildSchema(SelectionVectorMode.NONE); try { this.projector = context.getImplementationClass(cg.getCodeGenerator()); http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/b879e42b/exec/java-exec/src/main/java/org/apache/drill/exec/planner/physical/ProjectPrel.java ---------------------------------------------------------------------- diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/planner/physical/ProjectPrel.java b/exec/java-exec/src/main/java/org/apache/drill/exec/planner/physical/ProjectPrel.java index f76251f..1aa34d3 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/planner/physical/ProjectPrel.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/planner/physical/ProjectPrel.java @@ -73,7 +73,7 @@ public class ProjectPrel extends DrillProjectRelBase implements Prel{ @Override public SelectionVectorMode[] getSupportedEncodings() { - return SelectionVectorMode.DEFAULT; + return SelectionVectorMode.NONE_AND_TWO; } @Override
