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/06/02 11:17:57 UTC
incubator-kylin git commit: enable clear all cache again
Repository: incubator-kylin
Updated Branches:
refs/heads/0.8.0 4e0d4c318 -> 749b53589
enable clear all cache again
Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/749b5358
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/749b5358
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/749b5358
Branch: refs/heads/0.8.0
Commit: 749b53589e321b8316fdaea5f02a4a7dd47875fb
Parents: 4e0d4c3
Author: honma <ho...@ebay.com>
Authored: Tue Jun 2 17:17:47 2015 +0800
Committer: honma <ho...@ebay.com>
Committed: Tue Jun 2 17:17:47 2015 +0800
----------------------------------------------------------------------
.../org/apache/kylin/common/restclient/Broadcaster.java | 2 +-
.../java/org/apache/kylin/rest/service/CacheService.java | 11 +++++++++++
2 files changed, 12 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/749b5358/common/src/main/java/org/apache/kylin/common/restclient/Broadcaster.java
----------------------------------------------------------------------
diff --git a/common/src/main/java/org/apache/kylin/common/restclient/Broadcaster.java b/common/src/main/java/org/apache/kylin/common/restclient/Broadcaster.java
index 03a0d34..12a716c 100644
--- a/common/src/main/java/org/apache/kylin/common/restclient/Broadcaster.java
+++ b/common/src/main/java/org/apache/kylin/common/restclient/Broadcaster.java
@@ -136,7 +136,7 @@ public class Broadcaster {
}
public enum TYPE {
- CUBE("cube"), CUBE_DESC("cube_desc"), PROJECT("project"), INVERTED_INDEX("inverted_index"), INVERTED_INDEX_DESC("ii_desc"), TABLE("table"), DATA_MODEL("data_model"), HYBRID("hybrid");
+ ALL("all"),CUBE("cube"), CUBE_DESC("cube_desc"), PROJECT("project"), INVERTED_INDEX("inverted_index"), INVERTED_INDEX_DESC("ii_desc"), TABLE("table"), DATA_MODEL("data_model"), HYBRID("hybrid");
private String text;
TYPE(String text) {
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/749b5358/server/src/main/java/org/apache/kylin/rest/service/CacheService.java
----------------------------------------------------------------------
diff --git a/server/src/main/java/org/apache/kylin/rest/service/CacheService.java b/server/src/main/java/org/apache/kylin/rest/service/CacheService.java
index d3480ce..b4a5711 100644
--- a/server/src/main/java/org/apache/kylin/rest/service/CacheService.java
+++ b/server/src/main/java/org/apache/kylin/rest/service/CacheService.java
@@ -25,8 +25,10 @@ import org.apache.kylin.common.restclient.AbstractRestCache;
import org.apache.kylin.common.restclient.Broadcaster;
import org.apache.kylin.cube.CubeDescManager;
import org.apache.kylin.cube.CubeInstance;
+import org.apache.kylin.cube.CubeManager;
import org.apache.kylin.cube.CubeSegment;
import org.apache.kylin.invertedindex.IIDescManager;
+import org.apache.kylin.invertedindex.IIManager;
import org.apache.kylin.job.cube.CubingJob;
import org.apache.kylin.job.cube.CubingJobBuilder;
import org.apache.kylin.job.engine.JobEngineConfig;
@@ -99,6 +101,15 @@ public class CacheService extends BasicService {
IIDescManager.clearCache();
CubeDescManager.clearCache();
break;
+ case ALL:
+ getMetadataManager().reload();
+ CubeDescManager.clearCache();
+ CubeManager.clearCache();
+ IIDescManager.clearCache();
+ IIManager.clearCache();
+ ProjectManager.clearCache();
+ removeAllOLAPDataSources();
+ break;
default:
throw new RuntimeException("invalid cacheType:" + cacheType);
}