You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@drill.apache.org by ja...@apache.org on 2014/09/12 17:17:12 UTC
[03/37] git commit: DRILL-1392: Include partition columns in star
queries
DRILL-1392: Include partition columns in star queries
Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/00431d2c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/00431d2c
Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/00431d2c
Branch: refs/heads/master
Commit: 00431d2c87040e8f5e79ab09753c20e73b56744e
Parents: caf2329
Author: Steven Phillips <sp...@maprtech.com>
Authored: Tue Sep 9 02:00:56 2014 -0700
Committer: Aditya Kishore <ad...@maprtech.com>
Committed: Thu Sep 11 19:24:08 2014 -0700
----------------------------------------------------------------------
.../org/apache/drill/exec/store/dfs/easy/EasyFormatPlugin.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/00431d2c/exec/java-exec/src/main/java/org/apache/drill/exec/store/dfs/easy/EasyFormatPlugin.java
----------------------------------------------------------------------
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/dfs/easy/EasyFormatPlugin.java b/exec/java-exec/src/main/java/org/apache/drill/exec/store/dfs/easy/EasyFormatPlugin.java
index d1923a5..3669044 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/dfs/easy/EasyFormatPlugin.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/dfs/easy/EasyFormatPlugin.java
@@ -39,6 +39,7 @@ import org.apache.drill.exec.physical.impl.WriterRecordBatch;
import org.apache.drill.exec.proto.UserBitShared.CoreOperatorType;
import org.apache.drill.exec.record.RecordBatch;
import org.apache.drill.exec.server.DrillbitContext;
+import org.apache.drill.exec.store.AbstractRecordReader;
import org.apache.drill.exec.store.RecordReader;
import org.apache.drill.exec.store.RecordWriter;
import org.apache.drill.exec.store.StoragePluginOptimizerRule;
@@ -124,7 +125,7 @@ public abstract class EasyFormatPlugin<T extends FormatPluginConfig> implements
List<Integer> selectedPartitionColumns = Lists.newArrayList();
boolean selectAllColumns = false;
- if (columns == null || columns.size() == 0) {
+ if (AbstractRecordReader.isStarQuery(columns) || columns == null || columns.size() == 0) {
selectAllColumns = true;
} else {
List<SchemaPath> newColumns = Lists.newArrayList();