aboutsummaryrefslogtreecommitdiff
path: root/contrib/storage-hbase/src
diff options
context:
space:
mode:
authorJinfeng Ni <jni@apache.org>2016-02-12 14:18:59 -0800
committerJinfeng Ni <jni@apache.org>2016-02-22 11:54:11 -0800
commitc67d070bf68e9492b7fbe6d9e54d70d587b28a6e (patch)
tree688094a5c2d831582fbcebdeaeb9e19d66602211 /contrib/storage-hbase/src
parenta45f7fd1126cd5110ac959961256ce75923fa2fd (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.java6
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;
}