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 <[email protected]> Authored: Tue Sep 9 02:00:56 2014 -0700 Committer: Aditya Kishore <[email protected]> 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();
