You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by li...@apache.org on 2016/12/07 04:32:18 UTC
[19/50] [abbrv] kylin git commit: KYLIN-2180 minor,
get owenr project in CubeDesc.init()
KYLIN-2180 minor, get owenr project in CubeDesc.init()
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/9fc8f5e2
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/9fc8f5e2
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/9fc8f5e2
Branch: refs/heads/master-cdh5.7
Commit: 9fc8f5e207b5111fffaec3335efe0c8947353cfa
Parents: 1a5295b
Author: Li Yang <li...@apache.org>
Authored: Fri Dec 2 11:39:34 2016 +0800
Committer: Li Yang <li...@apache.org>
Committed: Fri Dec 2 11:39:34 2016 +0800
----------------------------------------------------------------------
.../main/java/org/apache/kylin/cube/model/CubeDesc.java | 11 ++++++++++-
1 file changed, 10 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/9fc8f5e2/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 327ce57..853571c 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
@@ -64,6 +64,9 @@ import org.apache.kylin.metadata.model.IStorageAware;
import org.apache.kylin.metadata.model.JoinDesc;
import org.apache.kylin.metadata.model.MeasureDesc;
import org.apache.kylin.metadata.model.TblColRef;
+import org.apache.kylin.metadata.project.ProjectInstance;
+import org.apache.kylin.metadata.project.ProjectManager;
+import org.apache.kylin.metadata.realization.RealizationType;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -519,11 +522,16 @@ public class CubeDesc extends RootPersistentEntity implements IEngineAware {
public void init(KylinConfig config) {
this.errors.clear();
- this.config = KylinConfigExt.createInstance(config, overrideKylinProps);
checkArgument(StringUtils.isNotBlank(name), "CubeDesc name is blank");
checkArgument(StringUtils.isNotBlank(modelName), "CubeDesc(%s) has blank modelName", name);
+ // note CubeDesc.name == CubeInstance.name
+ List<ProjectInstance> ownerPrj = ProjectManager.getInstance(config).findProjects(RealizationType.CUBE, name);
+ logger.info("CubeDesc '" + name + "' is owned by " + ownerPrj);
+
+ this.config = KylinConfigExt.createInstance(config, overrideKylinProps);
+
this.model = MetadataManager.getInstance(config).getDataModelDesc(modelName);
checkNotNull(this.model, "DateModelDesc(%s) not found", modelName);
@@ -823,6 +831,7 @@ public class CubeDesc extends RootPersistentEntity implements IEngineAware {
return col;
}
+ @SuppressWarnings("deprecation")
private void initMeasureColumns() {
if (measures == null || measures.isEmpty()) {
return;