ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [36/50] [abbrv] incubator-ignite git commit: # ignite-6
Date Thu, 05 Feb 2015 11:50:47 GMT
# ignite-6


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

Branch: refs/heads/sprint-1
Commit: ce3259487fd3df1df8404e62f1ae2fadbc45cde9
Parents: 3bcf470 8db2a83
Author: sboikov <sboikov@gridgain.com>
Authored: Wed Feb 4 15:27:27 2015 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Wed Feb 4 15:27:27 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   |  21 +-
 .../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  |  74 -----
 .../CacheAtomicReferenceExample.java            | 110 --------
 .../CacheAtomicSequenceExample.java             |  96 -------
 .../CacheAtomicStampedExample.java              | 117 --------
 .../CacheCountDownLatchExample.java             |  96 -------
 .../datastructures/CacheQueueExample.java       | 207 --------------
 .../datastructures/CacheSetExample.java         | 187 -------------
 .../datastructures/IgniteAtomicLongExample.java |  74 +++++
 .../IgniteAtomicReferenceExample.java           | 110 ++++++++
 .../IgniteAtomicSequenceExample.java            |  96 +++++++
 .../IgniteAtomicStampedExample.java             | 117 ++++++++
 .../IgniteCountDownLatchExample.java            |  96 +++++++
 .../datastructures/IgniteQueueExample.java      | 206 ++++++++++++++
 .../datastructures/IgniteSetExample.java        | 186 +++++++++++++
 .../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        |  15 +-
 .../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 +-
 .../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 +
 .../test/config/load/mongo-multinode-foster.xml | 170 ------------
 .../GridProjectionForCachesSelfTest.java        |  27 +-
 .../ignite/testframework/junits/IgniteMock.java |   2 +
 ...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     |   5 +
 186 files changed, 3689 insertions(+), 3953 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ce325948/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/CacheAtomicLongExample.java
----------------------------------------------------------------------
diff --cc examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/CacheAtomicLongExample.java
index d70edc5,fc657f1..0000000
deleted file mode 100644,100644
--- a/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/CacheAtomicLongExample.java
+++ /dev/null
@@@ -1,74 -1,78 +1,0 @@@
--/*
-- * Licensed to the Apache Software Foundation (ASF) under one or more
-- * contributor license agreements.  See the NOTICE file distributed with
-- * this work for additional information regarding copyright ownership.
-- * The ASF licenses this file to You under the Apache License, Version 2.0
-- * (the "License"); you may not use this file except in compliance with
-- * the License.  You may obtain a copy of the License at
-- *
-- *      http://www.apache.org/licenses/LICENSE-2.0
-- *
-- * Unless required by applicable law or agreed to in writing, software
-- * distributed under the License is distributed on an "AS IS" BASIS,
-- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-- * See the License for the specific language governing permissions and
-- * limitations under the License.
-- */
--
--package org.apache.ignite.examples.datagrid.datastructures;
--
--import org.apache.ignite.*;
 -import org.apache.ignite.cache.datastructures.*;
--import org.apache.ignite.examples.datagrid.*;
--import org.apache.ignite.lang.*;
--
--import java.util.*;
--
--/**
-- * Demonstrates a simple usage of distributed atomic long.
-- * <p>
-- * Remote nodes should always be started with special configuration file which
-- * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-cache.xml'}.
-- * <p>
-- * Alternatively you can run {@link CacheNodeStartup} in another JVM which will
-  * start GridGain node with {@code examples/config/example-cache.xml} configuration.
 - * start node with {@code examples/config/example-cache.xml} configuration.
-- */
--public final class CacheAtomicLongExample {
 -    /** Cache name. */
 -    private static final String CACHE_NAME = "partitioned_tx";
 -
--    /** Number of retries */
--    private static final int RETRIES = 20;
--
--    /**
--     * Executes example.
--     *
--     * @param args Command line arguments, none required.
-      * @throws Exception If example execution failed.
 -     * @throws IgniteCheckedException If example execution failed.
--     */
-     public static void main(String[] args) throws Exception {
-         try (Ignite g = Ignition.start("examples/config/example-cache.xml")) {
 -    public static void main(String[] args) throws IgniteCheckedException {
 -        try (Ignite ignite = Ignition.start("examples/config/example-cache.xml")) {
--            System.out.println();
-             System.out.println(">>> Atomic long example started.");
 -            System.out.println(">>> Cache atomic long example started.");
--
-             // Make name for atomic long (by which it will be known in the grid).
 -            // Make name for atomic long (by which it will be known in the cluster).
--            String atomicName = UUID.randomUUID().toString();
--
-             // Initialize atomic long in grid.
-             final IgniteAtomicLong atomicLong = g.atomicLong(atomicName, 0, true);
 -            // Initialize atomic long in ignite.
 -            final CacheAtomicLong atomicLong = ignite.cache(CACHE_NAME).dataStructures().atomicLong(atomicName, 0, true);
--
--            System.out.println();
--            System.out.println("Atomic long initial value : " + atomicLong.get() + '.');
--
-             // Try increment atomic long from all grid nodes.
-             // Note that this node is also part of the grid.
-             g.compute().broadcast(new IgniteCallable<Object>() {
-                 @Override public Object call() {
 -            // Try increment atomic long from all nodes.
 -            // Note that this node is also part of the ignite cluster.
 -            ignite.compute(ignite.cluster().forCacheNodes(CACHE_NAME)).call(new IgniteCallable<Object>() {
 -                @Override public Object call() throws  Exception {
--                    for (int i = 0; i < RETRIES; i++)
--                        System.out.println("AtomicLong value has been incremented: " + atomicLong.incrementAndGet());
--
--                    return null;
--                }
--            });
--
--            System.out.println();
--            System.out.println("Atomic long value after successful CAS: " + atomicLong.get());
--        }
--    }
--}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ce325948/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/CacheAtomicReferenceExample.java
----------------------------------------------------------------------
diff --cc examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/CacheAtomicReferenceExample.java
index e2b8602,4ce2e7a..0000000
deleted file mode 100644,100644
--- a/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/CacheAtomicReferenceExample.java
+++ /dev/null
@@@ -1,110 -1,126 +1,0 @@@
--/*
-- * Licensed to the Apache Software Foundation (ASF) under one or more
-- * contributor license agreements.  See the NOTICE file distributed with
-- * this work for additional information regarding copyright ownership.
-- * The ASF licenses this file to You under the Apache License, Version 2.0
-- * (the "License"); you may not use this file except in compliance with
-- * the License.  You may obtain a copy of the License at
-- *
-- *      http://www.apache.org/licenses/LICENSE-2.0
-- *
-- * Unless required by applicable law or agreed to in writing, software
-- * distributed under the License is distributed on an "AS IS" BASIS,
-- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-- * See the License for the specific language governing permissions and
-- * limitations under the License.
-- */
--
--package org.apache.ignite.examples.datagrid.datastructures;
--
--import org.apache.ignite.*;
 -import org.apache.ignite.cache.datastructures.*;
--import org.apache.ignite.examples.datagrid.*;
--import org.apache.ignite.lang.*;
--
--import java.util.*;
--
--/**
-- * Demonstrates a simple usage of distributed atomic reference.
-- * <p>
-- * Remote nodes should always be started with special configuration file which
-- * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-cache.xml'}.
-- * <p>
-- * Alternatively you can run {@link CacheNodeStartup} in another JVM which will
-  * start GridGain node with {@code examples/config/example-cache.xml} configuration.
 - * start node with {@code examples/config/example-cache.xml} configuration.
-- */
--public final class CacheAtomicReferenceExample {
 -    /** Cache name. */
 -    private static final String CACHE_NAME = "partitioned_tx";
 -
--    /**
--     * Executes example.
--     *
--     * @param args Command line arguments, none required.
-      * @throws Exception If example execution failed.
 -     * @throws IgniteCheckedException If example execution failed.
--     */
-     public static void main(String[] args) throws Exception {
-         try (Ignite g = Ignition.start("examples/config/example-cache.xml")) {
 -    public static void main(String[] args) throws IgniteCheckedException {
 -        try (Ignite ignite = Ignition.start("examples/config/example-cache.xml")) {
--            System.out.println();
-             System.out.println(">>> Atomic reference example started.");
 -            System.out.println(">>> Cache atomic reference example started.");
--
--            // Make name of atomic reference.
--            final String refName = UUID.randomUUID().toString();
--
--            // Make value of atomic reference.
--            String val = UUID.randomUUID().toString();
--
-             // Initialize atomic reference in grid.
-             IgniteAtomicReference<String> ref = g.atomicReference(refName, val, true);
 -            // Initialize atomic reference in cluster.
 -            CacheAtomicReference<String> ref = ignite.cache(CACHE_NAME).dataStructures().
 -                atomicReference(refName, val, true);
--
--            System.out.println("Atomic reference initial value : " + ref.get() + '.');
--
-             // Make closure for checking atomic reference value on grid.
-             Runnable c = new ReferenceClosure(refName);
 -            // Make closure for checking atomic reference value on cluster.
 -            Runnable c = new ReferenceClosure(CACHE_NAME, refName);
--
-             // Check atomic reference on all grid nodes.
-             g.compute().run(c);
 -            // Check atomic reference on all cluster nodes.
 -            ignite.compute().run(c);
--
--            // Make new value of atomic reference.
--            String newVal = UUID.randomUUID().toString();
--
--            System.out.println("Try to change value of atomic reference with wrong expected value.");
--
--            ref.compareAndSet("WRONG EXPECTED VALUE", newVal); // Won't change.
--
-             // Check atomic reference on all grid nodes.
 -            // Check atomic reference on all cluster nodes.
--            // Atomic reference value shouldn't be changed.
-             g.compute().run(c);
 -            ignite.compute().run(c);
--
--            System.out.println("Try to change value of atomic reference with correct expected value.");
--
--            ref.compareAndSet(val, newVal);
--
-             // Check atomic reference on all grid nodes.
 -            // Check atomic reference on all cluster nodes.
--            // Atomic reference value should be changed.
-             g.compute().run(c);
 -            ignite.compute().run(c);
--        }
--
--        System.out.println();
--        System.out.println("Finished atomic reference example...");
-         System.out.println("Check all nodes for output (this node is also part of the grid).");
 -        System.out.println("Check all nodes for output (this node is also part of the cluster).");
--    }
--
--    /**
--     * Obtains atomic reference.
--     */
--    private static class ReferenceClosure implements IgniteRunnable {
 -        /** Cache name. */
 -        private final String cacheName;
 -
--        /** Reference name. */
--        private final String refName;
--
--        /**
 -         * @param cacheName Cache name.
--         * @param refName Reference name.
--         */
-         ReferenceClosure(String refName) {
 -        ReferenceClosure(String cacheName, String refName) {
 -            this.cacheName = cacheName;
--            this.refName = refName;
--        }
--
--        /** {@inheritDoc} */
--        @Override public void run() {
-             IgniteAtomicReference<String> ref = Ignition.ignite().atomicReference(refName, null, true);
 -            try {
 -                CacheAtomicReference<String> ref = Ignition.ignite().cache(cacheName).dataStructures().
 -                    atomicReference(refName, null, true);
--
-             System.out.println("Atomic reference value is " + ref.get() + '.');
 -                System.out.println("Atomic reference value is " + ref.get() + '.');
 -            }
 -            catch (IgniteCheckedException e) {
 -                throw new IgniteException(e);
 -            }
--        }
--    }
--}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ce325948/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/CacheAtomicSequenceExample.java
----------------------------------------------------------------------
diff --cc examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/CacheAtomicSequenceExample.java
index 71c131f,6317c3f..0000000
deleted file mode 100644,100644
--- a/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/CacheAtomicSequenceExample.java
+++ /dev/null
@@@ -1,96 -1,112 +1,0 @@@
--/*
-- * Licensed to the Apache Software Foundation (ASF) under one or more
-- * contributor license agreements.  See the NOTICE file distributed with
-- * this work for additional information regarding copyright ownership.
-- * The ASF licenses this file to You under the Apache License, Version 2.0
-- * (the "License"); you may not use this file except in compliance with
-- * the License.  You may obtain a copy of the License at
-- *
-- *      http://www.apache.org/licenses/LICENSE-2.0
-- *
-- * Unless required by applicable law or agreed to in writing, software
-- * distributed under the License is distributed on an "AS IS" BASIS,
-- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-- * See the License for the specific language governing permissions and
-- * limitations under the License.
-- */
--
--package org.apache.ignite.examples.datagrid.datastructures;
--
--import org.apache.ignite.*;
 -import org.apache.ignite.cache.datastructures.*;
--import org.apache.ignite.examples.datagrid.*;
--import org.apache.ignite.lang.*;
--
--import java.util.*;
--
--/**
-- * Demonstrates a simple usage of distributed atomic sequence.
-- * <p>
-- * Remote nodes should always be started with special configuration file which
-- * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-cache.xml'}.
-- * <p>
-- * Alternatively you can run {@link CacheNodeStartup} in another JVM which will
-  * start GridGain node with {@code examples/config/example-cache.xml} configuration.
 - * start node with {@code examples/config/example-cache.xml} configuration.
-- */
--public final class CacheAtomicSequenceExample {
 -    /** Cache name. */
 -    private static final String CACHE_NAME = "partitioned_tx";
 -
--    /** Number of retries */
--    private static final int RETRIES = 20;
--
--    /**
--     * Executes example.
--     *
--     * @param args Command line arguments, none required.
-      * @throws Exception If example execution failed.
 -     * @throws IgniteCheckedException If example execution failed.
--     */
-     public static void main(String[] args) throws Exception {
-         try (Ignite g = Ignition.start("examples/config/example-cache.xml")) {
 -    public static void main(String[] args) throws IgniteCheckedException {
 -        try (Ignite ignite = Ignition.start("examples/config/example-cache.xml")) {
--            System.out.println();
--            System.out.println(">>> Cache atomic sequence example started.");
--
--            // Make name of sequence.
--            final String seqName = UUID.randomUUID().toString();
--
-             // Initialize atomic sequence in grid.
-             IgniteAtomicSequence seq = g.atomicSequence(seqName, 0, true);
 -            // Initialize atomic sequence in ignite.
 -            CacheAtomicSequence seq = ignite.cache(CACHE_NAME).dataStructures().atomicSequence(seqName, 0, true);
--
--            // First value of atomic sequence on this node.
--            long firstVal = seq.get();
--
--            System.out.println("Sequence initial value: " + firstVal);
--
-             // Try increment atomic sequence on all grid nodes. Note that this node is also part of the grid.
-             g.compute().run(new SequenceClosure(seqName));
 -            // Try increment atomic sequence on all cluster nodes. Note that this node is also part of the cluster.
 -            ignite.compute().run(new SequenceClosure(CACHE_NAME, seqName));
--
--            System.out.println("Sequence after incrementing [expected=" + (firstVal + RETRIES) + ", actual=" +
--                seq.get() + ']');
--        }
--
--        System.out.println();
--        System.out.println("Finished atomic sequence example...");
-         System.out.println("Check all nodes for output (this node is also part of the grid).");
 -        System.out.println("Check all nodes for output (this node is also part of the cluster).");
--    }
--
--    /**
--     * Obtains atomic sequence.
--     */
--    private static class SequenceClosure implements IgniteRunnable {
 -        /** Cache name. */
 -        private final String cacheName;
 -
--        /** Sequence name. */
--        private final String seqName;
--
--        /**
 -         * @param cacheName Cache name.
--         * @param seqName Sequence name.
--         */
-         SequenceClosure(String seqName) {
 -        SequenceClosure(String cacheName, String seqName) {
 -            this.cacheName = cacheName;
--            this.seqName = seqName;
--        }
--
--        /** {@inheritDoc} */
--        @Override public void run() {
-             IgniteAtomicSequence seq = Ignition.ignite().atomicSequence(seqName, 0, true);
 -            try {
 -                CacheAtomicSequence seq = Ignition.ignite().cache(cacheName).dataStructures().
 -                    atomicSequence(seqName, 0, true);
--
-             for (int i = 0; i < RETRIES; i++)
-                 System.out.println("Sequence [currentValue=" + seq.get() + ", afterIncrement=" +
-                     seq.incrementAndGet() + ']');
 -                for (int i = 0; i < RETRIES; i++)
 -                    System.out.println("Sequence [currentValue=" + seq.get() + ", afterIncrement=" +
 -                        seq.incrementAndGet() + ']');
 -
 -            }
 -            catch (IgniteCheckedException e) {
 -                throw new IgniteException(e);
 -            }
--        }
--    }
--}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ce325948/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/CacheAtomicStampedExample.java
----------------------------------------------------------------------
diff --cc examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/CacheAtomicStampedExample.java
index b2031e0,dd54374..0000000
deleted file mode 100644,100644
--- a/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/CacheAtomicStampedExample.java
+++ /dev/null
@@@ -1,117 -1,132 +1,0 @@@
--/*
-- * Licensed to the Apache Software Foundation (ASF) under one or more
-- * contributor license agreements.  See the NOTICE file distributed with
-- * this work for additional information regarding copyright ownership.
-- * The ASF licenses this file to You under the Apache License, Version 2.0
-- * (the "License"); you may not use this file except in compliance with
-- * the License.  You may obtain a copy of the License at
-- *
-- *      http://www.apache.org/licenses/LICENSE-2.0
-- *
-- * Unless required by applicable law or agreed to in writing, software
-- * distributed under the License is distributed on an "AS IS" BASIS,
-- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-- * See the License for the specific language governing permissions and
-- * limitations under the License.
-- */
--
--package org.apache.ignite.examples.datagrid.datastructures;
--
--import org.apache.ignite.*;
 -import org.apache.ignite.cache.datastructures.*;
--import org.apache.ignite.examples.datagrid.*;
--import org.apache.ignite.lang.*;
--
--import java.util.*;
--
--/**
-- * Demonstrates a simple usage of distributed atomic stamped.
-- * <p>
-- * Remote nodes should always be started with special configuration file which
-- * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-cache.xml'}.
-- * <p>
-- * Alternatively you can run {@link CacheNodeStartup} in another JVM which will
-  * start GridGain node with {@code examples/config/example-cache.xml} configuration.
 - * start node with {@code examples/config/example-cache.xml} configuration.
-- */
--public final class CacheAtomicStampedExample {
 -    /** Cache name. */
 -    private static final String CACHE_NAME = "partitioned_tx";
 -
--    /**
--     * Executes example.
--     *
--     * @param args Command line arguments, none required.
-      * @throws Exception If example execution failed.
 -     * @throws IgniteCheckedException If example execution failed.
--     */
-     public static void main(String[] args) throws Exception {
-         try (Ignite g = Ignition.start("examples/config/example-cache.xml")) {
 -    public static void main(String[] args) throws IgniteCheckedException {
 -        try (Ignite ignite = Ignition.start("examples/config/example-cache.xml")) {
--            System.out.println();
-             System.out.println(">>> Atomic stamped example started.");
 -            System.out.println(">>> Cache atomic stamped example started.");
--
--            // Make name of atomic stamped.
--            String stampedName = UUID.randomUUID().toString();
--
--            // Make value of atomic stamped.
--            String val = UUID.randomUUID().toString();
--
--            // Make stamp of atomic stamped.
--            String stamp = UUID.randomUUID().toString();
--
--            // Initialize atomic stamped in cache.
-             IgniteAtomicStamped<String, String> stamped = g.atomicStamped(stampedName, val, stamp, true);
 -            CacheAtomicStamped<String, String> stamped = ignite.cache(CACHE_NAME).dataStructures().
 -                atomicStamped(stampedName, val, stamp, true);
--
--            System.out.println("Atomic stamped initial [value=" + stamped.value() + ", stamp=" + stamped.stamp() + ']');
--
-             // Make closure for checking atomic stamped on grid.
-             Runnable c = new StampedUpdateClosure(stampedName);
 -            // Make closure for checking atomic stamped on ignite.
 -            Runnable c = new StampedUpdateClosure(CACHE_NAME, stampedName);
--
-             // Check atomic stamped on all grid nodes.
-             g.compute().run(c);
 -            // Check atomic stamped on all cluster nodes.
 -            ignite.compute().run(c);
--
--            // Make new value of atomic stamped.
--            String newVal = UUID.randomUUID().toString();
--
--            // Make new stamp of atomic stamped.
--            String newStamp = UUID.randomUUID().toString();
--
--            System.out.println("Try to change value and stamp of atomic stamped with wrong expected value and stamp.");
--
--            stamped.compareAndSet("WRONG EXPECTED VALUE", newVal, "WRONG EXPECTED STAMP", newStamp);
--
-             // Check atomic stamped on all grid nodes.
 -            // Check atomic stamped on all cluster nodes.
--            // Atomic stamped value and stamp shouldn't be changed.
-             g.compute().run(c);
 -            ignite.compute().run(c);
--
--            System.out.println("Try to change value and stamp of atomic stamped with correct value and stamp.");
--
--            stamped.compareAndSet(val, newVal, stamp, newStamp);
--
-             // Check atomic stamped on all grid nodes.
 -            // Check atomic stamped on all cluster nodes.
--            // Atomic stamped value and stamp should be changed.
-             g.compute().run(c);
 -            ignite.compute().run(c);
--        }
--
--        System.out.println();
--        System.out.println("Finished atomic stamped example...");
-         System.out.println("Check all nodes for output (this node is also part of the grid).");
 -        System.out.println("Check all nodes for output (this node is also part of the cluster).");
--    }
--
--    /**
--     * Performs update of on an atomic stamped variable in cache.
--     */
--    private static class StampedUpdateClosure implements IgniteRunnable {
 -        /** Cache name. */
 -        private final String cacheName;
 -
--        /** Atomic stamped variable name. */
--        private final String stampedName;
--
--        /**
 -         * @param cacheName Cache name.
--         * @param stampedName Atomic stamped variable name.
--         */
-         StampedUpdateClosure(String stampedName) {
 -        StampedUpdateClosure(String cacheName, String stampedName) {
 -            this.cacheName = cacheName;
--            this.stampedName = stampedName;
--        }
--
--        /** {@inheritDoc} */
--        @Override public void run() {
-             IgniteAtomicStamped<String, String> stamped = Ignition.ignite().
-                 atomicStamped(stampedName, null, null, true);
 -            try {
 -                CacheAtomicStamped<String, String> stamped = Ignition.ignite().cache(cacheName).dataStructures().
 -                    atomicStamped(stampedName, null, null, true);
--
-             System.out.println("Atomic stamped [value=" + stamped.value() + ", stamp=" + stamped.stamp() + ']');
 -                System.out.println("Atomic stamped [value=" + stamped.value() + ", stamp=" + stamped.stamp() + ']');
 -            }
 -            catch (IgniteCheckedException e) {
 -                throw new IgniteException(e);
 -            }
--        }
--    }
--}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ce325948/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/CacheCountDownLatchExample.java
----------------------------------------------------------------------
diff --cc examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/CacheCountDownLatchExample.java
index c255f87,de01b34..0000000
deleted file mode 100644,100644
--- a/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/CacheCountDownLatchExample.java
+++ /dev/null
@@@ -1,96 -1,112 +1,0 @@@
--/*
-- * Licensed to the Apache Software Foundation (ASF) under one or more
-- * contributor license agreements.  See the NOTICE file distributed with
-- * this work for additional information regarding copyright ownership.
-- * The ASF licenses this file to You under the Apache License, Version 2.0
-- * (the "License"); you may not use this file except in compliance with
-- * the License.  You may obtain a copy of the License at
-- *
-- *      http://www.apache.org/licenses/LICENSE-2.0
-- *
-- * Unless required by applicable law or agreed to in writing, software
-- * distributed under the License is distributed on an "AS IS" BASIS,
-- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-- * See the License for the specific language governing permissions and
-- * limitations under the License.
-- */
--
--package org.apache.ignite.examples.datagrid.datastructures;
--
--import org.apache.ignite.*;
 -import org.apache.ignite.cache.datastructures.*;
--import org.apache.ignite.examples.datagrid.*;
--import org.apache.ignite.lang.*;
--
--import java.util.*;
--
--/**
-- * Demonstrates a simple usage of distributed count down latch.
-- * <p>
-- * Remote nodes should always be started with special configuration file which
-- * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-cache.xml'}.
-- * <p>
-- * Alternatively you can run {@link CacheNodeStartup} in another JVM which will
-  * start GridGain node with {@code examples/config/example-cache.xml} configuration.
 - * start node with {@code examples/config/example-cache.xml} configuration.
-- */
--public class CacheCountDownLatchExample {
 -    /** Cache name. */
 -    private static final String CACHE_NAME = "partitioned_tx";
 -
--    /** Number of latch initial count */
--    private static final int INITIAL_COUNT = 10;
--
--    /**
--     * Executes example.
--     *
--     * @param args Command line arguments, none required.
--     * @throws IgniteCheckedException If example execution failed.
--     */
-     public static void main(String[] args) throws Exception {
-         try (Ignite g = Ignition.start("examples/config/example-cache.xml")) {
 -    public static void main(String[] args) throws IgniteCheckedException {
 -        try (Ignite ignite = Ignition.start("examples/config/example-cache.xml")) {
--            System.out.println();
--            System.out.println(">>> Cache atomic countdown latch example started.");
--
--            // Make name of count down latch.
--            final String latchName = UUID.randomUUID().toString();
--
-             // Initialize count down latch in grid.
-             IgniteCountDownLatch latch = g.countDownLatch(latchName, INITIAL_COUNT, false, true);
 -            // Initialize count down latch in ignite.
 -            CacheCountDownLatch latch = ignite.cache(CACHE_NAME).dataStructures().
 -                countDownLatch(latchName, INITIAL_COUNT, false, true);
--
--            System.out.println("Latch initial value: " + latch.count());
--
-             // Start waiting on the latch on all grid nodes.
 -            // Start waiting on the latch on all cluster nodes.
--            for (int i = 0; i < INITIAL_COUNT; i++)
-                 g.compute().run(new LatchClosure(latchName));
 -                ignite.compute().run(new LatchClosure(CACHE_NAME, latchName));
--
--            // Wait for latch to go down which essentially means that all remote closures completed.
--            latch.await();
--
--            System.out.println("All latch closures have completed.");
--        }
--
--        System.out.println();
--        System.out.println("Finished count down latch example...");
-         System.out.println("Check all nodes for output (this node is also part of the grid).");
 -        System.out.println("Check all nodes for output (this node is also part of the cluster).");
--    }
--
--    /**
--     * Closure which simply waits on the latch on all nodes.
--     */
--    private static class LatchClosure implements IgniteRunnable {
 -        /** Cache name. */
 -        private final String cacheName;
 -
--        /** Latch name. */
--        private final String latchName;
--
--        /**
 -         * @param cacheName Cache name.
--         * @param latchName Latch name.
--         */
-         LatchClosure(String latchName) {
 -        LatchClosure(String cacheName, String latchName) {
 -            this.cacheName = cacheName;
--            this.latchName = latchName;
--        }
--
--        /** {@inheritDoc} */
--        @Override public void run() {
-             IgniteCountDownLatch latch = Ignition.ignite().countDownLatch(latchName, 1, false, true);
 -            try {
 -                CacheCountDownLatch latch = Ignition.ignite().cache(cacheName).dataStructures().
 -                    countDownLatch(latchName, 1, false, true);
--
-             int newCnt = latch.countDown();
 -                int newCnt = latch.countDown();
--
-             System.out.println("Counted down [newCnt=" + newCnt + ", nodeId=" + Ignition.ignite().cluster().localNode().id() + ']');
 -                System.out.println("Counted down [newCnt=" + newCnt + ", nodeId=" + Ignition.ignite().cluster().localNode().id() + ']');
 -            }
 -            catch (IgniteCheckedException e) {
 -                throw new RuntimeException(e);
 -            }
--        }
--    }
--}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ce325948/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/CacheQueueExample.java
----------------------------------------------------------------------
diff --cc examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/CacheQueueExample.java
index 4ae9395,a2d2b55..0000000
deleted file mode 100644,100644
--- a/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/CacheQueueExample.java
+++ /dev/null
@@@ -1,207 -1,214 +1,0 @@@
--/*
-- * Licensed to the Apache Software Foundation (ASF) under one or more
-- * contributor license agreements.  See the NOTICE file distributed with
-- * this work for additional information regarding copyright ownership.
-- * The ASF licenses this file to You under the Apache License, Version 2.0
-- * (the "License"); you may not use this file except in compliance with
-- * the License.  You may obtain a copy of the License at
-- *
-- *      http://www.apache.org/licenses/LICENSE-2.0
-- *
-- * Unless required by applicable law or agreed to in writing, software
-- * distributed under the License is distributed on an "AS IS" BASIS,
-- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-- * See the License for the specific language governing permissions and
-- * limitations under the License.
-- */
--
--package org.apache.ignite.examples.datagrid.datastructures;
--
--import org.apache.ignite.*;
- import org.apache.ignite.configuration.*;
 -import org.apache.ignite.cache.datastructures.*;
--import org.apache.ignite.examples.datagrid.*;
--import org.apache.ignite.lang.*;
--
--import java.util.*;
--
--/**
-  * Grid cache distributed queue example. This example demonstrates {@code FIFO} unbounded
 - * Ignite cache distributed queue example. This example demonstrates {@code FIFO} unbounded
-- * cache queue.
-- * <p>
-- * Remote nodes should always be started with special configuration file which
-- * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-cache.xml'}.
-- * <p>
-- * Alternatively you can run {@link CacheNodeStartup} in another JVM which will
-  * start GridGain node with {@code examples/config/example-cache.xml} configuration.
 - * start node with {@code examples/config/example-cache.xml} configuration.
-- */
--public class CacheQueueExample {
--    /** Cache name. */
--    private static final String CACHE_NAME = "partitioned_tx";
--
--    /** Number of retries */
--    private static final int RETRIES = 20;
--
--    /** Queue instance. */
-     private static IgniteQueue<String> queue;
 -    private static CacheQueue<String> queue;
--
--    /**
--     * Executes example.
--     *
--     * @param args Command line arguments, none required.
-      * @throws Exception If example execution failed.
 -     * @throws IgniteCheckedException If example execution failed.
--     */
-     public static void main(String[] args) throws Exception {
-         try (Ignite g = Ignition.start("examples/config/example-cache.xml")) {
 -    public static void main(String[] args) throws IgniteCheckedException {
 -        try (Ignite ignite = Ignition.start("examples/config/example-cache.xml")) {
--            System.out.println();
--            System.out.println(">>> Cache queue example started.");
--
--            // Make queue name.
--            String queueName = UUID.randomUUID().toString();
--
-             queue = initializeQueue(g, queueName);
 -            queue = initializeQueue(ignite, queueName);
--
-             readFromQueue(g);
 -            readFromQueue(ignite);
--
-             writeToQueue(g);
 -            writeToQueue(ignite);
--
-             clearAndRemoveQueue(g);
 -            clearAndRemoveQueue(ignite);
--        }
--
--        System.out.println("Cache queue example finished.");
--    }
--
--    /**
--     * Initialize queue.
--     *
-      * @param g Grid.
 -     * @param ignite Ignite.
--     * @param queueName Name of queue.
--     * @return Queue.
-      * @throws IgniteException If execution failed.
 -     * @throws IgniteCheckedException If execution failed.
--     */
-     private static IgniteQueue<String> initializeQueue(Ignite g, String queueName) throws IgniteException {
-         IgniteCollectionConfiguration colCfg = new IgniteCollectionConfiguration();
- 
-         colCfg.setCacheName(CACHE_NAME);
- 
 -    private static CacheQueue<String> initializeQueue(Ignite ignite, String queueName) throws IgniteCheckedException {
--        // Initialize new FIFO queue.
-         IgniteQueue<String> queue = g.queue(queueName, colCfg, 0, true);
 -        CacheQueue<String> queue = ignite.cache(CACHE_NAME).dataStructures().queue(queueName, 0, false, true);
--
--        // Initialize queue items.
--        // We will be use blocking operation and queue size must be appropriated.
-         for (int i = 0; i < g.cluster().nodes().size() * RETRIES * 2; i++)
 -        for (int i = 0; i < ignite.cluster().nodes().size() * RETRIES * 2; i++)
--            queue.put(Integer.toString(i));
--
--        System.out.println("Queue size after initializing: " + queue.size());
--
--        return queue;
--    }
--
--    /**
--     * Read items from head and tail of queue.
--     *
-      * @param g Grid.
 -     * @param ignite Ignite.
--     * @throws IgniteException If failed.
--     */
-     private static void readFromQueue(Ignite g) throws IgniteException {
 -    private static void readFromQueue(Ignite ignite) throws IgniteException {
--        final String queueName = queue.name();
--
--        // Read queue items on each node.
-         g.compute().run(new QueueClosure(queueName, false));
 -        ignite.compute().run(new QueueClosure(CACHE_NAME, queueName, false));
--
--        System.out.println("Queue size after reading [expected=0, actual=" + queue.size() + ']');
--    }
--
--    /**
--     * Write items into queue.
--     *
-      * @param g Grid.
 -     * @param ignite Ignite.
--     * @throws IgniteException If failed.
--     */
-     private static void writeToQueue(Ignite g) throws IgniteException {
 -    private static void writeToQueue(Ignite ignite) throws IgniteException {
--        final String queueName = queue.name();
--
--        // Write queue items on each node.
-         g.compute().run(new QueueClosure(queueName, true));
 -        ignite.compute().run(new QueueClosure(CACHE_NAME, queueName, true));
--
-         System.out.println("Queue size after writing [expected=" + g.cluster().nodes().size() * RETRIES +
 -        System.out.println("Queue size after writing [expected=" + ignite.cluster().nodes().size() * RETRIES +
--            ", actual=" + queue.size() + ']');
--
--        System.out.println("Iterate over queue.");
--
--        // Iterate over queue.
--        for (String item : queue)
--            System.out.println("Queue item: " + item);
--    }
--
--    /**
--     * Clear and remove queue.
--     *
-      * @param g Grid.
-      * @throws IgniteException If execution failed.
 -     * @param ignite Ignite.
 -     * @throws IgniteCheckedException If execution failed.
--     */
-     private static void clearAndRemoveQueue(Ignite g) throws IgniteException {
 -    private static void clearAndRemoveQueue(Ignite ignite) throws IgniteCheckedException {
--        System.out.println("Queue size before clearing: " + queue.size());
--
--        // Clear queue.
--        queue.clear();
--
--        System.out.println("Queue size after clearing: " + queue.size());
--
-         // Remove queue.
-         queue.close();
 -        // Remove queue from cache.
 -        ignite.cache(CACHE_NAME).dataStructures().removeQueue(queue.name());
--
--        // Try to work with removed queue.
--        try {
--            queue.poll();
--        }
--        catch (IgniteException expected) {
--            System.out.println("Expected exception - " + expected.getMessage());
--        }
--    }
--
--    /**
--     * Closure to populate or poll the queue.
--     */
--    private static class QueueClosure implements IgniteRunnable {
 -        /** Cache name. */
 -        private final String cacheName;
 -
--        /** Queue name. */
--        private final String queueName;
--
--        /** Flag indicating whether to put or poll. */
--        private final boolean put;
--
--        /**
 -         * @param cacheName Cache name.
--         * @param queueName Queue name.
--         * @param put Flag indicating whether to put or poll.
--         */
-         QueueClosure(String queueName, boolean put) {
 -        QueueClosure(String cacheName, String queueName, boolean put) {
 -            this.cacheName = cacheName;
--            this.queueName = queueName;
--            this.put = put;
--        }
--
--        /** {@inheritDoc} */
--        @Override public void run() {
-             IgniteQueue<String> queue = Ignition.ignite().queue(queueName, null, 0, false);
 -            try {
 -                CacheQueue<String> queue = Ignition.ignite().cache(cacheName).dataStructures().
 -                    queue(queueName, 0, false, true);
--
-             if (put) {
-                 UUID locId = Ignition.ignite().cluster().localNode().id();
 -                if (put) {
 -                    UUID locId = Ignition.ignite().cluster().localNode().id();
--
-                 for (int i = 0; i < RETRIES; i++) {
-                     String item = locId + "_" + Integer.toString(i);
 -                    for (int i = 0; i < RETRIES; i++) {
 -                        String item = locId + "_" + Integer.toString(i);
--
-                     queue.put(item);
 -                        queue.put(item);
--
-                     System.out.println("Queue item has been added: " + item);
 -                        System.out.println("Queue item has been added: " + item);
 -                    }
--                }
-             }
-             else {
-                 // Take items from queue head.
-                 for (int i = 0; i < RETRIES; i++)
-                     System.out.println("Queue item has been read from queue head: " + queue.take());
 -                else {
 -                    // Take items from queue head.
 -                    for (int i = 0; i < RETRIES; i++)
 -                        System.out.println("Queue item has been read from queue head: " + queue.take());
--
-                 // Take items from queue head once again.
-                 for (int i = 0; i < RETRIES; i++)
-                     System.out.println("Queue item has been read from queue head: " + queue.poll());
 -                    // Take items from queue head once again.
 -                    for (int i = 0; i < RETRIES; i++)
 -                        System.out.println("Queue item has been read from queue head: " + queue.poll());
 -                }
 -            }
 -            catch (IgniteCheckedException e) {
 -                throw new RuntimeException(e);
--            }
--        }
--    }
--}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ce325948/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/CacheSetExample.java
----------------------------------------------------------------------
diff --cc examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/CacheSetExample.java
index a961f30,6de65c9..0000000
deleted file mode 100644,100644
--- a/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/CacheSetExample.java
+++ /dev/null
@@@ -1,187 -1,193 +1,0 @@@
--/*
-- * Licensed to the Apache Software Foundation (ASF) under one or more
-- * contributor license agreements.  See the NOTICE file distributed with
-- * this work for additional information regarding copyright ownership.
-- * The ASF licenses this file to You under the Apache License, Version 2.0
-- * (the "License"); you may not use this file except in compliance with
-- * the License.  You may obtain a copy of the License at
-- *
-- *      http://www.apache.org/licenses/LICENSE-2.0
-- *
-- * Unless required by applicable law or agreed to in writing, software
-- * distributed under the License is distributed on an "AS IS" BASIS,
-- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-- * See the License for the specific language governing permissions and
-- * limitations under the License.
-- */
--
--package org.apache.ignite.examples.datagrid.datastructures;
--
--import org.apache.ignite.*;
- import org.apache.ignite.configuration.*;
 -import org.apache.ignite.cache.datastructures.*;
--import org.apache.ignite.examples.datagrid.*;
--import org.apache.ignite.lang.*;
--
--import java.util.*;
--
--/**
-  * Grid cache distributed set example.
 - * Ignite cache distributed set example.
-- * <p>
-- * Remote nodes should always be started with special configuration file which
-- * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-cache.xml'}.
-- * <p>
-- * Alternatively you can run {@link CacheNodeStartup} in another JVM which will
-  * start GridGain node with {@code examples/config/example-cache.xml} configuration.
 - * start node with {@code examples/config/example-cache.xml} configuration.
-- */
--public class CacheSetExample {
--    /** Cache name. */
--    private static final String CACHE_NAME = "partitioned_tx";
--
--    /** Set instance. */
-     private static IgniteSet<String> set;
 -    private static CacheSet<String> set;
--
--    /**
--     * Executes example.
--     *
--     * @param args Command line arguments, none required.
-      * @throws Exception If example execution failed.
 -     * @throws IgniteCheckedException If example execution failed.
--     */
-     public static void main(String[] args) throws Exception {
-         try (Ignite g = Ignition.start("examples/config/example-cache.xml")) {
 -    public static void main(String[] args) throws IgniteCheckedException {
 -        try (Ignite ignite = Ignition.start("examples/config/example-cache.xml")) {
--            System.out.println();
--            System.out.println(">>> Cache set example started.");
--
--            // Make set name.
--            String setName = UUID.randomUUID().toString();
--
-             set = initializeSet(g, setName);
 -            set = initializeSet(ignite, setName);
--
-             writeToSet(g);
 -            writeToSet(ignite);
--
-             clearAndRemoveSet(g);
 -            clearAndRemoveSet(ignite);
--        }
--
--        System.out.println("Cache set example finished.");
--    }
--
--    /**
--     * Initialize set.
--     *
-      * @param g Grid.
 -     * @param ignite Ignite.
--     * @param setName Name of set.
--     * @return Set.
--     * @throws IgniteException If execution failed.
--     */
-     private static IgniteSet<String> initializeSet(Ignite g, String setName) throws IgniteException {
-         IgniteCollectionConfiguration setCfg = new IgniteCollectionConfiguration();
- 
-         setCfg.setCacheName(CACHE_NAME);
- 
 -    private static CacheSet<String> initializeSet(Ignite ignite, String setName) throws IgniteCheckedException {
--        // Initialize new set.
-         IgniteSet<String> set = g.set(setName, setCfg, true);
 -        CacheSet<String> set = ignite.cache(CACHE_NAME).dataStructures().set(setName, false, true);
--
--        // Initialize set items.
--        for (int i = 0; i < 10; i++)
--            set.add(Integer.toString(i));
--
--        System.out.println("Set size after initializing: " + set.size());
--
--        return set;
--    }
--
--    /**
--     * Write items into set.
--     *
-      * @param g Grid.
 -     * @param ignite Ignite.
--     * @throws IgniteException If failed.
--     */
-     private static void writeToSet(Ignite g) throws IgniteException {
 -    private static void writeToSet(Ignite ignite) throws IgniteException {
--        final String setName = set.name();
--
--        // Write set items on each node.
-         g.compute().broadcast(new SetClosure(setName));
 -        ignite.compute().broadcast(new SetClosure(CACHE_NAME, setName));
--
-         System.out.println("Set size after writing [expected=" + (10 + g.cluster().nodes().size() * 5) +
 -        System.out.println("Set size after writing [expected=" + (10 + ignite.cluster().nodes().size() * 5) +
--            ", actual=" + set.size() + ']');
--
--        System.out.println("Iterate over set.");
--
--        // Iterate over set.
--        for (String item : set)
--            System.out.println("Set item: " + item);
--
--        // Set API usage examples.
--        if (!set.contains("0"))
--            throw new RuntimeException("Set should contain '0' among its elements.");
--
--        if (set.add("0"))
--            throw new RuntimeException("Set should not allow duplicates.");
--
--        if (!set.remove("0"))
--            throw new RuntimeException("Set should correctly remove elements.");
--
--        if (set.contains("0"))
--            throw new RuntimeException("Set should not contain '0' among its elements.");
--
--        if (!set.add("0"))
--            throw new RuntimeException("Set should correctly add new elements.");
--    }
--
--    /**
--     * Clear and remove set.
--     *
-      * @param g Grid.
-      * @throws IgniteException If execution failed.
 -     * @param ignite Ignite.
 -     * @throws IgniteCheckedException If execution failed.
--     */
-     private static void clearAndRemoveSet(Ignite g) throws IgniteException {
 -    private static void clearAndRemoveSet(Ignite ignite) throws IgniteCheckedException {
--        System.out.println("Set size before clearing: " + set.size());
--
--        // Clear set.
--        set.clear();
--
--        System.out.println("Set size after clearing: " + set.size());
--
-         // Remove set.
-         set.close();
 -        // Remove set from cache.
 -        ignite.cache(CACHE_NAME).dataStructures().removeSet(set.name());
--
--        System.out.println("Set was removed: " + set.removed());
--
--        // Try to work with removed set.
--        try {
--            set.contains("1");
--        }
--        catch (IgniteException expected) {
--            System.out.println("Expected exception - " + expected.getMessage());
--        }
--    }
--
--    /**
--     * Closure to populate the set.
--     */
--    private static class SetClosure implements IgniteRunnable {
 -        /** Cache name. */
 -        private final String cacheName;
 -
--        /** Set name. */
--        private final String setName;
--
--        /**
 -         * @param cacheName Cache name.
--         * @param setName Set name.
--         */
-         SetClosure(String setName) {
 -        SetClosure(String cacheName, String setName) {
 -            this.cacheName = cacheName;
--            this.setName = setName;
--        }
--
--        /** {@inheritDoc} */
--        @Override public void run() {
-             IgniteSet<String> set = Ignition.ignite().set(setName, null, false);
 -            try {
 -                CacheSet<String> set = Ignition.ignite().cache(cacheName).dataStructures().set(setName, false, true);
--
-             UUID locId = Ignition.ignite().cluster().localNode().id();
 -                UUID locId = Ignition.ignite().cluster().localNode().id();
--
-             for (int i = 0; i < 5; i++) {
-                 String item = locId + "_" + Integer.toString(i);
 -                for (int i = 0; i < 5; i++) {
 -                    String item = locId + "_" + Integer.toString(i);
--
-                 set.add(item);
 -                    set.add(item);
--
-                 System.out.println("Set item has been added: " + item);
 -                    System.out.println("Set item has been added: " + item);
 -                }
 -            }
 -            catch (IgniteCheckedException e) {
 -                throw new RuntimeException(e);
--            }
--        }
--    }
--}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ce325948/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteAtomicLongExample.java
----------------------------------------------------------------------
diff --cc examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteAtomicLongExample.java
index 0000000,0000000..969de3e
new file mode 100644
--- /dev/null
+++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteAtomicLongExample.java
@@@ -1,0 -1,0 +1,74 @@@
++/*
++ * Licensed to the Apache Software Foundation (ASF) under one or more
++ * contributor license agreements.  See the NOTICE file distributed with
++ * this work for additional information regarding copyright ownership.
++ * The ASF licenses this file to You under the Apache License, Version 2.0
++ * (the "License"); you may not use this file except in compliance with
++ * the License.  You may obtain a copy of the License at
++ *
++ *      http://www.apache.org/licenses/LICENSE-2.0
++ *
++ * Unless required by applicable law or agreed to in writing, software
++ * distributed under the License is distributed on an "AS IS" BASIS,
++ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
++ * See the License for the specific language governing permissions and
++ * limitations under the License.
++ */
++
++package org.apache.ignite.examples.datagrid.datastructures;
++
++import org.apache.ignite.*;
++import org.apache.ignite.examples.datagrid.*;
++import org.apache.ignite.lang.*;
++
++import java.util.*;
++
++/**
++ * Demonstrates a simple usage of distributed atomic long.
++ * <p>
++ * Remote nodes should always be started with special configuration file which
++ * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-cache.xml'}.
++ * <p>
++ * Alternatively you can run {@link CacheNodeStartup} in another JVM which will
++ * start node with {@code examples/config/example-cache.xml} configuration.
++ */
++public final class IgniteAtomicLongExample {
++    /** Number of retries */
++    private static final int RETRIES = 20;
++
++    /**
++     * Executes example.
++     *
++     * @param args Command line arguments, none required.
++     * @throws Exception If example execution failed.
++     */
++    public static void main(String[] args) throws Exception {
++        try (Ignite ignite = Ignition.start("examples/config/example-cache.xml")) {
++            System.out.println();
++            System.out.println(">>> Atomic long example started.");
++
++            // Make name for atomic long (by which it will be known in the cluster).
++            String atomicName = UUID.randomUUID().toString();
++
++            // Initialize atomic long.
++            final IgniteAtomicLong atomicLong = ignite.atomicLong(atomicName, 0, true);
++
++            System.out.println();
++            System.out.println("Atomic long initial value : " + atomicLong.get() + '.');
++
++            // Try increment atomic long from all grid nodes.
++            // Note that this node is also part of the grid.
++            ignite.compute().broadcast(new IgniteCallable<Object>() {
++                @Override public Object call() {
++                    for (int i = 0; i < RETRIES; i++)
++                        System.out.println("AtomicLong value has been incremented: " + atomicLong.incrementAndGet());
++
++                    return null;
++                }
++            });
++
++            System.out.println();
++            System.out.println("Atomic long value after successful CAS: " + atomicLong.get());
++        }
++    }
++}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ce325948/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteAtomicReferenceExample.java
----------------------------------------------------------------------
diff --cc examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteAtomicReferenceExample.java
index 0000000,0000000..cfd9873
new file mode 100644
--- /dev/null
+++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteAtomicReferenceExample.java
@@@ -1,0 -1,0 +1,110 @@@
++/*
++ * Licensed to the Apache Software Foundation (ASF) under one or more
++ * contributor license agreements.  See the NOTICE file distributed with
++ * this work for additional information regarding copyright ownership.
++ * The ASF licenses this file to You under the Apache License, Version 2.0
++ * (the "License"); you may not use this file except in compliance with
++ * the License.  You may obtain a copy of the License at
++ *
++ *      http://www.apache.org/licenses/LICENSE-2.0
++ *
++ * Unless required by applicable law or agreed to in writing, software
++ * distributed under the License is distributed on an "AS IS" BASIS,
++ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
++ * See the License for the specific language governing permissions and
++ * limitations under the License.
++ */
++
++package org.apache.ignite.examples.datagrid.datastructures;
++
++import org.apache.ignite.*;
++import org.apache.ignite.examples.datagrid.*;
++import org.apache.ignite.lang.*;
++
++import java.util.*;
++
++/**
++ * Demonstrates a simple usage of distributed atomic reference.
++ * <p>
++ * Remote nodes should always be started with special configuration file which
++ * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-cache.xml'}.
++ * <p>
++ * Alternatively you can run {@link CacheNodeStartup} in another JVM which will
++ * start node with {@code examples/config/example-cache.xml} configuration.
++ */
++public final class IgniteAtomicReferenceExample {
++    /**
++     * Executes example.
++     *
++     * @param args Command line arguments, none required.
++     * @throws Exception If example execution failed.
++     */
++    public static void main(String[] args) throws Exception {
++        try (Ignite ignite = Ignition.start("examples/config/example-cache.xml")) {
++            System.out.println();
++            System.out.println(">>> Atomic reference example started.");
++
++            // Make name of atomic reference.
++            final String refName = UUID.randomUUID().toString();
++
++            // Make value of atomic reference.
++            String val = UUID.randomUUID().toString();
++
++            // Initialize atomic reference.
++            IgniteAtomicReference<String> ref = ignite.atomicReference(refName, val, true);
++
++            System.out.println("Atomic reference initial value : " + ref.get() + '.');
++
++            // Make closure for checking atomic reference value on grid.
++            Runnable c = new ReferenceClosure(refName);
++
++            // Check atomic reference on all cluster nodes.
++            ignite.compute().run(c);
++
++            // Make new value of atomic reference.
++            String newVal = UUID.randomUUID().toString();
++
++            System.out.println("Try to change value of atomic reference with wrong expected value.");
++
++            ref.compareAndSet("WRONG EXPECTED VALUE", newVal); // Won't change.
++
++            // Check atomic reference on all cluster nodes.
++            // Atomic reference value shouldn't be changed.
++            ignite.compute().run(c);
++
++            System.out.println("Try to change value of atomic reference with correct expected value.");
++
++            ref.compareAndSet(val, newVal);
++
++            // Check atomic reference on all cluster nodes.
++            // Atomic reference value should be changed.
++            ignite.compute().run(c);
++        }
++
++        System.out.println();
++        System.out.println("Finished atomic reference example...");
++        System.out.println("Check all nodes for output (this node is also part of the cluster).");
++    }
++
++    /**
++     * Obtains atomic reference.
++     */
++    private static class ReferenceClosure implements IgniteRunnable {
++        /** Reference name. */
++        private final String refName;
++
++        /**
++         * @param refName Reference name.
++         */
++        ReferenceClosure(String refName) {
++            this.refName = refName;
++        }
++
++        /** {@inheritDoc} */
++        @Override public void run() {
++            IgniteAtomicReference<String> ref = Ignition.ignite().atomicReference(refName, null, true);
++
++            System.out.println("Atomic reference value is " + ref.get() + '.');
++        }
++    }
++}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ce325948/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteAtomicSequenceExample.java
----------------------------------------------------------------------
diff --cc examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteAtomicSequenceExample.java
index 0000000,0000000..9172733
new file mode 100644
--- /dev/null
+++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteAtomicSequenceExample.java
@@@ -1,0 -1,0 +1,96 @@@
++/*
++ * Licensed to the Apache Software Foundation (ASF) under one or more
++ * contributor license agreements.  See the NOTICE file distributed with
++ * this work for additional information regarding copyright ownership.
++ * The ASF licenses this file to You under the Apache License, Version 2.0
++ * (the "License"); you may not use this file except in compliance with
++ * the License.  You may obtain a copy of the License at
++ *
++ *      http://www.apache.org/licenses/LICENSE-2.0
++ *
++ * Unless required by applicable law or agreed to in writing, software
++ * distributed under the License is distributed on an "AS IS" BASIS,
++ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
++ * See the License for the specific language governing permissions and
++ * limitations under the License.
++ */
++
++package org.apache.ignite.examples.datagrid.datastructures;
++
++import org.apache.ignite.*;
++import org.apache.ignite.examples.datagrid.*;
++import org.apache.ignite.lang.*;
++
++import java.util.*;
++
++/**
++ * Demonstrates a simple usage of distributed atomic sequence.
++ * <p>
++ * Remote nodes should always be started with special configuration file which
++ * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-cache.xml'}.
++ * <p>
++ * Alternatively you can run {@link CacheNodeStartup} in another JVM which will
++ * start node with {@code examples/config/example-cache.xml} configuration.
++ */
++public final class IgniteAtomicSequenceExample {
++    /** Number of retries */
++    private static final int RETRIES = 20;
++
++    /**
++     * Executes example.
++     *
++     * @param args Command line arguments, none required.
++     * @throws Exception If example execution failed.
++     */
++    public static void main(String[] args) throws Exception {
++        try (Ignite ignite = Ignition.start("examples/config/example-cache.xml")) {
++            System.out.println();
++            System.out.println(">>> Cache atomic sequence example started.");
++
++            // Make name of sequence.
++            final String seqName = UUID.randomUUID().toString();
++
++            // Initialize atomic sequence.
++            IgniteAtomicSequence seq = ignite.atomicSequence(seqName, 0, true);
++
++            // First value of atomic sequence on this node.
++            long firstVal = seq.get();
++
++            System.out.println("Sequence initial value: " + firstVal);
++
++            // Try increment atomic sequence on all grid nodes. Note that this node is also part of the grid.
++            ignite.compute().run(new SequenceClosure(seqName));
++
++            System.out.println("Sequence after incrementing [expected=" + (firstVal + RETRIES) + ", actual=" +
++                seq.get() + ']');
++        }
++
++        System.out.println();
++        System.out.println("Finished atomic sequence example...");
++        System.out.println("Check all nodes for output (this node is also part of the cluster).");
++    }
++
++    /**
++     * Obtains atomic sequence.
++     */
++    private static class SequenceClosure implements IgniteRunnable {
++        /** Sequence name. */
++        private final String seqName;
++
++        /**
++         * @param seqName Sequence name.
++         */
++        SequenceClosure(String seqName) {
++            this.seqName = seqName;
++        }
++
++        /** {@inheritDoc} */
++        @Override public void run() {
++            IgniteAtomicSequence seq = Ignition.ignite().atomicSequence(seqName, 0, true);
++
++            for (int i = 0; i < RETRIES; i++)
++                System.out.println("Sequence [currentValue=" + seq.get() + ", afterIncrement=" +
++                    seq.incrementAndGet() + ']');
++        }
++    }
++}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ce325948/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteAtomicStampedExample.java
----------------------------------------------------------------------
diff --cc examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteAtomicStampedExample.java
index 0000000,0000000..ea083e1
new file mode 100644
--- /dev/null
+++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteAtomicStampedExample.java
@@@ -1,0 -1,0 +1,117 @@@
++/*
++ * Licensed to the Apache Software Foundation (ASF) under one or more
++ * contributor license agreements.  See the NOTICE file distributed with
++ * this work for additional information regarding copyright ownership.
++ * The ASF licenses this file to You under the Apache License, Version 2.0
++ * (the "License"); you may not use this file except in compliance with
++ * the License.  You may obtain a copy of the License at
++ *
++ *      http://www.apache.org/licenses/LICENSE-2.0
++ *
++ * Unless required by applicable law or agreed to in writing, software
++ * distributed under the License is distributed on an "AS IS" BASIS,
++ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
++ * See the License for the specific language governing permissions and
++ * limitations under the License.
++ */
++
++package org.apache.ignite.examples.datagrid.datastructures;
++
++import org.apache.ignite.*;
++import org.apache.ignite.examples.datagrid.*;
++import org.apache.ignite.lang.*;
++
++import java.util.*;
++
++/**
++ * Demonstrates a simple usage of distributed atomic stamped.
++ * <p>
++ * Remote nodes should always be started with special configuration file which
++ * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-cache.xml'}.
++ * <p>
++ * Alternatively you can run {@link CacheNodeStartup} in another JVM which will
++ * start node with {@code examples/config/example-cache.xml} configuration.
++ */
++public final class IgniteAtomicStampedExample {
++    /**
++     * Executes example.
++     *
++     * @param args Command line arguments, none required.
++     * @throws Exception If example execution failed.
++     */
++    public static void main(String[] args) throws Exception {
++        try (Ignite ignite = Ignition.start("examples/config/example-cache.xml")) {
++            System.out.println();
++            System.out.println(">>> Atomic stamped example started.");
++
++            // Make name of atomic stamped.
++            String stampedName = UUID.randomUUID().toString();
++
++            // Make value of atomic stamped.
++            String val = UUID.randomUUID().toString();
++
++            // Make stamp of atomic stamped.
++            String stamp = UUID.randomUUID().toString();
++
++            // Initialize atomic stamped in cache.
++            IgniteAtomicStamped<String, String> stamped = ignite.atomicStamped(stampedName, val, stamp, true);
++
++            System.out.println("Atomic stamped initial [value=" + stamped.value() + ", stamp=" + stamped.stamp() + ']');
++
++            // Make closure for checking atomic stamped on grid.
++            Runnable c = new StampedUpdateClosure(stampedName);
++
++            // Check atomic stamped on all cluster nodes.
++            ignite.compute().run(c);
++
++            // Make new value of atomic stamped.
++            String newVal = UUID.randomUUID().toString();
++
++            // Make new stamp of atomic stamped.
++            String newStamp = UUID.randomUUID().toString();
++
++            System.out.println("Try to change value and stamp of atomic stamped with wrong expected value and stamp.");
++
++            stamped.compareAndSet("WRONG EXPECTED VALUE", newVal, "WRONG EXPECTED STAMP", newStamp);
++
++            // Check atomic stamped on all cluster nodes.
++            // Atomic stamped value and stamp shouldn't be changed.
++            ignite.compute().run(c);
++
++            System.out.println("Try to change value and stamp of atomic stamped with correct value and stamp.");
++
++            stamped.compareAndSet(val, newVal, stamp, newStamp);
++
++            // Check atomic stamped on all cluster nodes.
++            // Atomic stamped value and stamp should be changed.
++            ignite.compute().run(c);
++        }
++
++        System.out.println();
++        System.out.println("Finished atomic stamped example...");
++        System.out.println("Check all nodes for output (this node is also part of the cluster).");
++    }
++
++    /**
++     * Performs update of on an atomic stamped variable in cache.
++     */
++    private static class StampedUpdateClosure implements IgniteRunnable {
++        /** Atomic stamped variable name. */
++        private final String stampedName;
++
++        /**
++         * @param stampedName Atomic stamped variable name.
++         */
++        StampedUpdateClosure(String stampedName) {
++            this.stampedName = stampedName;
++        }
++
++        /** {@inheritDoc} */
++        @Override public void run() {
++            IgniteAtomicStamped<String, String> stamped = Ignition.ignite().
++                atomicStamped(stampedName, null, null, true);
++
++            System.out.println("Atomic stamped [value=" + stamped.value() + ", stamp=" + stamped.stamp() + ']');
++        }
++    }
++}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ce325948/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteCountDownLatchExample.java
----------------------------------------------------------------------
diff --cc examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteCountDownLatchExample.java
index 0000000,0000000..f7a282c
new file mode 100644
--- /dev/null
+++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/datastructures/IgniteCountDownLatchExample.java
@@@ -1,0 -1,0 +1,96 @@@
++/*
++ * Licensed to the Apache Software Foundation (ASF) under one or more
++ * contributor license agreements.  See the NOTICE file distributed with
++ * this work for additional information regarding copyright ownership.
++ * The ASF licenses this file to You under the Apache License, Version 2.0
++ * (the "License"); you may not use this file except in compliance with
++ * the License.  You may obtain a copy of the License at
++ *
++ *      http://www.apache.org/licenses/LICENSE-2.0
++ *
++ * Unless required by applicable law or agreed to in writing, software
++ * distributed under the License is distributed on an "AS IS" BASIS,
++ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
++ * See the License for the specific language governing permissions and
++ * limitations under the License.
++ */
++
++package org.apache.ignite.examples.datagrid.datastructures;
++
++import org.apache.ignite.*;
++import org.apache.ignite.examples.datagrid.*;
++import org.apache.ignite.lang.*;
++
++import java.util.*;
++
++/**
++ * Demonstrates a simple usage of distributed count down latch.
++ * <p>
++ * Remote nodes should always be started with special configuration file which
++ * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-cache.xml'}.
++ * <p>
++ * Alternatively you can run {@link CacheNodeStartup} in another JVM which will
++ * start node with {@code examples/config/example-cache.xml} configuration.
++ */
++public class IgniteCountDownLatchExample {
++    /** Number of latch initial count */
++    private static final int INITIAL_COUNT = 10;
++
++    /**
++     * Executes example.
++     *
++     * @param args Command line arguments, none required.
++     * @throws IgniteCheckedException If example execution failed.
++     */
++    public static void main(String[] args) throws IgniteCheckedException {
++        try (Ignite ignite = Ignition.start("examples/config/example-cache.xml")) {
++            System.out.println();
++            System.out.println(">>> Cache atomic countdown latch example started.");
++
++            // Make name of count down latch.
++            final String latchName = UUID.randomUUID().toString();
++
++            // Initialize count down latch.
++            IgniteCountDownLatch latch = ignite.countDownLatch(latchName, INITIAL_COUNT, false, true);
++
++            System.out.println("Latch initial value: " + latch.count());
++
++            // Start waiting on the latch on all cluster nodes.
++            for (int i = 0; i < INITIAL_COUNT; i++)
++                ignite.compute().run(new LatchClosure(latchName));
++
++            // Wait for latch to go down which essentially means that all remote closures completed.
++            latch.await();
++
++            System.out.println("All latch closures have completed.");
++        }
++
++        System.out.println();
++        System.out.println("Finished count down latch example...");
++        System.out.println("Check all nodes for output (this node is also part of the cluster).");
++    }
++
++    /**
++     * Closure which simply waits on the latch on all nodes.
++     */
++    private static class LatchClosure implements IgniteRunnable {
++        /** Latch name. */
++        private final String latchName;
++
++        /**
++         * @param latchName Latch name.
++         */
++        LatchClosure(String latchName) {
++            this.latchName = latchName;
++        }
++
++        /** {@inheritDoc} */
++        @Override public void run() {
++            IgniteCountDownLatch latch = Ignition.ignite().countDownLatch(latchName, 1, false, true);
++
++            int newCnt = latch.countDown();
++
++            System.out.println("Counted down [newCnt=" + newCnt + ", nodeId=" + Ignition.ignite().cluster().localNode().id() + ']');
++        }
++    }
++}


Mime
View raw message