ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sevdoki...@apache.org
Subject [26/34] incubator-ignite git commit: Merge remote-tracking branch 'remotes/origin/sprint-1' into ignite-54-55
Date Thu, 05 Feb 2015 13:54:22 GMT
Merge remote-tracking branch 'remotes/origin/sprint-1' into ignite-54-55

Conflicts:
	examples/src/main/java/org/apache/ignite/examples/datagrid/CacheAffinityExample.java
	examples/src/main/java/org/apache/ignite/examples/datagrid/CacheApiExample.java
	examples/src/main/java/org/apache/ignite/examples/datagrid/CacheDataLoaderExample.java
	examples/src/main/java/org/apache/ignite/examples/datagrid/CacheEventsExample.java
	examples/src/main/java/org/apache/ignite/examples/datagrid/CachePopularNumbersExample.java
	examples/src/main/java/org/apache/ignite/examples/datagrid/CachePutGetExample.java
	examples/src/main/java/org/apache/ignite/examples/datagrid/CacheQueryExample.java
	examples/src/main/java/org/apache/ignite/examples/datagrid/CacheTransactionExample.java
	examples/src/main/java/org/apache/ignite/examples/datagrid/starschema/CacheStarSchemaExample.java
	examples/src/main/java/org/apache/ignite/examples/datagrid/store/CacheStoreExample.java
	examples/src/main/java/org/apache/ignite/examples/datagrid/store/CacheStoreLoadDataExample.java
	examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCachePopularNumbersExample.scala


Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/eb46cbbb
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/eb46cbbb
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/eb46cbbb

Branch: refs/heads/sprint-1
Commit: eb46cbbbed8f29060172787574d8c272b7bb37e5
Parents: e601a6d 878a289
Author: sevdokimov <sevdokimov@gridgain.com>
Authored: Wed Feb 4 17:12:18 2015 +0300
Committer: sevdokimov <sevdokimov@gridgain.com>
Committed: Wed Feb 4 17:12:18 2015 +0300

----------------------------------------------------------------------
 docs/core-site.ignite.xml                       |   2 +-
 examples/config/example-cache.xml               |  14 +-
 examples/config/example-compute.xml             |   8 +-
 examples/config/example-streamer.xml            |  30 +-
 examples/config/filesystem/core-site.xml        |  10 +-
 examples/config/filesystem/example-ggfs.xml     | 165 -----------
 examples/config/filesystem/example-ignitefs.xml | 165 +++++++++++
 examples/config/filesystem/readme.txt           |   8 +-
 .../hibernate/example-hibernate-L2-cache.xml    |   6 +-
 examples/config/servlet/WEB-INF/web.xml         |   2 +-
 examples/rest/http-rest-example.php             |   8 +-
 examples/rest/memcache-rest-example.php         |   4 +-
 .../ignite/examples/ComputeNodeStartup.java     |   4 +-
 .../apache/ignite/examples/ExamplesUtils.java   |   6 +-
 .../compute/ComputeBroadcastExample.java        |  34 +--
 .../compute/ComputeCallableExample.java         |  18 +-
 .../examples/compute/ComputeClosureExample.java |  20 +-
 .../compute/ComputeContinuousMapperExample.java |  24 +-
 .../compute/ComputeExecutorServiceExample.java  |  16 +-
 .../ComputeFibonacciContinuationExample.java    |  35 ++-
 .../compute/ComputeProjectionExample.java       |  23 +-
 .../examples/compute/ComputeReducerExample.java |  20 +-
 .../compute/ComputeRunnableExample.java         |  17 +-
 .../compute/ComputeScheduleExample.java         |  14 +-
 .../examples/compute/ComputeTaskMapExample.java |  30 +-
 .../compute/ComputeTaskSplitExample.java        |  26 +-
 .../failover/ComputeFailoverExample.java        |  17 +-
 .../failover/ComputeFailoverNodeStartup.java    |  12 +-
 .../compute/montecarlo/CreditRiskExample.java   |  30 +-
 .../compute/montecarlo/CreditRiskManager.java   |  14 +-
 .../apache/ignite/examples/compute/package.html |   2 +-
 .../examples/datagrid/CacheAffinityExample.java |  37 ++-
 .../examples/datagrid/CacheApiExample.java      | 104 ++-----
 .../datagrid/CacheContinuousQueryExample.java   |  10 +-
 .../datagrid/CacheDataLoaderExample.java        |  16 +-
 .../examples/datagrid/CacheEventsExample.java   |  19 +-
 .../examples/datagrid/CacheNodeStartup.java     |   4 +-
 .../datagrid/CachePopularNumbersExample.java    |  32 +--
 .../examples/datagrid/CachePutGetExample.java   |  29 +-
 .../examples/datagrid/CacheQueryExample.java    |  26 +-
 .../datagrid/CacheTransactionExample.java       |  41 ++-
 .../datastructures/CacheAtomicLongExample.java  |  16 +-
 .../CacheAtomicReferenceExample.java            |  24 +-
 .../CacheAtomicSequenceExample.java             |  14 +-
 .../CacheAtomicStampedExample.java              |  22 +-
 .../CacheCountDownLatchExample.java             |  16 +-
 .../datastructures/CacheQueueExample.java       |  46 +--
 .../datastructures/CacheSetExample.java         |  36 +--
 .../hibernate/HibernateL2CacheExample.java      |  18 +-
 .../HibernateL2CacheExampleNodeStartup.java     |  12 +-
 .../ignite/examples/datagrid/package.html       |   2 +-
 .../starschema/CacheStarSchemaExample.java      |  57 ++--
 .../datagrid/starschema/DimProduct.java         |   3 +-
 .../examples/datagrid/starschema/DimStore.java  |   3 +-
 .../datagrid/starschema/FactPurchase.java       |   3 +-
 .../examples/datagrid/starschema/package.html   |   2 +-
 .../store/CacheNodeWithStoreStartup.java        |  12 +-
 .../datagrid/store/CacheStoreExample.java       |  17 +-
 .../store/CacheStoreLoadDataExample.java        |  13 +-
 .../store/dummy/CacheDummyPersonStore.java      |   9 +-
 .../datagrid/store/hibernate/hibernate.cfg.xml  |   2 +-
 .../store/jdbc/CacheJdbcPersonStore.java        |  10 +-
 .../ignite/examples/events/EventsExample.java   |  32 +--
 .../ignite/examples/fs/IgniteFsExample.java     | 278 +++++++++++++++++++
 .../examples/fs/IgniteFsMapReduceExample.java   | 249 +++++++++++++++++
 .../ignite/examples/fs/IgniteFsNodeStartup.java |  41 +++
 .../org/apache/ignite/examples/fs/package.html  |  23 ++
 .../ignite/examples/ggfs/GgfsExample.java       | 278 -------------------
 .../examples/ggfs/GgfsMapReduceExample.java     | 249 -----------------
 .../ignite/examples/ggfs/GgfsNodeStartup.java   |  41 ---
 .../apache/ignite/examples/ggfs/package.html    |  23 --
 .../examples/messaging/MessagingExample.java    |  36 +--
 .../messaging/MessagingPingPongExample.java     |  26 +-
 .../MessagingPingPongListenActorExample.java    |  20 +-
 .../client/memcache/MemcacheRestExample.java    |  22 +-
 .../MemcacheRestExampleNodeStartup.java         |  14 +-
 .../misc/deployment/DeploymentExample.java      |  34 +--
 .../misc/lifecycle/LifecycleExample.java        |  24 +-
 .../misc/springbean/SpringBeanExample.java      |  30 +-
 .../examples/misc/springbean/package.html       |   2 +-
 .../examples/misc/springbean/spring-bean.xml    |   8 +-
 .../org/apache/ignite/examples/package.html     |   2 +-
 .../examples/services/ServicesExample.java      |  16 +-
 .../streaming/StreamingCheckInExample.java      |  30 +-
 .../streaming/StreamingNodeStartup.java         |   4 +-
 .../StreamingPopularNumbersExample.java         |  40 +--
 .../streaming/StreamingPriceBarsExample.java    |  38 +--
 .../StreamingRunningAverageExample.java         |   6 +-
 .../apache/ignite/examples/ComputeExample.java  |  22 +-
 .../ignite/examples/MessagingExample.java       |  66 +++--
 .../examples/ScalarCacheAffinityExample1.scala  |  22 +-
 .../examples/ScalarCacheAffinityExample2.scala  |  18 +-
 .../ScalarCacheAffinitySimpleExample.scala      |   6 +-
 .../scalar/examples/ScalarCacheExample.scala    |   4 +-
 .../ScalarCachePopularNumbersExample.scala      |  26 +-
 .../examples/ScalarCacheQueryExample.scala      |  20 +-
 .../scalar/examples/ScalarClosureExample.scala  |  20 +-
 .../examples/ScalarContinuationExample.scala    |  33 ++-
 .../examples/ScalarCreditRiskExample.scala      |  22 +-
 .../scalar/examples/ScalarJvmCloudExample.scala |  22 +-
 .../examples/ScalarPiCalculationExample.scala   |   6 +-
 .../scalar/examples/ScalarPingPongExample.scala |  14 +-
 .../scalar/examples/ScalarPrimeExample.scala    |  16 +-
 .../scalar/examples/ScalarScheduleExample.scala |   6 +-
 .../examples/ScalarSnowflakeSchemaExample.scala |  40 +--
 .../scalar/examples/ScalarTaskExample.scala     |  14 +-
 .../examples/ScalarWorldShortestMapReduce.scala |   2 +-
 .../BasicExamplesMultiNodeSelfTest.java         |  28 ++
 .../ignite/examples/BasicExamplesSelfTest.java  |  82 ++++++
 .../CacheExamplesMultiNodeSelfTest.java         |  48 ++++
 .../ignite/examples/CacheExamplesSelfTest.java  | 155 +++++++++++
 ...heStoreLoadDataExampleMultiNodeSelfTest.java |  39 +++
 .../examples/CheckpointExamplesSelfTest.java    |  45 +++
 .../ContinuationExamplesMultiNodeSelfTest.java  |  28 ++
 .../examples/ContinuationExamplesSelfTest.java  |  33 +++
 ...ntinuousMapperExamplesMultiNodeSelfTest.java |  28 ++
 .../ContinuousMapperExamplesSelfTest.java       |  33 +++
 .../DeploymentExamplesMultiNodeSelfTest.java    |  30 ++
 .../examples/DeploymentExamplesSelfTest.java    |  33 +++
 .../EventsExamplesMultiNodeSelfTest.java        |  28 ++
 .../ignite/examples/EventsExamplesSelfTest.java |  33 +++
 .../GridBasicExamplesMultiNodeSelfTest.java     |  28 --
 .../examples/GridBasicExamplesSelfTest.java     |  82 ------
 .../GridCacheExamplesMultiNodeSelfTest.java     |  48 ----
 .../examples/GridCacheExamplesSelfTest.java     | 155 -----------
 ...heStoreLoadDataExampleMultiNodeSelfTest.java |  39 ---
 .../GridCheckpointExamplesSelfTest.java         |  45 ---
 ...idContinuationExamplesMultiNodeSelfTest.java |  28 --
 .../GridContinuationExamplesSelfTest.java       |  33 ---
 ...ntinuousMapperExamplesMultiNodeSelfTest.java |  28 --
 .../GridContinuousMapperExamplesSelfTest.java   |  33 ---
 ...GridDeploymentExamplesMultiNodeSelfTest.java |  30 --
 .../GridDeploymentExamplesSelfTest.java         |  33 ---
 .../GridEventsExamplesMultiNodeSelfTest.java    |  28 --
 .../examples/GridEventsExamplesSelfTest.java    |  33 ---
 ...ibernateL2CacheExampleMultiNodeSelfTest.java |  31 ---
 .../GridHibernateL2CacheExampleSelfTest.java    |  33 ---
 .../examples/GridLifecycleExamplesSelfTest.java |  33 ---
 ...idMemcacheRestExamplesMultiNodeSelfTest.java |  31 ---
 .../GridMemcacheRestExamplesSelfTest.java       |  41 ---
 .../examples/GridMessagingExamplesSelfTest.java |  52 ----
 ...GridMonteCarloExamplesMultiNodeSelfTest.java |  28 --
 .../GridMonteCarloExamplesSelfTest.java         |  74 -----
 .../examples/GridProjectionExampleSelfTest.java |  39 ---
 .../GridSpringBeanExamplesSelfTest.java         |  33 ---
 .../GridTaskExamplesMultiNodeSelfTest.java      |  28 --
 .../examples/GridTaskExamplesSelfTest.java      |  40 ---
 ...ibernateL2CacheExampleMultiNodeSelfTest.java |  31 +++
 .../HibernateL2CacheExampleSelfTest.java        |  33 +++
 .../examples/IgniteFsExamplesSelfTest.java      |  16 +-
 .../examples/LifecycleExamplesSelfTest.java     |  33 +++
 .../MemcacheRestExamplesMultiNodeSelfTest.java  |  31 +++
 .../examples/MemcacheRestExamplesSelfTest.java  |  41 +++
 .../examples/MessagingExamplesSelfTest.java     |  52 ++++
 .../MonteCarloExamplesMultiNodeSelfTest.java    |  28 ++
 .../examples/MonteCarloExamplesSelfTest.java    |  74 +++++
 .../examples/ProjectionExampleSelfTest.java     |  39 +++
 .../examples/SpringBeanExamplesSelfTest.java    |  33 +++
 .../examples/TaskExamplesMultiNodeSelfTest.java |  28 ++
 .../ignite/examples/TaskExamplesSelfTest.java   |  40 +++
 .../testsuites/IgniteExamplesSelfTestSuite.java |  54 ++--
 .../ScalarExamplesSelfTestSuite.scala           |   7 +-
 .../src/main/java/org/apache/ignite/Ignite.java |   4 +-
 .../apache/ignite/IgniteCheckedException.java   |  24 --
 .../java/org/apache/ignite/IgniteException.java |  26 +-
 .../org/apache/ignite/cluster/ClusterGroup.java |   9 +-
 .../ignite/internal/ClusterGroupAdapter.java    |  51 +---
 .../ignite/internal/IgniteClusterAsyncImpl.java |  12 +-
 .../apache/ignite/internal/IgniteKernal.java    |   2 +-
 .../processors/cache/GridCacheMapEntry.java     |   6 +-
 .../processors/cache/IgniteCacheProxy.java      |   7 +
 .../ignite/internal/util/IgniteUtils.java       |  22 --
 .../apache/ignite/internal/util/typedef/X.java  |  36 ---
 .../test/config/load/mongo-multinode-foster.xml | 170 ------------
 .../IgniteExceptionHelpLinksSelfTest.java       | 105 -------
 .../GridProjectionForCachesSelfTest.java        |  27 +-
 .../fs/GridGgfsCommonAbstractTest.java          |   4 +-
 .../ipc/shmem/GgfsSharedMemoryTestServer.java   |   2 +-
 .../IpcSharedMemoryCrashDetectionSelfTest.java  |   2 +-
 .../IpcSharedMemoryBenchmarkReader.java         |   2 +-
 .../ignite/p2p/GridP2PUndeploySelfTest.java     |   2 +-
 .../GridAbstractCommunicationSelfTest.java      |   6 +-
 ...mmunicationSpiConcurrentConnectSelfTest.java |   6 +-
 .../tcp/GridTcpCommunicationSpiLanTest.java     |   6 +-
 ...cpCommunicationSpiMultithreadedSelfTest.java |   6 +-
 ...dTcpCommunicationSpiRecoveryAckSelfTest.java |   6 +-
 ...GridTcpCommunicationSpiRecoverySelfTest.java |   6 +-
 .../GridAbstractDiscoverySelfTest.java          |  12 +-
 .../testframework/junits/GridAbstractTest.java  |  10 +-
 .../testframework/junits/GridTestIgnite.java    | 230 ---------------
 .../testframework/junits/GridTestResources.java | 255 -----------------
 .../ignite/testframework/junits/IgniteMock.java | 230 +++++++++++++++
 .../junits/IgniteTestResources.java             | 255 +++++++++++++++++
 .../junits/spi/GridSpiAbstractTest.java         |   6 +-
 .../ignite/testsuites/IgniteBasicTestSuite.java |   1 -
 ...idHadoopDefaultMapReducePlannerSelfTest.java |   6 +-
 .../scala/org/apache/ignite/scalar/scalar.scala |  14 +-
 .../tests/ScalarAffinityRoutingSpec.scala       |  12 +-
 .../tests/ScalarCacheProjectionSpec.scala       |   2 +-
 .../ignite/scalar/tests/ScalarCacheSpec.scala   |   2 +-
 .../scalar/tests/ScalarProjectionSpec.scala     |  36 +--
 .../org/apache/ignite/IgniteSpringBean.java     |   2 +-
 202 files changed, 3407 insertions(+), 3888 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/eb46cbbb/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheContinuousQueryExample.java
----------------------------------------------------------------------
diff --cc examples/src/main/java/org/apache/ignite/examples/datagrid/CacheContinuousQueryExample.java
index 2af56ba,866967f..ce05988
--- a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheContinuousQueryExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheContinuousQueryExample.java
@@@ -48,10 -48,10 +48,10 @@@ public class CacheContinuousQueryExampl
              System.out.println();
              System.out.println(">>> Cache continuous query example started.");
  
-             GridCache<Integer, String> cache = g.cache(CACHE_NAME);
+             GridCache<Integer, String> cache = ignite.cache(CACHE_NAME);
  
              // Clean up caches on all nodes before run.
 -            cache.globalClearAll(0);
 +            cache.clear(0);
  
              int keyCnt = 20;
  

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/eb46cbbb/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheDataLoaderExample.java
----------------------------------------------------------------------
diff --cc examples/src/main/java/org/apache/ignite/examples/datagrid/CacheDataLoaderExample.java
index 6fc742e,64fa179..ca2ef64
--- a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheDataLoaderExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheDataLoaderExample.java
@@@ -56,7 -56,7 +56,7 @@@ public class CacheDataLoaderExample 
              System.out.println(">>> Cache data loader example started.");
  
              // Clean up caches on all nodes before run.
-             g.cache(CACHE_NAME).clear(0);
 -            ignite.jcache(CACHE_NAME).clear();
++            ignite.cache(CACHE_NAME).clear(0);
  
              System.out.println();
              System.out.println(">>> Cache clear finished.");

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/eb46cbbb/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheEventsExample.java
----------------------------------------------------------------------
diff --cc examples/src/main/java/org/apache/ignite/examples/datagrid/CacheEventsExample.java
index 83c406d,5156a1b..0a3245f
--- a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheEventsExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheEventsExample.java
@@@ -51,10 -50,10 +50,10 @@@ public class CacheEventsExample 
              System.out.println();
              System.out.println(">>> Cache events example started.");
  
-             final GridCache<Integer, String> cache = g.cache(CACHE_NAME);
+             final IgniteCache<Integer, String> cache = ignite.jcache(CACHE_NAME);
  
              // Clean up caches on all nodes before run.
 -            cache.clear();
 +            cache.clear(0);
  
              // This optional local callback is called for each event notification
              // that passed remote predicate listener.

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/eb46cbbb/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheTransactionExample.java
----------------------------------------------------------------------
diff --cc examples/src/main/java/org/apache/ignite/examples/datagrid/CacheTransactionExample.java
index 07f1c80,6710ebc..f5042da
--- a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheTransactionExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheTransactionExample.java
@@@ -52,13 -50,13 +50,13 @@@ public class CacheTransactionExample 
              System.out.println(">>> Cache transaction example started.");
  
              // Clean up caches on all nodes before run.
-             g.cache(CACHE_NAME).clear(0);
 -            ignite.jcache(CACHE_NAME).clear();
++            ignite.cache(CACHE_NAME).clear(0);
  
-             GridCache<Integer, Account> cache = g.cache(CACHE_NAME);
+             IgniteCache<Integer, Account> cache = ignite.jcache(CACHE_NAME);
  
              // Initialize.
-             cache.putx(1, new Account(1, 100));
-             cache.putx(2, new Account(1, 200));
+             cache.put(1, new Account(1, 100));
+             cache.put(2, new Account(1, 200));
  
              System.out.println();
              System.out.println(">>> Accounts before deposit: ");

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/eb46cbbb/examples/src/main/java/org/apache/ignite/examples/datagrid/store/CacheStoreLoadDataExample.java
----------------------------------------------------------------------
diff --cc examples/src/main/java/org/apache/ignite/examples/datagrid/store/CacheStoreLoadDataExample.java
index fac42ae,7bc7133..f38374e
--- a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/CacheStoreLoadDataExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/CacheStoreLoadDataExample.java
@@@ -51,10 -50,10 +50,10 @@@ public class CacheStoreLoadDataExample 
              System.out.println();
              System.out.println(">>> Cache store load data example started.");
  
-             final GridCache<String, Integer> cache = g.cache(null);
+             final IgniteCache<String, Integer> cache = ignite.jcache(null);
  
              // Clean up caches on all nodes before run.
 -            cache.clear();
 +            cache.clear(0);
  
              long start = System.currentTimeMillis();
  

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/eb46cbbb/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCacheAffinityExample1.scala
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/eb46cbbb/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCacheAffinityExample2.scala
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/eb46cbbb/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCacheAffinitySimpleExample.scala
----------------------------------------------------------------------
diff --cc examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCacheAffinitySimpleExample.scala
index fdfa877,ad980e8..a13252f
--- a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCacheAffinitySimpleExample.scala
+++ b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCacheAffinitySimpleExample.scala
@@@ -51,9 -51,9 +51,9 @@@ object ScalarCacheAffinitySimpleExampl
       */
      scalar("examples/config/example-cache.xml") {
          // Clean up caches on all nodes before run.
 -        cache$(NAME).get.globalClearAll(0)
 +        cache$(NAME).get.clear(0)
  
-         val c = grid$.cache[Int, String](NAME)
+         val c = ignite$.cache[Int, String](NAME)
  
          populate(c)
          visit(c)

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/eb46cbbb/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCacheExample.scala
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/eb46cbbb/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCachePopularNumbersExample.scala
----------------------------------------------------------------------
diff --cc examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCachePopularNumbersExample.scala
index daf015c,9453d58..e376bda
--- a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCachePopularNumbersExample.scala
+++ b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCachePopularNumbersExample.scala
@@@ -75,7 -75,7 +75,7 @@@ object ScalarCachePopularNumbersExampl
                  query(POPULAR_NUMBERS_CNT)
  
                  // Clean up caches on all nodes after run.
-                 grid$.cluster().forCacheNodes(CACHE_NAME).bcastRun(() => grid$.cache(CACHE_NAME).clear(),
null)
 -                ignite$.cluster().forCacheNodes(CACHE_NAME).bcastRun(() => ignite$.cache(CACHE_NAME).clearAll(),
null)
++                ignite$.cluster().forCacheNodes(CACHE_NAME).bcastRun(() => ignite$.cache(CACHE_NAME).clear(),
null)
              }
              finally {
                  popularNumbersQryTimer.cancel()

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/eb46cbbb/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCacheQueryExample.scala
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/eb46cbbb/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarSnowflakeSchemaExample.scala
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/eb46cbbb/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java
----------------------------------------------------------------------


Mime
View raw message