You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by ma...@apache.org on 2015/11/10 07:02:31 UTC
incubator-kylin git commit: take care of HBaseStorage
Repository: incubator-kylin
Updated Branches:
refs/heads/KYLIN-1126 933919846 -> 8d0fea49e
take care of HBaseStorage
Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/8d0fea49
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/8d0fea49
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/8d0fea49
Branch: refs/heads/KYLIN-1126
Commit: 8d0fea49e1e8de58c85b228cad82e8a9cafb8cbf
Parents: 9339198
Author: honma <ho...@ebay.com>
Authored: Tue Nov 10 14:07:29 2015 +0800
Committer: honma <ho...@ebay.com>
Committed: Tue Nov 10 14:07:29 2015 +0800
----------------------------------------------------------------------
core-cube/src/main/java/org/apache/kylin/cube/model/CubeDesc.java | 1 +
.../src/main/java/org/apache/kylin/storage/StorageFactory.java | 2 ++
2 files changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/8d0fea49/core-cube/src/main/java/org/apache/kylin/cube/model/CubeDesc.java
----------------------------------------------------------------------
diff --git a/core-cube/src/main/java/org/apache/kylin/cube/model/CubeDesc.java b/core-cube/src/main/java/org/apache/kylin/cube/model/CubeDesc.java
index eced0f2..160090a 100644
--- a/core-cube/src/main/java/org/apache/kylin/cube/model/CubeDesc.java
+++ b/core-cube/src/main/java/org/apache/kylin/cube/model/CubeDesc.java
@@ -135,6 +135,7 @@ public class CubeDesc extends RootPersistentEntity {
private Map<Array<TblColRef>, List<DeriveInfo>> hostToDerivedMap = Maps.newHashMap();
public boolean isEnableSharding() {
+ //in the future may extend to other storage that is shard-able
return storageType == IStorageAware.ID_SHARDED_HBASE;
}
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/8d0fea49/core-storage/src/main/java/org/apache/kylin/storage/StorageFactory.java
----------------------------------------------------------------------
diff --git a/core-storage/src/main/java/org/apache/kylin/storage/StorageFactory.java b/core-storage/src/main/java/org/apache/kylin/storage/StorageFactory.java
index 271583c..da2f69c 100644
--- a/core-storage/src/main/java/org/apache/kylin/storage/StorageFactory.java
+++ b/core-storage/src/main/java/org/apache/kylin/storage/StorageFactory.java
@@ -20,6 +20,7 @@ package org.apache.kylin.storage;
import static org.apache.kylin.metadata.model.IStorageAware.ID_HBASE;
import static org.apache.kylin.metadata.model.IStorageAware.ID_HYBRID;
+import static org.apache.kylin.metadata.model.IStorageAware.ID_SHARDED_HBASE;
import java.util.HashMap;
import java.util.Map;
@@ -36,6 +37,7 @@ public class StorageFactory {
static {
Map<Integer, String> impls = new HashMap<>();
impls.put(ID_HBASE, "org.apache.kylin.storage.hbase.HBaseStorage");
+ impls.put(ID_SHARDED_HBASE, "org.apache.kylin.storage.hbase.HBaseStorage");//ID_SHARDED_HBASE is a special HBaseStorage
impls.put(ID_HYBRID, "org.apache.kylin.storage.hybrid.HybridStorage");
storages = new ImplementationSwitch<IStorage>(impls, IStorage.class);
}