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-57
Commit: eb46cbbbed8f29060172787574d8c272b7bb37e5
Parents: e601a6d 878a289
Author: sevdokimov <[email protected]>
Authored: Wed Feb 4 17:12:18 2015 +0300
Committer: sevdokimov <[email protected]>
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
----------------------------------------------------------------------