Restored backward compatibility for cache objects
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/38b3ffda Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/38b3ffda Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/38b3ffda Branch: refs/heads/ignite-884 Commit: 38b3ffdaf2944cb908c45e22e3a1b1b834cf3b6c Parents: 2938a9b Author: Valentin Kulichenko <valentin.kuliche...@gmail.com> Authored: Wed Aug 26 15:39:12 2015 -0700 Committer: Valentin Kulichenko <valentin.kuliche...@gmail.com> Committed: Wed Aug 26 15:39:12 2015 -0700 ---------------------------------------------------------------------- .../processors/cacheobject/IgniteCacheObjectProcessor.java | 2 +- .../processors/cacheobject/IgniteCacheObjectProcessorImpl.java | 2 +- .../ignite/internal/processors/query/GridQueryProcessor.java | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/38b3ffda/modules/core/src/main/java/org/apache/ignite/internal/processors/cacheobject/IgniteCacheObjectProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cacheobject/IgniteCacheObjectProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cacheobject/IgniteCacheObjectProcessor.java index dc0d1e5..b9b6132 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cacheobject/IgniteCacheObjectProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cacheobject/IgniteCacheObjectProcessor.java @@ -78,7 +78,7 @@ public interface IgniteCacheObjectProcessor extends GridProcessor { * * @return {@code true} If portable objects are enabled. */ - public boolean isPortableEnabled(); + public boolean isPortableEnabled(CacheConfiguration<?, ?> ccfg); /** * @param obj Portable object to get field from. http://git-wip-us.apache.org/repos/asf/ignite/blob/38b3ffda/modules/core/src/main/java/org/apache/ignite/internal/processors/cacheobject/IgniteCacheObjectProcessorImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cacheobject/IgniteCacheObjectProcessorImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cacheobject/IgniteCacheObjectProcessorImpl.java index 3e59b10..e8f7781 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cacheobject/IgniteCacheObjectProcessorImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cacheobject/IgniteCacheObjectProcessorImpl.java @@ -233,7 +233,7 @@ public class IgniteCacheObjectProcessorImpl extends GridProcessorAdapter impleme } /** {@inheritDoc} */ - @Override public boolean isPortableEnabled() { + @Override public boolean isPortableEnabled(CacheConfiguration<?, ?> ccfg) { return false; } http://git-wip-us.apache.org/repos/asf/ignite/blob/38b3ffda/modules/core/src/main/java/org/apache/ignite/internal/processors/query/GridQueryProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/GridQueryProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/GridQueryProcessor.java index f3ad4b2..c8b8166 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/GridQueryProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/GridQueryProcessor.java @@ -140,7 +140,7 @@ public class GridQueryProcessor extends GridProcessorAdapter { TypeId typeId; - if (valCls == null || ctx.cacheObjects().isPortableEnabled()) { + if (valCls == null || ctx.cacheObjects().isPortableEnabled(ccfg)) { processPortableMeta(meta, desc); typeId = new TypeId(ccfg.getName(), ctx.cacheObjects().typeId(meta.getValueType()));