ignite-1.5 Added CacheConfiguration.storeKeepBinary flag support in Visor.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/c5ed0d0e Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/c5ed0d0e Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/c5ed0d0e Branch: refs/heads/master Commit: c5ed0d0e23329b8badb594e6f625eb58a24e2392 Parents: d8576b8 Author: Alexey Kuznetsov <akuznet...@apache.org> Authored: Tue Dec 22 14:14:43 2015 +0700 Committer: Alexey Kuznetsov <akuznet...@apache.org> Committed: Tue Dec 22 14:14:43 2015 +0700 ---------------------------------------------------------------------- .../visor/cache/VisorCacheStoreConfiguration.java | 13 ++++++++++++- .../visor/commands/cache/VisorCacheCommand.scala | 1 + 2 files changed, 13 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/c5ed0d0e/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheStoreConfiguration.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheStoreConfiguration.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheStoreConfiguration.java index f2d5961..38a419a 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheStoreConfiguration.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheStoreConfiguration.java @@ -65,6 +65,9 @@ public class VisorCacheStoreConfiguration implements Serializable { /** Number of threads that will perform cache flushing. */ private int flushThreadCnt; + /** Keep binary in store flag. */ + private boolean storeKeepBinary; + /** * @param ignite Ignite instance. * @param ccfg Cache configuration. @@ -81,6 +84,7 @@ public class VisorCacheStoreConfiguration implements Serializable { cfg.store = compactClass(store); cfg.storeFactory = compactClass(ccfg.getCacheStoreFactory()); + cfg.storeKeepBinary = ccfg.isStoreKeepBinary(); cfg.readThrough = ccfg.isReadThrough(); cfg.writeThrough = ccfg.isWriteThrough(); @@ -123,6 +127,13 @@ public class VisorCacheStoreConfiguration implements Serializable { } /** + * @return Keep binary in store flag. + */ + public boolean storeKeepBinary() { + return storeKeepBinary; + } + + /** * @return Whether cache should operate in read-through mode. */ public boolean readThrough() { @@ -175,4 +186,4 @@ public class VisorCacheStoreConfiguration implements Serializable { @Override public String toString() { return S.toString(VisorCacheStoreConfiguration.class, this); } -} \ No newline at end of file +} http://git-wip-us.apache.org/repos/asf/ignite/blob/c5ed0d0e/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/cache/VisorCacheCommand.scala ---------------------------------------------------------------------- diff --git a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/cache/VisorCacheCommand.scala b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/cache/VisorCacheCommand.scala index 0d8d036..57f7066 100644 --- a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/cache/VisorCacheCommand.scala +++ b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/cache/VisorCacheCommand.scala @@ -866,6 +866,7 @@ object VisorCacheCommand { cacheT += ("Store Enabled", bool2Str(storeCfg.enabled())) cacheT += ("Store Class", safe(storeCfg.store())) cacheT += ("Store Factory Class", storeCfg.storeFactory()) + cacheT += ("Store Keep Binary", storeCfg.storeKeepBinary()) cacheT += ("Store Read Through", bool2Str(storeCfg.readThrough())) cacheT += ("Store Write Through", bool2Str(storeCfg.writeThrough()))
