IGNITE-5920: Fixed CacheClientBinaryQueryExample": set CacheKeyConfiguration explicitly to enable affinity co-location. This closes #2389.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/eb336074 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/eb336074 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/eb336074 Branch: refs/heads/ignite-5872 Commit: eb336074c91da2e35aab4ca9f69a5d7191b3701b Parents: 6bdad4d Author: tledkov-gridgain <tled...@gridgain.com> Authored: Fri Aug 4 11:16:52 2017 +0300 Committer: devozerov <voze...@gridgain.com> Committed: Fri Aug 4 11:18:09 2017 +0300 ---------------------------------------------------------------------- .../examples/binary/datagrid/CacheClientBinaryQueryExample.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/eb336074/examples/src/main/java/org/apache/ignite/examples/binary/datagrid/CacheClientBinaryQueryExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/binary/datagrid/CacheClientBinaryQueryExample.java b/examples/src/main/java/org/apache/ignite/examples/binary/datagrid/CacheClientBinaryQueryExample.java index c2d4964..a3c9996 100644 --- a/examples/src/main/java/org/apache/ignite/examples/binary/datagrid/CacheClientBinaryQueryExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/binary/datagrid/CacheClientBinaryQueryExample.java @@ -25,6 +25,7 @@ import javax.cache.Cache; import org.apache.ignite.Ignite; import org.apache.ignite.IgniteCache; import org.apache.ignite.Ignition; +import org.apache.ignite.cache.CacheKeyConfiguration; import org.apache.ignite.cache.CacheMode; import org.apache.ignite.cache.QueryEntity; import org.apache.ignite.cache.QueryIndex; @@ -84,6 +85,8 @@ public class CacheClientBinaryQueryExample { employeeCacheCfg.setQueryEntities(Arrays.asList(createEmployeeQueryEntity())); + employeeCacheCfg.setKeyConfiguration(new CacheKeyConfiguration(EmployeeKey.class)); + try (IgniteCache<Integer, Organization> orgCache = ignite.getOrCreateCache(orgCacheCfg); IgniteCache<EmployeeKey, Employee> employeeCache = ignite.getOrCreateCache(employeeCacheCfg) ) {