[关闭]
@aloxc 2017-12-05T06:37:18.000000Z 字数 24097 阅读 501

ignite中部署模式配置调整对官方的测试类CacheQueryExample.java的影响

ignite

如题，使用官方的示例代码来测试ignite的时候，如果不配置部署模式deploymentMode，也就是默认的配置SHARED，测试该类，一切正常，当调整为PRIVATE的时候（服务器端的配置同步调整为PRIVATE），如下

  1. <property name="deploymentMode" value="PRIVATE"/>

第二天补充下

部署模式测试了一下几种都会发生这个异常

  • PRIVATE
  • ISOLATED

而SHARED和CONTINUOUS没问题，难道是bug还是？

这时候执行该类，会发生异常，异常堆栈如下：

  1. Exception in thread "main" javax.cache.CacheException: class org.apache.ignite.IgniteCheckedException: Query execution failed: GridCacheQueryBean [qry=GridCacheQueryAdapter [type=SCAN, clsName=null, clause=null, filter=com.github.aloxc.ignite.datagrid.CacheQueryExample$1@10c8f62, part=null, incMeta=false, metrics=GridCacheQueryMetricsAdapter [minTime=0, maxTime=0, sumTime=0, avgTime=0.0, execs=0, completed=0, fails=0], pageSize=1024, timeout=0, keepAll=true, incBackups=false, dedup=false, prj=null, keepBinary=true, subjId=9d99e4dc-7040-4670-a190-4bdb10f92dcf, taskHash=0], rdc=null, trans=null]
  2. 	at org.apache.ignite.internal.processors.cache.GridCacheUtils.convertToCacheException(GridCacheUtils.java:1502)
  3. 	at org.apache.ignite.internal.processors.cache.query.GridCacheQueryFutureAdapter.next(GridCacheQueryFutureAdapter.java:176)
  4. 	at org.apache.ignite.internal.processors.cache.query.GridCacheDistributedQueryManager$5.onHasNext(GridCacheDistributedQueryManager.java:634)
  5.     at org.apache.ignite.internal.util.GridCloseableIteratorAdapter.hasNextX(GridCloseableIteratorAdapter.java:53)
  6.     at org.apache.ignite.internal.processors.cache.IgniteCacheProxy$2$1.onHasNext(IgniteCacheProxy.java:501)
  7.     at org.apache.ignite.internal.util.GridCloseableIteratorAdapter.hasNextX(GridCloseableIteratorAdapter.java:53)
  8.     at org.apache.ignite.internal.util.lang.GridIteratorAdapter.hasNext(GridIteratorAdapter.java:45)
  9.     at org.apache.ignite.internal.processors.cache.QueryCursorImpl.getAll(QueryCursorImpl.java:73)
  10.     at com.github.aloxc.ignite.datagrid.CacheQueryExample.scanQueryx(CacheQueryExample.java:177)
  11.     at com.github.aloxc.ignite.datagrid.CacheQueryExample.main(CacheQueryExample.java:111)
  12.     at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  13.     at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  14.     at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  15.     at java.lang.reflect.Method.invoke(Method.java:498)
  16.     at com.intellij.rt.execution.application.AppMain.main(AppMain.java:144)
  17. Caused by: class org.apache.ignite.IgniteCheckedException: Query execution failed: GridCacheQueryBean [qry=GridCacheQueryAdapter [type=SCAN, clsName=null, clause=null, filter=com.github.aloxc.ignite.datagrid.CacheQueryExample$1@10c8f62, part=null, incMeta=false, metrics=GridCacheQueryMetricsAdapter [minTime=0, maxTime=0, sumTime=0, avgTime=0.0, execs=0, completed=0, fails=0], pageSize=1024, timeout=0, keepAll=true, incBackups=false, dedup=false, prj=null, keepBinary=true, subjId=9d99e4dc-7040-4670-a190-4bdb10f92dcf, taskHash=0], rdc=null, trans=null]
  18. 	at org.apache.ignite.internal.processors.cache.query.GridCacheQueryFutureAdapter.checkError(GridCacheQueryFutureAdapter.java:262)
  19. 	at org.apache.ignite.internal.processors.cache.query.GridCacheQueryFutureAdapter.internalIterator(GridCacheQueryFutureAdapter.java:320)
  20. 	at org.apache.ignite.internal.processors.cache.query.GridCacheQueryFutureAdapter.next(GridCacheQueryFutureAdapter.java:166)
  21. 	... 13 more
  22. Caused by: class org.apache.ignite.IgniteCheckedException: Failed to execute query on node [query=GridCacheQueryBean [qry=GridCacheQueryAdapter [type=SCAN, clsName=null, clause=null, filter=com.github.aloxc.ignite.datagrid.CacheQueryExample$1@10c8f62, part=null, incMeta=false, metrics=GridCacheQueryMetricsAdapter [minTime=0, maxTime=0, sumTime=0, avgTime=0.0, execs=0, completed=0, fails=0], pageSize=1024, timeout=0, keepAll=true, incBackups=false, dedup=false, prj=null, keepBinary=true, subjId=9d99e4dc-7040-4670-a190-4bdb10f92dcf, taskHash=0], rdc=null, trans=null], nodeId=a71b03a7-311c-41d6-9b9d-e381adfca013]
  23.     at org.apache.ignite.internal.processors.cache.query.GridCacheQueryFutureAdapter.onPage(GridCacheQueryFutureAdapter.java:385)
  24.     at org.apache.ignite.internal.processors.cache.query.GridCacheDistributedQueryManager.processQueryResponse(GridCacheDistributedQueryManager.java:398)
  25.     at org.apache.ignite.internal.processors.cache.query.GridCacheDistributedQueryManager.access$000(GridCacheDistributedQueryManager.java:63)
  26. 	at org.apache.ignite.internal.processors.cache.query.GridCacheDistributedQueryManager$1.apply(GridCacheDistributedQueryManager.java:93)
  27.     at org.apache.ignite.internal.processors.cache.query.GridCacheDistributedQueryManager$1.apply(GridCacheDistributedQueryManager.java:91)
  28. 	at org.apache.ignite.internal.processors.cache.GridCacheIoManager.processMessage(GridCacheIoManager.java:748)
  29. 	at org.apache.ignite.internal.processors.cache.GridCacheIoManager.onMessage0(GridCacheIoManager.java:353)
  30. 	at org.apache.ignite.internal.processors.cache.GridCacheIoManager.access$400(GridCacheIoManager.java:88)
  31.     at org.apache.ignite.internal.processors.cache.GridCacheIoManager$OrderedMessageListener.onMessage(GridCacheIoManager.java:1262)
  32. 	at org.apache.ignite.internal.managers.communication.GridIoManager.invokeListener(GridIoManager.java:1238)
  33. 	at org.apache.ignite.internal.managers.communication.GridIoManager.access$1600(GridIoManager.java:106)
  34.     at org.apache.ignite.internal.managers.communication.GridIoManager$GridCommunicationMessageSet.unwind(GridIoManager.java:2488)
  35. 	at org.apache.ignite.internal.managers.communication.GridIoManager.unwindMessageSet(GridIoManager.java:1198)
  36. 	at org.apache.ignite.internal.managers.communication.GridIoManager.access$1900(GridIoManager.java:106)
  37.     at org.apache.ignite.internal.managers.communication.GridIoManager$6.run(GridIoManager.java:1167)
  38. 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
  39. 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
  40.     at java.lang.Thread.run(Thread.java:745)
  41. Caused by: class org.apache.ignite.IgniteCheckedException: com.github.aloxc.ignite.datagrid.CacheQueryExample$1
  42. 	at org.apache.ignite.internal.processors.cache.GridCacheIoManager.unmarshall(GridCacheIoManager.java:1221)
  43. 	at org.apache.ignite.internal.processors.cache.GridCacheIoManager.onMessage0(GridCacheIoManager.java:348)
  44. 	at org.apache.ignite.internal.processors.cache.GridCacheIoManager.handleMessage(GridCacheIoManager.java:277)
  45. 	at org.apache.ignite.internal.processors.cache.GridCacheIoManager.access$000(GridCacheIoManager.java:88)
  46.     at org.apache.ignite.internal.processors.cache.GridCacheIoManager$1.onMessage(GridCacheIoManager.java:231)
  47. 	at org.apache.ignite.internal.managers.communication.GridIoManager.invokeListener(GridIoManager.java:1238)
  48. 	at org.apache.ignite.internal.managers.communication.GridIoManager.processRegularMessage0(GridIoManager.java:866)
  49. 	at org.apache.ignite.internal.managers.communication.GridIoManager.access$1700(GridIoManager.java:106)
  50.     at org.apache.ignite.internal.managers.communication.GridIoManager$5.run(GridIoManager.java:829)
  51. 	... 3 more
  52. Caused by: class org.apache.ignite.binary.BinaryInvalidTypeException: com.github.aloxc.ignite.datagrid.CacheQueryExample$1
  53.     at org.apache.ignite.internal.binary.BinaryContext.descriptorForTypeId(BinaryContext.java:671)
  54.     at org.apache.ignite.internal.binary.BinaryContext.descriptorForTypeId(BinaryContext.java:668)
  55.     at org.apache.ignite.internal.binary.BinaryReaderExImpl.deserialize(BinaryReaderExImpl.java:1474)
  56.     at org.apache.ignite.internal.binary.GridBinaryMarshaller.deserialize(GridBinaryMarshaller.java:298)
  57.     at org.apache.ignite.internal.binary.BinaryMarshaller.unmarshal(BinaryMarshaller.java:109)
  58.     at org.apache.ignite.internal.processors.cache.query.GridCacheQueryRequest.finishUnmarshal(GridCacheQueryRequest.java:322)
  59.     at org.apache.ignite.internal.processors.cache.GridCacheIoManager.unmarshall(GridCacheIoManager.java:1215)
  60.     ... 11 more
  61. Caused by: java.lang.ClassNotFoundException: com.github.aloxc.ignite.datagrid.CacheQueryExample$1
  62. 	at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
  63. 	at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
  64. 	at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:331)
  65.     at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
  66.     at java.lang.Class.forName0(Native Method)
  67.     at java.lang.Class.forName(Class.java:348)
  68.     at org.apache.ignite.internal.util.IgniteUtils.forName(IgniteUtils.java:8350)
  69.     at org.apache.ignite.internal.MarshallerContextAdapter.getClass(MarshallerContextAdapter.java:185)
  70.     at org.apache.ignite.internal.binary.BinaryContext.descriptorForTypeId(BinaryContext.java:662)
  71.     ... 17 more

我们把java代码中的方法scanQuery（）中的代码注释掉以后又没问题了，这是为嘛？有谁知道
注意看异常堆栈信息提示
Caused by: java.lang.ClassNotFoundException: com.github.aloxc.ignite.datagrid.CacheQueryExample$1，这个提示就是找不到CacheQueryExample，这是本类啊；照说找不到的话我把scanQuery()方法中的代码注释掉后再运行也应该找不到啊

  1. /*
  2.  * Licensed to the Apache Software Foundation (ASF) under one or more
  3.  * contributor license agreements.  See the NOTICE file distributed with
  4.  * this work for additional information regarding copyright ownership.
  5.  * The ASF licenses this file to You under the Apache License, Version 2.0
  6.  * (the "License"); you may not use this file except in compliance with
  7.  * the License.  You may obtain a copy of the License at
  8.  *
  9.  *      http://www.apache.org/licenses/LICENSE-2.0
  10.  *
  11.  * Unless required by applicable law or agreed to in writing, software
  12.  * distributed under the License is distributed on an "AS IS" BASIS,
  13.  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14.  * See the License for the specific language governing permissions and
  15.  * limitations under the License.
  16.  */
  18. package com.github.aloxc.ignite.datagrid;
  20. import com.github.aloxc.ignite.Config;
  21. import org.apache.ignite.Ignite;
  22. import org.apache.ignite.IgniteCache;
  23. import org.apache.ignite.Ignition;
  24. import org.apache.ignite.binary.BinaryObject;
  25. import org.apache.ignite.cache.CacheMode;
  26. import org.apache.ignite.cache.affinity.AffinityKey;
  27. import org.apache.ignite.cache.query.*;
  28. import org.apache.ignite.configuration.CacheConfiguration;
  29. import org.apache.ignite.examples.ExampleNodeStartup;
  30. import org.apache.ignite.examples.model.Organization;
  31. import org.apache.ignite.examples.model.Person;
  32. import org.apache.ignite.lang.IgniteBiPredicate;
  34. import javax.cache.Cache;
  35. import java.util.List;
  37. /**
  38.  * Cache queries example. This example demonstrates SQL, TEXT, and FULL SCAN
  39.  * queries over cache.
  40.  * <p>
  41.  * Example also demonstrates usage of fields queries that return only required
  42.  * fields instead of whole key-value pairs. When fields queries are distributed
  43.  * across several nodes, they may not work as expected. Keep in mind following
  44.  * limitations (not applied if data is queried from one node only):
  45.  * <ul>
  46.  *     <li>
  47.  *         Non-distributed joins will work correctly only if joined objects are stored in
  48.  *         collocated mode. Refer to {@link AffinityKey} javadoc for more details.
  49.  *         <p>
  50.  *         To use distributed joins it is necessary to set query 'distributedJoin' flag using
  51.  *         {@link SqlFieldsQuery#setDistributedJoins(boolean)} or {@link SqlQuery#setDistributedJoins(boolean)}.
  52.  *     </li>
  53.  *     <li>
  54.  *         Note that if you created query on to replicated cache, all data will
  55.  *         be queried only on one node, not depending on what caches participate in
  56.  *         the query (some data from partitioned cache can be lost). And visa versa,
  57.  *         if you created it on partitioned cache, data from replicated caches
  58.  *         will be duplicated.
  59.  *     </li>
  60.  * </ul>
  61.  * <p>
  62.  * Remote nodes should be started using {@link ExampleNodeStartup} which will
  63.  * start node with {@code examples/config/example-ignite.xml} configuration.
  64.  */
  65. public class CacheQueryExample {
  66.     /** Organizations cache name. */
  67.     private static final String ORG_CACHE = CacheQueryExample.class.getSimpleName() + "Organizations";
  69.     /** Persons collocated with Organizations cache name. */
  70.     private static final String COLLOCATED_PERSON_CACHE = CacheQueryExample.class.getSimpleName() + "CollocatedPersons";
  72.     /** Persons cache name. */
  73.     private static final String PERSON_CACHE = CacheQueryExample.class.getSimpleName() + "Persons";
  75.     /**
  76.      * Executes example.
  77.      *
  78.      * @param args Command line arguments, none required.
  79.      * @throws Exception If example execution failed.
  80.      */
  81.     public static void main(String[] args) throws Exception {
  82.         try (Ignite ignite = Ignition.start(Config.DEFAULT_CONFIG_PATH)) {
  83.             System.out.println();
  84.             System.out.println(">>> Cache query example started.");
  86.             CacheConfiguration<Long, Organization> orgCacheCfg = new CacheConfiguration<>(ORG_CACHE);
  88.             orgCacheCfg.setCacheMode(CacheMode.PARTITIONED); // Default.
  89.             orgCacheCfg.setIndexedTypes(Long.class, Organization.class);
  91.             CacheConfiguration<AffinityKey<Long>, Person> colPersonCacheCfg = new CacheConfiguration<>(COLLOCATED_PERSON_CACHE);
  93.             colPersonCacheCfg.setCacheMode(CacheMode.PARTITIONED); // Default.
  94.             colPersonCacheCfg.setIndexedTypes(AffinityKey.class, Person.class);
  96.             CacheConfiguration<AffinityKey<Long>, Person> personCacheCfg = new CacheConfiguration<>(PERSON_CACHE);
  98.             personCacheCfg.setCacheMode(CacheMode.PARTITIONED); // Default.
  99.             personCacheCfg.setIndexedTypes(Long.class, Person.class);
  101.             // Auto-close cache at the end of the example.
  102.             try (
  103.                 IgniteCache<Long, Organization> orgCache = ignite.getOrCreateCache(orgCacheCfg);
  104.                 IgniteCache<AffinityKey<Long>, Person> colPersonCache = ignite.getOrCreateCache(colPersonCacheCfg);
  105.                 IgniteCache<AffinityKey<Long>, Person> personCache = ignite.getOrCreateCache(personCacheCfg)
  106.             ) {
  107.                 // Populate cache.
  108.                 initialize();
  110.                 // Example for SCAN-based query based on a predicate.
  111.                 scanQuery();
  115.                 // Example for SQL-based querying employees based on salary ranges.
  116.                 sqlQuery();
  118.                 // Example for SQL-based querying employees for a given organization (includes SQL join for collocated objects).
  119.                 sqlQueryWithJoin();
  121.                 // Example for SQL-based querying employees for a given organization (includes distributed SQL join).
  122.                 sqlQueryWithDistributedJoin();
  124.                 // Example for TEXT-based querying for a given string in peoples resumes.
  125.                 textQuery();
  127.                 // Example for SQL-based querying to calculate average salary among all employees within a company.
  128.                 sqlQueryWithAggregation();
  130.                 // Example for SQL-based fields queries that return only required
  131.                 // fields instead of whole key-value pairs.
  132.                 sqlFieldsQuery();
  134.                 // Example for SQL-based fields queries that uses joins.
  135.                 sqlFieldsQueryWithJoin();
  136.             }
  137.             finally {
  138.                 // Distributed cache could be removed from cluster only by #destroyCache() call.
  139.                 ignite.destroyCache(COLLOCATED_PERSON_CACHE);
  140.                 ignite.destroyCache(PERSON_CACHE);
  141.                 ignite.destroyCache(ORG_CACHE);
  142.             }
  144.             print("Cache query example finished.");
  145.         }
  146.     }
  149.     private static void scanQuery() {
  150.         IgniteCache<BinaryObject, BinaryObject> cache = Ignition.ignite().cache(COLLOCATED_PERSON_CACHE).withKeepBinary();
  152.         ScanQuery<BinaryObject, BinaryObject> scan = new ScanQuery<>(
  153.                 new IgniteBiPredicate<BinaryObject, BinaryObject>() {
  154.                     @Override public boolean apply(BinaryObject key, BinaryObject person) {
  155.                         return person.<Double>field("salary") <= 1000;
  156.                     }
  157.                 }
  158.         );
  160.         // Execute queries for salary ranges.
  161.         print("People with salaries between 0 and 1000 (queried with SCAN query)[withKeepBinary]: ", cache.query(scan).getAll());
  162.     }
  163.     /**
  164.      * Example for SQL queries based on salary ranges.
  165.      */
  166.     private static void sqlQuery() {
  167.         IgniteCache<AffinityKey<Long>, Person> cache = Ignition.ignite().cache(PERSON_CACHE);
  169.         // SQL clause which selects salaries based on range.
  170.         String sql = "salary > ? and salary <= ?";
  172.         // Execute queries for salary ranges.
  173.         print("People with salaries between 0 and 1000 (queried with SQL query): ",
  174.             cache.query(new SqlQuery<AffinityKey<Long>, Person>(Person.class, sql).
  175.                 setArgs(0, 1000)).getAll());
  177.         print("People with salaries between 1000 and 2000 (queried with SQL query): ",
  178.             cache.query(new SqlQuery<AffinityKey<Long>, Person>(Person.class, sql).
  179.                 setArgs(1000, 2000)).getAll());
  180.     }
  182.     /**
  183.      * Example for SQL queries based on all employees working for a specific organization.
  184.      */
  185.     private static void sqlQueryWithJoin() {
  186.         IgniteCache<AffinityKey<Long>, Person> cache = Ignition.ignite().cache(COLLOCATED_PERSON_CACHE);
  188.         // SQL clause query which joins on 2 types to select people for a specific organization.
  189.         String joinSql =
  190.             "from Person, \"" + ORG_CACHE + "\".Organization as org " +
  191.             "where Person.orgId = org.id " +
  192.             "and lower(org.name) = lower(?)";
  194.         // Execute queries for find employees for different organizations.
  195.         print("Following people are 'ApacheIgnite' employees: ",
  196.             cache.query(new SqlQuery<AffinityKey<Long>, Person>(Person.class, joinSql).
  197.                 setArgs("ApacheIgnite")).getAll());
  199.         print("Following people are 'Other' employees: ",
  200.             cache.query(new SqlQuery<AffinityKey<Long>, Person>(Person.class, joinSql).
  201.                 setArgs("Other")).getAll());
  202.     }
  204.     /**
  205.      * Example for SQL queries based on all employees working for a specific organization (query uses distributed join).
  206.      */
  207.     private static void sqlQueryWithDistributedJoin() {
  208.         IgniteCache<AffinityKey<Long>, Person> cache = Ignition.ignite().cache(PERSON_CACHE);
  210.         // SQL clause query which joins on 2 types to select people for a specific organization.
  211.         String joinSql =
  212.             "from Person, \"" + ORG_CACHE + "\".Organization as org " +
  213.             "where Person.orgId = org.id " +
  214.             "and lower(org.name) = lower(?)";
  216.         SqlQuery qry = new SqlQuery<AffinityKey<Long>, Person>(Person.class, joinSql).
  217.             setArgs("ApacheIgnite");
  219.         // Enable distributed joins for query.
  220.         qry.setDistributedJoins(true);
  222.         // Execute queries for find employees for different organizations.
  223.         print("Following people are 'ApacheIgnite' employees (distributed join): ", cache.query(qry).getAll());
  225.         qry.setArgs("Other");
  227.         print("Following people are 'Other' employees (distributed join): ", cache.query(qry).getAll());
  228.     }
  230.     /**
  231.      * Example for TEXT queries using LUCENE-based indexing of people's resumes.
  232.      */
  233.     private static void textQuery() {
  234.         IgniteCache<AffinityKey<Long>, Person> cache = Ignition.ignite().cache(PERSON_CACHE);
  236.         //  Query for all people with "Master Degree" in their resumes.
  237.         QueryCursor<Cache.Entry<AffinityKey<Long>, Person>> masters =
  238.             cache.query(new TextQuery<AffinityKey<Long>, Person>(Person.class, "Master"));
  240.         // Query for all people with "Bachelor Degree" in their resumes.
  241.         QueryCursor<Cache.Entry<AffinityKey<Long>, Person>> bachelors =
  242.             cache.query(new TextQuery<AffinityKey<Long>, Person>(Person.class, "Bachelor"));
  244.         print("Following people have 'Master Degree' in their resumes: ", masters.getAll());
  245.         print("Following people have 'Bachelor Degree' in their resumes: ", bachelors.getAll());
  246.     }
  248.     /**
  249.      * Example for SQL queries to calculate average salary for a specific organization.
  250.      */
  251.     private static void sqlQueryWithAggregation() {
  252.         IgniteCache<AffinityKey<Long>, Person> cache = Ignition.ignite().cache(COLLOCATED_PERSON_CACHE);
  254.         // Calculate average of salary of all persons in ApacheIgnite.
  255.         // Note that we also join on Organization cache as well.
  256.         String sql =
  257.             "select avg(salary) " +
  258.             "from Person, \"" + ORG_CACHE + "\".Organization as org " +
  259.             "where Person.orgId = org.id " +
  260.             "and lower(org.name) = lower(?)";
  262.         QueryCursor<List<?>> cursor = cache.query(new SqlFieldsQuery(sql).setArgs("ApacheIgnite"));
  264.         // Calculate average salary for a specific organization.
  265.         print("Average salary for 'ApacheIgnite' employees: ", cursor.getAll());
  266.     }
  268.     /**
  269.      * Example for SQL-based fields queries that return only required
  270.      * fields instead of whole key-value pairs.
  271.      */
  272.     private static void sqlFieldsQuery() {
  273.         IgniteCache<AffinityKey<Long>, Person> cache = Ignition.ignite().cache(PERSON_CACHE);
  275.         // Execute query to get names of all employees.
  276.         QueryCursor<List<?>> cursor = cache.query(new SqlFieldsQuery(
  277.             "select concat(firstName, ' ', lastName) from Person"));
  279.         // In this particular case each row will have one element with full name of an employees.
  280.         List<List<?>> res = cursor.getAll();
  282.         // Print names.
  283.         print("Names of all employees:", res);
  284.     }
  286.     /**
  287.      * Example for SQL-based fields queries that return only required
  288.      * fields instead of whole key-value pairs.
  289.      */
  290.     private static void sqlFieldsQueryWithJoin() {
  291.         IgniteCache<AffinityKey<Long>, Person> cache = Ignition.ignite().cache(COLLOCATED_PERSON_CACHE);
  293.         // Execute query to get names of all employees.
  294.         String sql =
  295.             "select concat(firstName, ' ', lastName), org.name " +
  296.             "from Person, \"" + ORG_CACHE + "\".Organization as org " +
  297.             "where Person.orgId = org.id";
  299.         QueryCursor<List<?>> cursor = cache.query(new SqlFieldsQuery(sql));
  301.         // In this particular case each row will have one element with full name of an employees.
  302.         List<List<?>> res = cursor.getAll();
  304.         // Print persons' names and organizations' names.
  305.         print("Names of all employees and organizations they belong to: ", res);
  306.     }
  308.     /**
  309.      * Populate cache with test data.
  310.      */
  311.     private static void initialize() {
  312.         IgniteCache<Long, Organization> orgCache = Ignition.ignite().cache(ORG_CACHE);
  314.         // Clear cache before running the example.
  315.         orgCache.clear();
  317.         // Organizations.
  318.         Organization org1 = new Organization("ApacheIgnite");
  319.         Organization org2 = new Organization("Other");
  321.         orgCache.put(org1.id(), org1);
  322.         orgCache.put(org2.id(), org2);
  324.         IgniteCache<AffinityKey<Long>, Person> colPersonCache = Ignition.ignite().cache(COLLOCATED_PERSON_CACHE);
  325.         IgniteCache<Long, Person> personCache = Ignition.ignite().cache(PERSON_CACHE);
  327.         // Clear caches before running the example.
  328.         colPersonCache.clear();
  329.         personCache.clear();
  331.         // People.
  332.         Person p1 = new Person(org1, "John", "Doe", 2000, "John Doe has Master Degree.");
  333.         Person p2 = new Person(org1, "Jane", "Doe", 800, "Jane Doe has Bachelor Degree.");
  334.         Person p3 = new Person(org2, "John", "Smith", 900, "John Smith has Bachelor Degree.");
  335.         Person p4 = new Person(org2, "Jane", "Smith", 2000, "Jane Smith has Master Degree.");
  337.         // Note that in this example we use custom affinity key for Person objects
  338.         // to ensure that all persons are collocated with their organizations.
  339.         colPersonCache.put(p1.key(), p1);
  340.         colPersonCache.put(p2.key(), p2);
  341.         colPersonCache.put(p3.key(), p3);
  342.         colPersonCache.put(p4.key(), p4);
  344.         // These Person objects are not collocated with their organizations.
  345.         personCache.put(p1.id, p1);
  346.         personCache.put(p2.id, p2);
  347.         personCache.put(p3.id, p3);
  348.         personCache.put(p4.id, p4);
  349.     }
  351.     /**
  352.      * Prints message and query results.
  353.      *
  354.      * @param msg Message to print before all objects are printed.
  355.      * @param col Query results.
  356.      */
  357.     private static void print(String msg, Iterable<?> col) {
  358.         print(msg);
  359.         print(col);
  360.     }
  362.     /**
  363.      * Prints message.
  364.      *
  365.      * @param msg Message to print before all objects are printed.
  366.      */
  367.     private static void print(String msg) {
  368.         System.out.println();
  369.         System.out.println(">>> " + msg);
  370.     }
  372.     /**
  373.      * Prints query results.
  374.      *
  375.      * @param col Query results.
  376.      */
  377.     private static void print(Iterable<?> col) {
  378.         for (Object next : col)
  379.             System.out.println(">>>     " + next);
  380.     }
  381. }

2016-12-07补充下：今天为技术分享会做准备的时候，对一些参数进行测试，其中就有调整过部署模式，调整为PRIVATE，当时是测试分布式计算，计算字符串中所有单词的长度。当部署模式是SHARED的时候没问题，更改为PRIVATE的时候日志中有一行提示，
Deployment mode for cache is not CONTINUOUS or SHARED (it is recommended that you change deployment mode and restart): PRIVATE
意思是对于缓存来说，部署模式仅仅支持CONTINUOUS和SHARED.我当时的配置文件中的确有缓存相关的配置，虽然我测试中没有使用缓存，它还是依然给我提示了。如下为配置文件

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans"
  3.        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.        xmlns:util="http://www.springframework.org/schema/util"
  5.        xmlns:context="http://www.springframework.org/schema/context"
  6.        xsi:schemaLocation="
  7.         http://www.springframework.org/schema/beans
  8.         http://www.springframework.org/schema/beans/spring-beans.xsd
  9.         http://www.springframework.org/schema/util
  10.         http://www.springframework.org/schema/util/spring-util.xsd
  11.         http://www.springframework.org/schema/context
  12.         http://www.springframework.org/schema/context/spring-context.xsd">
  14.     <context:annotation-config/>
  15.     <context:component-scan base-package="com.github.aloxc.ignite.datagrid.store"/>
  16.     <!-- Datasource for sample in-memory H2 database. -->
  17.     <bean id="h2-example-db" class="org.h2.jdbcx.JdbcDataSource">
  18.         <property name="URL" value="jdbc:h2:tcp://localhost/mem:ExampleDb" />
  19.         <property name="user" value="sa" />
  20.     </bean>
  21.     <bean class="org.springframework.jdbc.datasource.DriverManagerDataSource" id="tybbs_user_datasource">
  22.         <property name="driverClassName" value="com.mysql.jdbc.Driver"></property>
  23.         <property name="url" value="jdbc:mysql://192.168.20.185:3306/user"></property>
  24.         <property name="username" value="testtyDB"></property>
  25.         <property name="password" value="wfjmL2vF"></property>
  26.     </bean>
  28.     <bean id="cacheOnlyStoreFactoryExampleUsingMysql" class="com.github.aloxc.ignite.datagrid.store.CacheOnlyStoreFactoryExampleUsingMysql">
  29.         <property name="dataSource" ref="tybbs_user_datasource"></property>
  30.     </bean>
  32.     <bean id="grid.cfg" class="org.apache.ignite.configuration.IgniteConfiguration">
  34.         <property name="peerClassLoadingEnabled" value="true"/>
  35.         <property name="clientMode" value="false"/>
  36.         <property name="deploymentMode" value="PRIVATE"/>
  37.         <property name="marshaller">
  38.             <bean class="org.apache.ignite.internal.binary.BinaryMarshaller"/>
  39.         </property>
  41.         <property name="cacheConfiguration" >
  42.             <list>
  43.                 <bean class="org.apache.ignite.configuration.CacheConfiguration">
  44.                     <property name="cacheMode" value="PARTITIONED"/>
  45.                     <property name="writeThrough" value="true"/>
  46.                     <property name="readThrough" value="true" />
  47.                     <property name="name" value="cacheOnlyUsingMysql"/>
  48.                     <property name="backups" value="1"/>
  49.                     <property name="writeBehindEnabled" value="true" />
  50.                     <property name="writeBehindFlushSize" value="3" />
  51.                     <property name="writeBehindFlushFrequency" value="0" />
  52.                     <property name="writeBehindBatchSize" value="10" />
  53.                     <property name="cacheStoreFactory">
  54.                         <bean class="javax.cache.configuration.FactoryBuilder.SingletonFactory">
  55.                             <constructor-arg ref="cacheOnlyStoreFactoryExampleUsingMysql" />
  56.                         </bean>
  57.                     </property>
  58.                     <property name="queryEntities">
  59.                         <util:list>
  60.                             <bean class="org.apache.ignite.cache.QueryEntity">
  61.                                 <property name="keyType" value="java.lang.Long"/>
  62.                                 <property name="valueType" value="com.github.aloxc.ignite.model.Person"/>
  63.                                 <property name="fields">
  64.                                     <map>
  65.                                         <entry key="id" value="java.lang.Long"/>
  66.                                         <entry key="first_name" value="java.lang.String"/>
  67.                                         <entry key="last_name" value="java.lang.String"/>
  68.                                     </map>
  69.                                 </property>
  70.                                 <property name="indexes">
  71.                                     <list>
  72.                                         <bean class="org.apache.ignite.cache.QueryIndex">
  73.                                             <constructor-arg name="field" value="id" />
  74.                                         </bean>
  75.                                         <bean class="org.apache.ignite.cache.QueryIndex">
  76.                                             <constructor-arg name="field" value="first_name" />
  77.                                         </bean>
  78.                                     </list>
  79.                                 </property>
  80.                             </bean>
  81.                         </util:list>
  82.                     </property>
  83.                 </bean>
  84.             </list>
  85.         </property>
  87.     </bean>
  88. </beans>

作者[@aloxc]

x

添加新批注
在作者公开此批注前，只有你和作者可见。
回复批注