diff options
author | Jinfeng Ni <jni@apache.org> | 2016-02-12 14:18:59 -0800 |
---|---|---|
committer | Jinfeng Ni <jni@apache.org> | 2016-02-22 11:54:11 -0800 |
commit | c67d070bf68e9492b7fbe6d9e54d70d587b28a6e (patch) | |
tree | 688094a5c2d831582fbcebdeaeb9e19d66602211 /contrib/storage-hbase/src | |
parent | a45f7fd1126cd5110ac959961256ce75923fa2fd (diff) |
DRILL-4387: GroupScan or ScanBatchCreator should not use star column in case of skipAll query.
The skipAll query should be handled in RecordReader.
Diffstat (limited to 'contrib/storage-hbase/src')
-rw-r--r-- | contrib/storage-hbase/src/main/java/org/apache/drill/exec/store/hbase/HBaseGroupScan.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/contrib/storage-hbase/src/main/java/org/apache/drill/exec/store/hbase/HBaseGroupScan.java b/contrib/storage-hbase/src/main/java/org/apache/drill/exec/store/hbase/HBaseGroupScan.java index 1d01635ad..ae243b329 100644 --- a/contrib/storage-hbase/src/main/java/org/apache/drill/exec/store/hbase/HBaseGroupScan.java +++ b/contrib/storage-hbase/src/main/java/org/apache/drill/exec/store/hbase/HBaseGroupScan.java @@ -114,7 +114,7 @@ public class HBaseGroupScan extends AbstractGroupScan implements DrillHBaseConst this.storagePlugin = storagePlugin; this.storagePluginConfig = storagePlugin.getConfig(); this.hbaseScanSpec = scanSpec; - this.columns = columns == null || columns.size() == 0? ALL_COLUMNS : columns; + this.columns = columns == null ? ALL_COLUMNS : columns; init(); } @@ -124,7 +124,7 @@ public class HBaseGroupScan extends AbstractGroupScan implements DrillHBaseConst */ private HBaseGroupScan(HBaseGroupScan that) { super(that); - this.columns = that.columns; + this.columns = that.columns == null ? ALL_COLUMNS : that.columns; this.hbaseScanSpec = that.hbaseScanSpec; this.endpointFragmentMapping = that.endpointFragmentMapping; this.regionsToScan = that.regionsToScan; @@ -139,7 +139,7 @@ public class HBaseGroupScan extends AbstractGroupScan implements DrillHBaseConst @Override public GroupScan clone(List<SchemaPath> columns) { HBaseGroupScan newScan = new HBaseGroupScan(this); - newScan.columns = columns; + newScan.columns = columns == null ? ALL_COLUMNS : columns;; newScan.verifyColumns(); return newScan; } |