You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ag...@apache.org on 2017/08/10 13:53:01 UTC
[04/30] ignite git commit: IGNITE-5920: Fixed
CacheClientBinaryQueryExample": set CacheKeyConfiguration explicitly to
enable affinity co-location. This closes #2389.
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/e8b355f9
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/e8b355f9
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/e8b355f9
Branch: refs/heads/ignite-5872
Commit: e8b355f9d375e6d53a5fc55008a9c38864fba0a8
Parents: 80cc292
Author: tledkov-gridgain <tl...@gridgain.com>
Authored: Fri Aug 4 11:16:52 2017 +0300
Committer: devozerov <vo...@gridgain.com>
Committed: Fri Aug 4 11:16:52 2017 +0300
----------------------------------------------------------------------
.../examples/binary/datagrid/CacheClientBinaryQueryExample.java | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/e8b355f9/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)
) {