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/ignite-54-55 Commit: eb46cbbbed8f29060172787574d8c272b7bb37e5 Parents: e601a6d 878a289 Author: sevdokimov <sevdoki...@gridgain.com> Authored: Wed Feb 4 17:12:18 2015 +0300 Committer: sevdokimov <sevdoki...@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 ----------------------------------------------------------------------