kylin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From liy...@apache.org
Subject [01/22] kylin git commit: minor, refine GTCubeStorageQueryRequest [Forced Update!]
Date Thu, 13 Apr 2017 10:37:07 GMT
Repository: kylin
Updated Branches:
  refs/heads/master-hbase0.98 de4ddd143 -> ab000ea67 (forced update)


minor, refine GTCubeStorageQueryRequest


Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/d216e223
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/d216e223
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/d216e223

Branch: refs/heads/master-hbase0.98
Commit: d216e223b0d1ef67aaa93aa820a11f04ac69cb2e
Parents: 9250d9b
Author: lidongsjtu <lidong@apache.org>
Authored: Fri Mar 31 22:57:52 2017 +0800
Committer: lidongsjtu <lidong@apache.org>
Committed: Fri Mar 31 22:57:52 2017 +0800

----------------------------------------------------------------------
 .../kylin/storage/gtrecord/GTCubeStorageQueryBase.java  |  2 +-
 .../storage/gtrecord/GTCubeStorageQueryRequest.java     | 12 +++++++++++-
 2 files changed, 12 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kylin/blob/d216e223/core-storage/src/main/java/org/apache/kylin/storage/gtrecord/GTCubeStorageQueryBase.java
----------------------------------------------------------------------
diff --git a/core-storage/src/main/java/org/apache/kylin/storage/gtrecord/GTCubeStorageQueryBase.java
b/core-storage/src/main/java/org/apache/kylin/storage/gtrecord/GTCubeStorageQueryBase.java
index 065fd6e..083080c 100644
--- a/core-storage/src/main/java/org/apache/kylin/storage/gtrecord/GTCubeStorageQueryBase.java
+++ b/core-storage/src/main/java/org/apache/kylin/storage/gtrecord/GTCubeStorageQueryBase.java
@@ -150,7 +150,7 @@ public abstract class GTCubeStorageQueryBase implements IStorageQuery
{
 
         logger.info("Cuboid identified: cube={}, cuboidId={}, groupsD={}, filterD={}, limitPushdown={},
storageAggr={}", cubeInstance.getName(), cuboid.getId(), groupsD, filterColumnD, context.getFinalPushDownLimit(),
context.isNeedStorageAggregation());
 
-        return new GTCubeStorageQueryRequest(cuboid, dimensionsD, groupsD, metrics, filterD,
context);
+        return new GTCubeStorageQueryRequest(cuboid, dimensionsD, groupsD, filterColumnD,
metrics, filterD, context);
     }
 
     protected abstract String getGTStorage();

http://git-wip-us.apache.org/repos/asf/kylin/blob/d216e223/core-storage/src/main/java/org/apache/kylin/storage/gtrecord/GTCubeStorageQueryRequest.java
----------------------------------------------------------------------
diff --git a/core-storage/src/main/java/org/apache/kylin/storage/gtrecord/GTCubeStorageQueryRequest.java
b/core-storage/src/main/java/org/apache/kylin/storage/gtrecord/GTCubeStorageQueryRequest.java
index c4d81d2..68f755c 100644
--- a/core-storage/src/main/java/org/apache/kylin/storage/gtrecord/GTCubeStorageQueryRequest.java
+++ b/core-storage/src/main/java/org/apache/kylin/storage/gtrecord/GTCubeStorageQueryRequest.java
@@ -31,14 +31,16 @@ public class GTCubeStorageQueryRequest implements Serializable {
     private Cuboid cuboid;
     private Set<TblColRef> dimensions;
     private Set<TblColRef> groups;
+    private Set<TblColRef> filterCols;
     private Set<FunctionDesc> metrics;
     private TupleFilter filter;
     private StorageContext context;
 
-    public GTCubeStorageQueryRequest(Cuboid cuboid, Set<TblColRef> dimensions, Set<TblColRef>
groups, Set<FunctionDesc> metrics, TupleFilter filter, StorageContext context) {
+    public GTCubeStorageQueryRequest(Cuboid cuboid, Set<TblColRef> dimensions, Set<TblColRef>
groups, Set<TblColRef> filterCols, Set<FunctionDesc> metrics, TupleFilter filter,
StorageContext context) {
         this.cuboid = cuboid;
         this.dimensions = dimensions;
         this.groups = groups;
+        this.filterCols = filterCols;
         this.metrics = metrics;
         this.filter = filter;
         this.context = context;
@@ -91,4 +93,12 @@ public class GTCubeStorageQueryRequest implements Serializable {
     public void setContext(StorageContext context) {
         this.context = context;
     }
+
+    public Set<TblColRef> getFilterCols() {
+        return filterCols;
+    }
+
+    public void setFilterCols(Set<TblColRef> filterCols) {
+        this.filterCols = filterCols;
+    }
 }


Mime
View raw message