ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vkuliche...@apache.org
Subject [10/11] incubator-ignite git commit: IGNITE-45 - java7 package in examples
Date Sat, 21 Mar 2015 06:11:41 GMT
IGNITE-45 - java7 package in examples


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

Branch: refs/heads/ignite-45
Commit: be0e755b03898bb891d4f03a0a67026dccaa03b4
Parents: 01bc984
Author: Valentin Kulichenko <vkulichenko@gridgain.com>
Authored: Fri Mar 20 23:12:58 2015 -0700
Committer: Valentin Kulichenko <vkulichenko@gridgain.com>
Committed: Fri Mar 20 23:12:58 2015 -0700

----------------------------------------------------------------------
 examples/config/example-cache.xml               |  10 +-
 .../ignite/examples/ExampleNodeStartup.java     |  35 --
 .../apache/ignite/examples/ExamplesUtils.java   |  81 ----
 .../computegrid/ComputeBroadcastExample.java    | 114 ------
 .../computegrid/ComputeCallableExample.java     |  79 ----
 .../computegrid/ComputeClosureExample.java      |  77 ----
 .../ComputeClusterGroupsExample.java            |  93 -----
 .../ComputeContinuousMapperExample.java         | 158 -------
 .../ComputeExecutorServiceExample.java          |  71 ----
 .../ComputeFibonacciContinuationExample.java    | 194 ---------
 .../computegrid/ComputeReducerExample.java      |  89 ----
 .../computegrid/ComputeRunnableExample.java     |  74 ----
 .../computegrid/ComputeScheduleExample.java     |  81 ----
 .../computegrid/ComputeTaskMapExample.java      | 113 -----
 .../computegrid/ComputeTaskSplitExample.java    | 102 -----
 .../failover/ComputeFailoverExample.java        | 137 -------
 .../failover/ComputeFailoverNodeStartup.java    |  77 ----
 .../computegrid/failover/package-info.java      |  22 -
 .../examples/computegrid/montecarlo/Credit.java | 110 -----
 .../montecarlo/CreditRiskExample.java           | 153 -------
 .../montecarlo/CreditRiskManager.java           | 143 -------
 .../computegrid/montecarlo/package-info.java    |  22 -
 .../examples/computegrid/package-info.java      |  22 -
 .../examples/datagrid/CacheAffinityExample.java | 138 -------
 .../examples/datagrid/CacheApiExample.java      | 128 ------
 .../datagrid/CacheContinuousQueryExample.java   | 107 -----
 .../datagrid/CacheDataStreamerExample.java      |  91 -----
 .../examples/datagrid/CacheEventsExample.java   |  99 -----
 .../datagrid/CachePopularNumbersExample.java    | 172 --------
 .../examples/datagrid/CachePutGetExample.java   | 113 -----
 .../examples/datagrid/CacheQueryExample.java    | 408 -------------------
 .../datagrid/CacheTransactionExample.java       | 148 -------
 .../hibernate/HibernateL2CacheExample.java      | 204 ----------
 .../HibernateL2CacheExampleNodeStartup.java     |  97 -----
 .../examples/datagrid/hibernate/Post.java       | 126 ------
 .../examples/datagrid/hibernate/User.java       | 151 -------
 .../datagrid/hibernate/package-info.java        |  22 -
 .../ignite/examples/datagrid/package-info.java  |  22 -
 .../starschema/CacheStarSchemaExample.java      | 244 -----------
 .../datagrid/starschema/DimProduct.java         | 101 -----
 .../examples/datagrid/starschema/DimStore.java  | 101 -----
 .../datagrid/starschema/FactPurchase.java       | 103 -----
 .../datagrid/starschema/package-info.java       |  22 -
 .../store/CacheNodeWithStoreStartup.java        | 155 -------
 .../datagrid/store/CacheStoreExample.java       | 107 -----
 .../store/CacheStoreLoadDataExample.java        |  67 ---
 .../store/dummy/CacheDummyPersonStore.java      | 120 ------
 .../datagrid/store/dummy/package-info.java      |  22 -
 .../hibernate/CacheHibernatePersonStore.java    | 290 -------------
 .../datagrid/store/hibernate/Person.hbm.xml     |  34 --
 .../datagrid/store/hibernate/hibernate.cfg.xml  |  41 --
 .../datagrid/store/hibernate/package-info.java  |  22 -
 .../store/jdbc/CacheJdbcPersonStore.java        | 275 -------------
 .../store/jdbc/CacheJdbcPojoPersonStore.java    |  82 ----
 .../datagrid/store/jdbc/package-info.java       |  22 -
 .../examples/datagrid/store/model/Person.java   | 155 -------
 .../examples/datagrid/store/package-info.java   |  22 -
 .../datastructures/IgniteAtomicLongExample.java |  74 ----
 .../IgniteAtomicReferenceExample.java           | 110 -----
 .../IgniteAtomicSequenceExample.java            |  91 -----
 .../IgniteAtomicStampedExample.java             | 117 ------
 .../IgniteCountDownLatchExample.java            |  95 -----
 .../datastructures/IgniteQueueExample.java      | 215 ----------
 .../datastructures/IgniteSetExample.java        | 197 ---------
 .../examples/datastructures/package-info.java   |  22 -
 .../ignite/examples/events/EventsExample.java   | 144 -------
 .../ignite/examples/events/package-info.java    |  22 -
 .../ignite/examples/igfs/IgfsExample.java       | 278 -------------
 .../examples/igfs/IgfsMapReduceExample.java     | 249 -----------
 .../ignite/examples/igfs/IgfsNodeStartup.java   |  41 --
 .../ignite/examples/igfs/package-info.java      |  22 -
 .../examples/java7/ExampleNodeStartup.java      |  35 ++
 .../ignite/examples/java7/ExamplesUtils.java    |  81 ++++
 .../computegrid/ComputeBroadcastExample.java    | 114 ++++++
 .../computegrid/ComputeCallableExample.java     |  79 ++++
 .../computegrid/ComputeClosureExample.java      |  77 ++++
 .../ComputeClusterGroupsExample.java            |  93 +++++
 .../ComputeContinuousMapperExample.java         | 158 +++++++
 .../ComputeExecutorServiceExample.java          |  71 ++++
 .../ComputeFibonacciContinuationExample.java    | 194 +++++++++
 .../computegrid/ComputeReducerExample.java      |  89 ++++
 .../computegrid/ComputeRunnableExample.java     |  74 ++++
 .../computegrid/ComputeScheduleExample.java     |  81 ++++
 .../computegrid/ComputeTaskMapExample.java      | 113 +++++
 .../computegrid/ComputeTaskSplitExample.java    | 102 +++++
 .../failover/ComputeFailoverExample.java        | 137 +++++++
 .../failover/ComputeFailoverNodeStartup.java    |  77 ++++
 .../computegrid/failover/package-info.java      |  22 +
 .../java7/computegrid/montecarlo/Credit.java    | 110 +++++
 .../montecarlo/CreditRiskExample.java           | 153 +++++++
 .../montecarlo/CreditRiskManager.java           | 143 +++++++
 .../computegrid/montecarlo/package-info.java    |  22 +
 .../java7/computegrid/package-info.java         |  22 +
 .../java7/datagrid/CacheAffinityExample.java    | 138 +++++++
 .../java7/datagrid/CacheApiExample.java         | 128 ++++++
 .../datagrid/CacheContinuousQueryExample.java   | 107 +++++
 .../datagrid/CacheDataStreamerExample.java      |  91 +++++
 .../java7/datagrid/CacheEventsExample.java      |  99 +++++
 .../datagrid/CachePopularNumbersExample.java    | 172 ++++++++
 .../java7/datagrid/CachePutGetExample.java      | 113 +++++
 .../java7/datagrid/CacheQueryExample.java       | 407 ++++++++++++++++++
 .../java7/datagrid/CacheTransactionExample.java | 148 +++++++
 .../hibernate/HibernateL2CacheExample.java      | 204 ++++++++++
 .../HibernateL2CacheExampleNodeStartup.java     |  97 +++++
 .../examples/java7/datagrid/hibernate/Post.java | 126 ++++++
 .../examples/java7/datagrid/hibernate/User.java | 151 +++++++
 .../java7/datagrid/hibernate/package-info.java  |  22 +
 .../examples/java7/datagrid/package-info.java   |  22 +
 .../starschema/CacheStarSchemaExample.java      | 244 +++++++++++
 .../java7/datagrid/starschema/DimProduct.java   | 101 +++++
 .../java7/datagrid/starschema/DimStore.java     | 101 +++++
 .../java7/datagrid/starschema/FactPurchase.java | 103 +++++
 .../java7/datagrid/starschema/package-info.java |  22 +
 .../store/CacheNodeWithStoreStartup.java        | 159 ++++++++
 .../java7/datagrid/store/CacheStoreExample.java | 108 +++++
 .../store/CacheStoreLoadDataExample.java        |  67 +++
 .../store/dummy/CacheDummyPersonStore.java      | 121 ++++++
 .../datagrid/store/dummy/package-info.java      |  22 +
 .../hibernate/CacheHibernatePersonStore.java    | 292 +++++++++++++
 .../datagrid/store/hibernate/Person.hbm.xml     |  34 ++
 .../datagrid/store/hibernate/hibernate.cfg.xml  |  41 ++
 .../datagrid/store/hibernate/package-info.java  |  22 +
 .../store/jdbc/CacheJdbcPersonStore.java        | 276 +++++++++++++
 .../store/jdbc/CacheJdbcPojoPersonStore.java    |  83 ++++
 .../java7/datagrid/store/jdbc/package-info.java |  22 +
 .../java7/datagrid/store/model/Person.java      | 155 +++++++
 .../java7/datagrid/store/package-info.java      |  22 +
 .../datastructures/IgniteAtomicLongExample.java |  74 ++++
 .../IgniteAtomicReferenceExample.java           | 110 +++++
 .../IgniteAtomicSequenceExample.java            |  91 +++++
 .../IgniteAtomicStampedExample.java             | 117 ++++++
 .../IgniteCountDownLatchExample.java            |  95 +++++
 .../datastructures/IgniteQueueExample.java      | 215 ++++++++++
 .../java7/datastructures/IgniteSetExample.java  | 197 +++++++++
 .../java7/datastructures/package-info.java      |  22 +
 .../examples/java7/events/EventsExample.java    | 144 +++++++
 .../examples/java7/events/package-info.java     |  22 +
 .../ignite/examples/java7/igfs/IgfsExample.java | 278 +++++++++++++
 .../java7/igfs/IgfsMapReduceExample.java        | 249 +++++++++++
 .../examples/java7/igfs/IgfsNodeStartup.java    |  41 ++
 .../examples/java7/igfs/package-info.java       |  22 +
 .../java7/messaging/MessagingExample.java       | 173 ++++++++
 .../messaging/MessagingPingPongExample.java     | 133 ++++++
 .../MessagingPingPongListenActorExample.java    | 106 +++++
 .../examples/java7/messaging/package-info.java  |  22 +
 .../client/memcache/MemcacheRestExample.java    | 125 ++++++
 .../MemcacheRestExampleNodeStartup.java         |  92 +++++
 .../misc/client/memcache/package-info.java      |  22 +
 .../java7/misc/client/package-info.java         |  22 +
 .../misc/deployment/DeploymentExample.java      | 129 ++++++
 .../java7/misc/deployment/package-info.java     |  22 +
 .../java7/misc/lifecycle/LifecycleExample.java  |  92 +++++
 .../java7/misc/lifecycle/package-info.java      |  22 +
 .../examples/java7/misc/package-info.java       |  22 +
 .../misc/springbean/SpringBeanExample.java      |  88 ++++
 .../java7/misc/springbean/package-info.java     |  22 +
 .../java7/misc/springbean/spring-bean.xml       |  70 ++++
 .../ignite/examples/java7/package-info.java     |  22 +
 .../java7/servicegrid/ServicesExample.java      | 167 ++++++++
 .../java7/servicegrid/SimpleMapService.java     |  49 +++
 .../java7/servicegrid/SimpleMapServiceImpl.java |  71 ++++
 .../examples/messaging/MessagingExample.java    | 173 --------
 .../messaging/MessagingPingPongExample.java     | 133 ------
 .../MessagingPingPongListenActorExample.java    | 106 -----
 .../ignite/examples/messaging/package-info.java |  22 -
 .../client/memcache/MemcacheRestExample.java    | 125 ------
 .../MemcacheRestExampleNodeStartup.java         |  92 -----
 .../misc/client/memcache/package-info.java      |  22 -
 .../examples/misc/client/package-info.java      |  22 -
 .../misc/deployment/DeploymentExample.java      | 129 ------
 .../examples/misc/deployment/package-info.java  |  22 -
 .../misc/lifecycle/LifecycleExample.java        |  92 -----
 .../examples/misc/lifecycle/package-info.java   |  22 -
 .../ignite/examples/misc/package-info.java      |  22 -
 .../misc/springbean/SpringBeanExample.java      |  88 ----
 .../examples/misc/springbean/package-info.java  |  22 -
 .../examples/misc/springbean/spring-bean.xml    |  70 ----
 .../apache/ignite/examples/package-info.java    |  22 -
 .../examples/servicegrid/ServicesExample.java   | 167 --------
 .../examples/servicegrid/SimpleMapService.java  |  49 ---
 .../servicegrid/SimpleMapServiceImpl.java       |  71 ----
 .../ignite/examples/BasicExamplesSelfTest.java  |   1 +
 .../ignite/examples/CacheExamplesSelfTest.java  |   4 +
 ...heStoreLoadDataExampleMultiNodeSelfTest.java |   1 +
 .../examples/CheckpointExamplesSelfTest.java    |   1 +
 .../ComputeClusterGroupsExampleSelfTest.java    |   1 +
 .../examples/ContinuationExamplesSelfTest.java  |   1 +
 .../ContinuousMapperExamplesSelfTest.java       |   1 +
 .../examples/DeploymentExamplesSelfTest.java    |   1 +
 .../ignite/examples/EventsExamplesSelfTest.java |   1 +
 ...ibernateL2CacheExampleMultiNodeSelfTest.java |   1 +
 .../HibernateL2CacheExampleSelfTest.java        |   1 +
 .../ignite/examples/IgfsExamplesSelfTest.java   |   1 +
 .../examples/LifecycleExamplesSelfTest.java     |   1 +
 .../MemcacheRestExamplesMultiNodeSelfTest.java  |   1 +
 .../examples/MemcacheRestExamplesSelfTest.java  |   1 +
 .../examples/MessagingExamplesSelfTest.java     |   1 +
 .../examples/MonteCarloExamplesSelfTest.java    |   1 +
 .../examples/SpringBeanExamplesSelfTest.java    |   1 +
 .../ignite/examples/TaskExamplesSelfTest.java   |   1 +
 200 files changed, 9242 insertions(+), 9211 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/be0e755b/examples/config/example-cache.xml
----------------------------------------------------------------------
diff --git a/examples/config/example-cache.xml b/examples/config/example-cache.xml
index 1cf1e2d..00aacab 100644
--- a/examples/config/example-cache.xml
+++ b/examples/config/example-cache.xml
@@ -64,11 +64,11 @@
                         <list>
                             <!-- Key and value type for SQL table Organization. -->
                             <value>java.util.UUID</value>
-                            <value>org.apache.ignite.examples.datagrid.CacheQueryExample.Organization</value>
+                            <value>org.apache.ignite.examples.java7.datagrid.CacheQueryExample.Organization</value>
 
                             <!-- Key and value type for SQL table Person. -->
                             <value>org.apache.ignite.cache.affinity.CacheAffinityKey</value>
-                            <value>org.apache.ignite.examples.datagrid.CacheQueryExample.Person</value>
+                            <value>org.apache.ignite.examples.java7.datagrid.CacheQueryExample.Person</value>
 
                             <!-- Key and value type for SQL table Long. -->
                             <value>java.lang.Integer</value>
@@ -76,7 +76,7 @@
 
                             <!-- Key and value type for SQL table FactPurchase. -->
                             <value>java.lang.Integer</value>
-                            <value>org.apache.ignite.examples.datagrid.starschema.FactPurchase</value>
+                            <value>org.apache.ignite.examples.java7.datagrid.starschema.FactPurchase</value>
                         </list>
                     </property>
                 </bean>
@@ -107,11 +107,11 @@
                         <list>
                             <!-- Key and value type for SQL table DimStore. -->
                             <value>java.lang.Integer</value>
-                            <value>org.apache.ignite.examples.datagrid.starschema.DimStore</value>
+                            <value>org.apache.ignite.examples.java7.datagrid.starschema.DimStore</value>
 
                             <!-- Key and value type for SQL table DimProduct. -->
                             <value>java.lang.Integer</value>
-                            <value>org.apache.ignite.examples.datagrid.starschema.DimProduct</value>
+                            <value>org.apache.ignite.examples.java7.datagrid.starschema.DimProduct</value>
                         </list>
                     </property>
                 </bean>

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/be0e755b/examples/src/main/java/org/apache/ignite/examples/ExampleNodeStartup.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/ExampleNodeStartup.java b/examples/src/main/java/org/apache/ignite/examples/ExampleNodeStartup.java
deleted file mode 100644
index f972b53..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/ExampleNodeStartup.java
+++ /dev/null
@@ -1,35 +0,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;
-
-import org.apache.ignite.*;
-
-/**
- * Starts up an empty node with example compute configuration.
- */
-public class ExampleNodeStartup {
-    /**
-     * Start up an empty node with example compute configuration.
-     *
-     * @param args Command line arguments, none required.
-     * @throws IgniteException If failed.
-     */
-    public static void main(String[] args) throws IgniteException {
-        Ignition.start("examples/config/example-ignite.xml");
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/be0e755b/examples/src/main/java/org/apache/ignite/examples/ExamplesUtils.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/ExamplesUtils.java b/examples/src/main/java/org/apache/ignite/examples/ExamplesUtils.java
deleted file mode 100644
index a506595..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/ExamplesUtils.java
+++ /dev/null
@@ -1,81 +0,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;
-
-import org.apache.ignite.cluster.*;
-
-import java.net.*;
-
-/**
- *
- */
-public class ExamplesUtils {
-    /** */
-    private static final ClassLoader CLS_LDR = ExamplesUtils.class.getClassLoader();
-
-    /**
-     * Exits with code {@code -1} if maximum memory is below 90% of minimally allowed threshold.
-     *
-     * @param min Minimum memory threshold.
-     */
-    public static void checkMinMemory(long min) {
-        long maxMem = Runtime.getRuntime().maxMemory();
-
-        if (maxMem < .85 * min) {
-            System.err.println("Heap limit is too low (" + (maxMem / (1024 * 1024)) +
-                "MB), please increase heap size at least up to " + (min / (1024 * 1024)) + "MB.");
-
-            System.exit(-1);
-        }
-    }
-
-    /**
-     * Returns URL resolved by class loader for classes in examples project.
-     *
-     * @return Resolved URL.
-     */
-    public static URL url(String path) {
-        URL url = CLS_LDR.getResource(path);
-
-        if (url == null)
-            throw new RuntimeException("Failed to resolve resource URL by path: " + path);
-
-        return url;
-    }
-
-    /**
-     * Checks minimum topology size for running a certain example.
-     *
-     * @param prj Cluster to check size for.
-     * @param size Minimum number of nodes required to run a certain example.
-     * @return {@code True} if check passed, {@code false} otherwise.
-     */
-    public static boolean checkMinTopologySize(ClusterGroup prj, int size) {
-        int prjSize = prj.nodes().size();
-
-        if (prjSize < size) {
-            System.out.println();
-            System.out.println(">>> Please start at least " + size + " cluster nodes to run example.");
-            System.out.println();
-
-            return false;
-        }
-
-        return true;
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/be0e755b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeBroadcastExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeBroadcastExample.java b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeBroadcastExample.java
deleted file mode 100644
index 2ea878c..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeBroadcastExample.java
+++ /dev/null
@@ -1,114 +0,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.computegrid;
-
-import org.apache.ignite.*;
-import org.apache.ignite.examples.*;
-import org.apache.ignite.lang.*;
-import org.apache.ignite.resources.*;
-
-import java.util.*;
-
-/**
- * Demonstrates broadcasting computations within cluster.
- * <p>
- * Remote nodes should always be started with special configuration file which
- * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-ignite.xml'}.
- * <p>
- * Alternatively you can run {@link ExampleNodeStartup} in another JVM which will start node
- * with {@code examples/config/example-ignite.xml} configuration.
- */
-public class ComputeBroadcastExample {
-    /**
-     * Executes example.
-     *
-     * @param args Command line arguments, none required.
-     * @throws IgniteException If example execution failed.
-     */
-    public static void main(String[] args) throws IgniteException {
-        try (Ignite ignite = Ignition.start("examples/config/example-ignite.xml")) {
-            System.out.println();
-            System.out.println(">>> Compute broadcast example started.");
-
-            // Print hello message on all nodes.
-            hello(ignite);
-
-            // Gather system info from all nodes.
-            gatherSystemInfo(ignite);
-       }
-    }
-
-    /**
-     * Print 'Hello' message on all nodes.
-     *
-     * @param ignite Ignite instance.
-     * @throws IgniteException If failed.
-     */
-    private static void hello(Ignite ignite) throws IgniteException {
-        // Print out hello message on all nodes.
-        ignite.compute().broadcast(
-            new IgniteRunnable() {
-                @Override public void run() {
-                    System.out.println();
-                    System.out.println(">>> Hello Node! :)");
-                }
-            }
-        );
-
-        System.out.println();
-        System.out.println(">>> Check all nodes for hello message output.");
-    }
-
-    /**
-     * Gather system info from all nodes and print it out.
-     *
-     * @param ignite Ignite instance.
-     * @throws IgniteException if failed.
-     */
-    private static void gatherSystemInfo(Ignite ignite) throws IgniteException {
-        // Gather system info from all nodes.
-        Collection<String> res = ignite.compute().broadcast(
-            new IgniteCallable<String>() {
-                // Automatically inject ignite instance.
-                @IgniteInstanceResource
-                private Ignite ignite;
-
-                @Override public String call() {
-                    System.out.println();
-                    System.out.println("Executing task on node: " + ignite.cluster().localNode().id());
-
-                    return "Node ID: " + ignite.cluster().localNode().id() + "\n" +
-                        "OS: " + System.getProperty("os.name") + " " + System.getProperty("os.version") + " " +
-                        System.getProperty("os.arch") + "\n" +
-                        "User: " + System.getProperty("user.name") + "\n" +
-                        "JRE: " + System.getProperty("java.runtime.name") + " " +
-                        System.getProperty("java.runtime.version");
-                }
-        });
-
-        // Print result.
-        System.out.println();
-        System.out.println("Nodes system information:");
-        System.out.println();
-
-        for (String r : res) {
-            System.out.println(r);
-            System.out.println();
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/be0e755b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeCallableExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeCallableExample.java b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeCallableExample.java
deleted file mode 100644
index f9a2939..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeCallableExample.java
+++ /dev/null
@@ -1,79 +0,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.computegrid;
-
-import org.apache.ignite.*;
-import org.apache.ignite.examples.*;
-import org.apache.ignite.lang.*;
-
-import java.util.*;
-
-/**
- * Demonstrates using of {@link IgniteCallable} job execution on the cluster.
- * <p>
- * This example takes a sentence composed of multiple words and counts number of non-space
- * characters in the sentence by having each compute job count characters in each individual
- * word.
- * <p>
- * Remote nodes should always be started with special configuration file which
- * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-ignite.xml'}.
- * <p>
- * Alternatively you can run {@link ExampleNodeStartup} in another JVM which will start node
- * with {@code examples/config/example-ignite.xml} configuration.
- */
-public class ComputeCallableExample {
-    /**
-     * Executes example.
-     *
-     * @param args Command line arguments, none required.
-     * @throws IgniteException If example execution failed.
-     */
-    public static void main(String[] args) throws IgniteException {
-        try (Ignite ignite = Ignition.start("examples/config/example-ignite.xml")) {
-            System.out.println();
-            System.out.println(">>> Compute callable example started.");
-
-            Collection<IgniteCallable<Integer>> calls = new ArrayList<>();
-
-            // Iterate through all words in the sentence and create callable jobs.
-            for (final String word : "Count characters using callable".split(" ")) {
-                calls.add(new IgniteCallable<Integer>() {
-                    @Override public Integer call() throws Exception {
-                        System.out.println();
-                        System.out.println(">>> Printing '" + word + "' on this node from ignite job.");
-
-                        return word.length();
-                    }
-                });
-            }
-
-            // Execute collection of callables on the ignite.
-            Collection<Integer> res = ignite.compute().call(calls);
-
-            int sum = 0;
-
-            // Add up individual word lengths received from remote nodes.
-            for (int len : res)
-                sum += len;
-
-            System.out.println();
-            System.out.println(">>> Total number of characters in the phrase is '" + sum + "'.");
-            System.out.println(">>> Check all nodes for output (this node is also part of the cluster).");
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/be0e755b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeClosureExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeClosureExample.java b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeClosureExample.java
deleted file mode 100644
index 0efb4cc..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeClosureExample.java
+++ /dev/null
@@ -1,77 +0,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.computegrid;
-
-import org.apache.ignite.*;
-import org.apache.ignite.examples.*;
-import org.apache.ignite.lang.*;
-
-import java.util.*;
-
-/**
- * Demonstrates a simple use of Ignite with reduce closure.
- * <p>
- * This example splits a phrase into collection of words, computes their length on different
- * nodes and then computes total amount of non-whitespaces characters in the phrase.
- * <p>
- * Remote nodes should always be started with special configuration file which
- * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-ignite.xml'}.
- * <p>
- * Alternatively you can run {@link ExampleNodeStartup} in another JVM which will start node
- * with {@code examples/config/example-ignite.xml} configuration.
- */
-public class ComputeClosureExample {
-    /**
-     * Executes example.
-     *
-     * @param args Command line arguments, none required.
-     * @throws IgniteException If example execution failed.
-     */
-    public static void main(String[] args) throws IgniteException {
-        try (Ignite ignite = Ignition.start("examples/config/example-ignite.xml")) {
-            System.out.println();
-            System.out.println(">>> Compute closure example started.");
-
-            // Execute closure on all cluster nodes.
-            Collection<Integer> res = ignite.compute().apply(
-                new IgniteClosure<String, Integer>() {
-                    @Override public Integer apply(String word) {
-                        System.out.println();
-                        System.out.println(">>> Printing '" + word + "' on this node from ignite job.");
-
-                        // Return number of letters in the word.
-                        return word.length();
-                    }
-                },
-
-                // Job parameters. Ignite will create as many jobs as there are parameters.
-                Arrays.asList("Count characters using closure".split(" "))
-            );
-
-            int sum = 0;
-
-            // Add up individual word lengths received from remote nodes
-            for (int len : res)
-                sum += len;
-
-            System.out.println();
-            System.out.println(">>> Total number of characters in the phrase is '" + sum + "'.");
-            System.out.println(">>> Check all nodes for output (this node is also part of the cluster).");
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/be0e755b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeClusterGroupsExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeClusterGroupsExample.java b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeClusterGroupsExample.java
deleted file mode 100644
index 40f8598..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeClusterGroupsExample.java
+++ /dev/null
@@ -1,93 +0,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.computegrid;
-
-import org.apache.ignite.*;
-import org.apache.ignite.cluster.*;
-import org.apache.ignite.examples.*;
-import org.apache.ignite.lang.*;
-
-/**
- * Demonstrates new functional APIs.
- * <p>
- * Remote nodes should always be started with special configuration file which
- * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-ignite.xml'}.
- * <p>
- * Alternatively you can run {@link ExampleNodeStartup} in another JVM which will start node
- * with {@code examples/config/example-ignite.xml} configuration.
- */
-public class ComputeClusterGroupsExample {
-    /**
-     * Executes example.
-     *
-     * @param args Command line arguments, none required.
-     * @throws IgniteException If example execution failed.
-     */
-    public static void main(String[] args) throws IgniteException {
-        try (Ignite ignite = Ignition.start("examples/config/example-ignite.xml")) {
-            if (!ExamplesUtils.checkMinTopologySize(ignite.cluster(), 2))
-                return;
-
-            System.out.println();
-            System.out.println("Compute example started.");
-
-            IgniteCluster cluster = ignite.cluster();
-
-            // Say hello to all nodes in the cluster, including local node.
-            sayHello(ignite, cluster);
-
-            // Say hello to all remote nodes.
-            sayHello(ignite, cluster.forRemotes());
-
-            // Pick random node out of remote nodes.
-            ClusterGroup randomNode = cluster.forRemotes().forRandom();
-
-            // Say hello to a random node.
-            sayHello(ignite, randomNode);
-
-            // Say hello to all nodes residing on the same host with random node.
-            sayHello(ignite, cluster.forHost(randomNode.node()));
-
-            // Say hello to all nodes that have current CPU load less than 50%.
-            sayHello(ignite, cluster.forPredicate(new IgnitePredicate<ClusterNode>() {
-                @Override public boolean apply(ClusterNode n) {
-                    return n.metrics().getCurrentCpuLoad() < 0.5;
-                }
-            }));
-        }
-    }
-
-    /**
-     * Print 'Hello' message on remote nodes.
-     *
-     * @param ignite Ignite.
-     * @param grp Cluster group.
-     * @throws IgniteException If failed.
-     */
-    private static void sayHello(Ignite ignite, final ClusterGroup grp) throws IgniteException {
-        // Print out hello message on all cluster nodes.
-        ignite.compute(grp).broadcast(
-            new IgniteRunnable() {
-                @Override public void run() {
-                    // Print ID of remote node on remote node.
-                    System.out.println(">>> Hello Node: " + grp.ignite().cluster().localNode().id());
-                }
-            }
-        );
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/be0e755b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeContinuousMapperExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeContinuousMapperExample.java b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeContinuousMapperExample.java
deleted file mode 100644
index 715001e..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeContinuousMapperExample.java
+++ /dev/null
@@ -1,158 +0,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.computegrid;
-
-import org.apache.ignite.*;
-import org.apache.ignite.cluster.*;
-import org.apache.ignite.compute.*;
-import org.apache.ignite.examples.*;
-import org.apache.ignite.resources.*;
-
-import java.util.*;
-import java.util.concurrent.*;
-import java.util.concurrent.atomic.*;
-
-/**
- * Demonstrates usage of continuous mapper. With continuous mapper
- * it is possible to continue mapping jobs asynchronously even after
- * initial {@link ComputeTask#map(List, Object)} method completes.
- * <p>
- * String "Hello Continuous Mapper" is passed as an argument for execution
- * of {@link ComputeContinuousMapperExample.ContinuousMapperTask}. As an outcome, participating
- * nodes will print out a single word from the passed in string and return
- * number of characters in that word. However, to demonstrate continuous
- * mapping, next word will be mapped to a node only after the result from
- * previous word has been received.
- * <p>
- * Remote nodes should always be started with special configuration file which
- * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-ignite.xml'}.
- * <p>
- * Alternatively you can run {@link ExampleNodeStartup} in another JVM which will start node
- * with {@code examples/config/example-ignite.xml} configuration.
- */
-public class ComputeContinuousMapperExample {
-    /**
-     * Executes example.
-     *
-     * @param args Command line arguments, none required.
-     * @throws IgniteException If example execution failed.
-     */
-    public static void main(String[] args) throws IgniteException {
-        System.out.println();
-        System.out.println(">>> Compute continuous mapper example started.");
-
-        try (Ignite ignite = Ignition.start("examples/config/example-ignite.xml")) {
-            int phraseLen = ignite.compute().execute(ContinuousMapperTask.class, "Hello Continuous Mapper");
-
-            System.out.println();
-            System.out.println(">>> Total number of characters in the phrase is '" + phraseLen + "'.");
-        }
-    }
-
-    /**
-     * This task demonstrates how continuous mapper is used. The passed in phrase
-     * is split into multiple words and next word is sent out for processing only
-     * when the result for the previous word was received.
-     * <p>
-     * Note that annotation {@link ComputeTaskNoResultCache} is optional and tells Ignite
-     * not to accumulate results from individual jobs. In this example we increment
-     * total character count directly in {@link #result(ComputeJobResult, List)} method,
-     * and therefore don't need to accumulate them be be processed at reduction step.
-     */
-    @ComputeTaskNoResultCache
-    private static class ContinuousMapperTask extends ComputeTaskAdapter<String, Integer> {
-        /** This field will be injected with task continuous mapper. */
-        @TaskContinuousMapperResource
-        private ComputeTaskContinuousMapper mapper;
-
-        /** Word queue. */
-        private final Queue<String> words = new ConcurrentLinkedQueue<>();
-
-        /** Total character count. */
-        private final AtomicInteger totalChrCnt = new AtomicInteger(0);
-
-        /** {@inheritDoc} */
-        @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> nodes, String phrase) {
-            if (phrase == null || phrase.isEmpty())
-                throw new IgniteException("Phrase is empty.");
-
-            // Populate word queue.
-            Collections.addAll(words, phrase.split(" "));
-
-            // Sends first word.
-            sendWord();
-
-            // Since we have sent at least one job, we are allowed to return
-            // 'null' from map method.
-            return null;
-        }
-
-        /** {@inheritDoc} */
-        @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) {
-            // If there is an error, fail-over to another node.
-            if (res.getException() != null)
-                return super.result(res, rcvd);
-
-            // Add result to total character count.
-            totalChrCnt.addAndGet(res.<Integer>getData());
-
-            sendWord();
-
-            // If next word was sent, keep waiting, otherwise work queue is empty and we reduce.
-            return ComputeJobResultPolicy.WAIT;
-        }
-
-        /** {@inheritDoc} */
-        @Override public Integer reduce(List<ComputeJobResult> results) {
-            return totalChrCnt.get();
-        }
-
-        /**
-         * Sends next queued word to the next node implicitly selected by load balancer.
-         */
-        private void sendWord() {
-            // Remove first word from the queue.
-            String word = words.poll();
-
-            if (word != null) {
-                // Map next word.
-                mapper.send(new ComputeJobAdapter(word) {
-                    @Override public Object execute() {
-                        String word = argument(0);
-
-                        System.out.println();
-                        System.out.println(">>> Printing '" + word + "' from ignite job at time: " + new Date());
-
-                        int cnt = word.length();
-
-                        // Sleep for some time so it will be visually noticeable that
-                        // jobs are executed sequentially.
-                        try {
-                            Thread.sleep(1000);
-                        }
-                        catch (InterruptedException ignored) {
-                            // No-op.
-                        }
-
-                        return cnt;
-                    }
-                });
-            }
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/be0e755b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeExecutorServiceExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeExecutorServiceExample.java b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeExecutorServiceExample.java
deleted file mode 100644
index 3b9be86..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeExecutorServiceExample.java
+++ /dev/null
@@ -1,71 +0,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.computegrid;
-
-import org.apache.ignite.*;
-import org.apache.ignite.examples.*;
-import org.apache.ignite.lang.*;
-
-import java.util.concurrent.*;
-
-/**
- * Simple example to demonstrate usage of distributed executor service provided by Ignite.
- * <p>
- * Remote nodes should always be started with special configuration file which
- * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-ignite.xml'}.
- * <p>
- * Alternatively you can run {@link ExampleNodeStartup} in another JVM which will start node
- * with {@code examples/config/example-ignite.xml} configuration.
- */
-public final class ComputeExecutorServiceExample {
-    /**
-     * Executes example.
-     *
-     * @param args Command line arguments, none required.
-     * @throws Exception If example execution failed.
-     */
-    @SuppressWarnings({"TooBroadScope"})
-    public static void main(String[] args) throws Exception {
-        try (Ignite ignite = Ignition.start("examples/config/example-ignite.xml")) {
-            System.out.println();
-            System.out.println(">>> Compute executor service example started.");
-
-            // Get ignite-enabled executor service.
-            ExecutorService exec = ignite.executorService();
-
-            // Iterate through all words in the sentence and create callable jobs.
-            for (final String word : "Print words using runnable".split(" ")) {
-                // Execute runnable on some node.
-                exec.submit(new IgniteRunnable() {
-                    @Override public void run() {
-                        System.out.println();
-                        System.out.println(">>> Printing '" + word + "' on this node from ignite job.");
-                    }
-                });
-            }
-
-            exec.shutdown();
-
-            // Wait for all jobs to complete (0 means no limit).
-            exec.awaitTermination(0, TimeUnit.MILLISECONDS);
-
-            System.out.println();
-            System.out.println(">>> Check all nodes for output (this node is also part of the cluster).");
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/be0e755b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeFibonacciContinuationExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeFibonacciContinuationExample.java b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeFibonacciContinuationExample.java
deleted file mode 100644
index ff2fae9..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeFibonacciContinuationExample.java
+++ /dev/null
@@ -1,194 +0,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.computegrid;
-
-import org.apache.ignite.*;
-import org.apache.ignite.cluster.*;
-import org.apache.ignite.compute.*;
-import org.apache.ignite.examples.*;
-import org.apache.ignite.lang.*;
-import org.apache.ignite.resources.*;
-import org.jetbrains.annotations.*;
-
-import java.math.*;
-import java.util.*;
-import java.util.concurrent.*;
-
-/**
- * This example demonstrates how to use continuation feature of Ignite by
- * performing the distributed recursive calculation of {@code 'Fibonacci'}
- * numbers on the cluster. Continuations
- * functionality is exposed via {@link ComputeJobContext#holdcc()} and
- * {@link ComputeJobContext#callcc()} method calls in {@link ComputeFibonacciContinuationExample.FibonacciClosure} class.
- * <p>
- * Remote nodes should always be started with special configuration file which
- * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-ignite.xml'}.
- * <p>
- * Alternatively you can run {@link ExampleNodeStartup} in another JVM which will start node
- * with {@code examples/config/example-ignite.xml} configuration.
- */
-public final class ComputeFibonacciContinuationExample {
-    /**
-     * Executes example.
-     *
-     * @param args Command line arguments, none required.
-     * @throws IgniteException If example execution failed.
-     */
-    public static void main(String[] args) throws IgniteException {
-        try (Ignite ignite = Ignition.start("examples/config/example-ignite.xml")) {
-            System.out.println();
-            System.out.println("Compute Fibonacci continuation example started.");
-
-            long N = 100;
-
-            final UUID exampleNodeId = ignite.cluster().localNode().id();
-
-            // Filter to exclude this node from execution.
-            final IgnitePredicate<ClusterNode> nodeFilter = new IgnitePredicate<ClusterNode>() {
-                @Override public boolean apply(ClusterNode n) {
-                    // Give preference to remote nodes.
-                    return ignite.cluster().forRemotes().nodes().isEmpty() || !n.id().equals(exampleNodeId);
-                }
-            };
-
-            long start = System.currentTimeMillis();
-
-            BigInteger fib = ignite.compute(ignite.cluster().forPredicate(nodeFilter)).apply(new FibonacciClosure(nodeFilter), N);
-
-            long duration = System.currentTimeMillis() - start;
-
-            System.out.println();
-            System.out.println(">>> Finished executing Fibonacci for '" + N + "' in " + duration + " ms.");
-            System.out.println(">>> Fibonacci sequence for input number '" + N + "' is '" + fib + "'.");
-            System.out.println(">>> If you re-run this example w/o stopping remote nodes - the performance will");
-            System.out.println(">>> increase since intermediate results are pre-cache on remote nodes.");
-            System.out.println(">>> You should see prints out every recursive Fibonacci execution on cluster nodes.");
-            System.out.println(">>> Check remote nodes for output.");
-        }
-    }
-
-    /**
-     * Closure to execute.
-     */
-    private static class FibonacciClosure implements IgniteClosure<Long, BigInteger> {
-        /** Future for spawned task. */
-        private IgniteFuture<BigInteger> fut1;
-
-        /** Future for spawned task. */
-        private IgniteFuture<BigInteger> fut2;
-
-        /** Auto-inject job context. */
-        @JobContextResource
-        private ComputeJobContext jobCtx;
-
-        /** Auto-inject ignite instance. */
-        @IgniteInstanceResource
-        private Ignite ignite;
-
-        /** Predicate. */
-        private final IgnitePredicate<ClusterNode> nodeFilter;
-
-        /**
-         * @param nodeFilter Predicate to filter nodes.
-         */
-        FibonacciClosure(IgnitePredicate<ClusterNode> nodeFilter) {
-            this.nodeFilter = nodeFilter;
-        }
-
-        /** {@inheritDoc} */
-        @Nullable @Override public BigInteger apply(Long n) {
-            if (fut1 == null || fut2 == null) {
-                System.out.println();
-                System.out.println(">>> Starting fibonacci execution for number: " + n);
-
-                // Make sure n is not negative.
-                n = Math.abs(n);
-
-                if (n <= 2)
-                    return n == 0 ? BigInteger.ZERO : BigInteger.ONE;
-
-                // Node-local storage.
-                ConcurrentMap<Long, IgniteFuture<BigInteger>> locMap = ignite.cluster().nodeLocalMap();
-
-                // Check if value is cached in node-local-map first.
-                fut1 = locMap.get(n - 1);
-                fut2 = locMap.get(n - 2);
-
-                ClusterGroup p = ignite.cluster().forPredicate(nodeFilter);
-
-                IgniteCompute compute = ignite.compute(p).withAsync();
-
-                // If future is not cached in node-local-map, cache it.
-                if (fut1 == null) {
-                    compute.apply(new FibonacciClosure(nodeFilter), n - 1);
-
-                    ComputeTaskFuture<BigInteger> futVal = compute.future();
-
-                    fut1 = locMap.putIfAbsent(n - 1, futVal);
-
-                    if (fut1 == null)
-                        fut1 = futVal;
-                }
-
-                // If future is not cached in node-local-map, cache it.
-                if (fut2 == null) {
-                    compute.apply(new FibonacciClosure(nodeFilter), n - 2);
-
-                    ComputeTaskFuture<BigInteger> futVal = compute.<BigInteger>future();
-
-                    fut2 = locMap.putIfAbsent(n - 2, futVal);
-
-                    if (fut2 == null)
-                        fut2 = futVal;
-                }
-
-                // If futures are not done, then wait asynchronously for the result
-                if (!fut1.isDone() || !fut2.isDone()) {
-                    IgniteInClosure<IgniteFuture<BigInteger>> lsnr = new IgniteInClosure<IgniteFuture<BigInteger>>() {
-                        @Override public void apply(IgniteFuture<BigInteger> f) {
-                            // If both futures are done, resume the continuation.
-                            if (fut1.isDone() && fut2.isDone())
-                                // CONTINUATION:
-                                // =============
-                                // Resume suspended job execution.
-                                jobCtx.callcc();
-                        }
-                    };
-
-                    // CONTINUATION:
-                    // =============
-                    // Hold (suspend) job execution.
-                    // It will be resumed in listener above via 'callcc()' call
-                    // once both futures are done.
-                    jobCtx.holdcc();
-
-                    // Attach the same listener to both futures.
-                    fut1.listen(lsnr);
-                    fut2.listen(lsnr);
-
-                    return null;
-                }
-            }
-
-            assert fut1.isDone() && fut2.isDone();
-
-            // Return cached results.
-            return fut1.get().add(fut2.get());
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/be0e755b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeReducerExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeReducerExample.java b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeReducerExample.java
deleted file mode 100644
index b678d45..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeReducerExample.java
+++ /dev/null
@@ -1,89 +0,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.computegrid;
-
-import org.apache.ignite.*;
-import org.apache.ignite.examples.*;
-import org.apache.ignite.lang.*;
-
-import java.util.*;
-import java.util.concurrent.atomic.*;
-
-/**
- * Demonstrates a simple use of Ignite with reduce closure.
- * <p>
- * Phrase is split into words and distributed across nodes where length of each word is
- * calculated. Then total phrase length is calculated using reducer.
- * <p>
- * Remote nodes should always be started with special configuration file which
- * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-ignite.xml'}.
- * <p>
- * Alternatively you can run {@link ExampleNodeStartup} in another JVM which will start Ignite node
- * with {@code examples/config/example-ignite.xml} configuration.
- */
-public class ComputeReducerExample {
-    /**
-     * Executes example.
-     *
-     * @param args Command line arguments, none required.
-     * @throws IgniteException If example execution failed.
-     */
-    public static void main(String[] args) throws IgniteException {
-        try (Ignite ignite = Ignition.start("examples/config/example-ignite.xml")) {
-            System.out.println();
-            System.out.println("Compute reducer example started.");
-
-            Integer sum = ignite.compute().apply(
-                new IgniteClosure<String, Integer>() {
-                    @Override public Integer apply(String word) {
-                        System.out.println();
-                        System.out.println(">>> Printing '" + word + "' on this node from ignite job.");
-
-                        // Return number of letters in the word.
-                        return word.length();
-                    }
-                },
-
-                // Job parameters. Ignite will create as many jobs as there are parameters.
-                Arrays.asList("Count characters using reducer".split(" ")),
-
-                // Reducer to process results as they come.
-                new IgniteReducer<Integer, Integer>() {
-                    private AtomicInteger sum = new AtomicInteger();
-
-                    // Callback for every job result.
-                    @Override public boolean collect(Integer len) {
-                        sum.addAndGet(len);
-
-                        // Return true to continue waiting until all results are received.
-                        return true;
-                    }
-
-                    // Reduce all results into one.
-                    @Override public Integer reduce() {
-                        return sum.get();
-                    }
-                }
-            );
-
-            System.out.println();
-            System.out.println(">>> Total number of characters in the phrase is '" + sum + "'.");
-            System.out.println(">>> Check all nodes for output (this node is also part of the cluster).");
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/be0e755b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeRunnableExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeRunnableExample.java b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeRunnableExample.java
deleted file mode 100644
index 1d907e3..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeRunnableExample.java
+++ /dev/null
@@ -1,74 +0,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.computegrid;
-
-import org.apache.ignite.*;
-import org.apache.ignite.examples.*;
-import org.apache.ignite.lang.*;
-
-import java.util.*;
-
-/**
- * Demonstrates a simple use of {@link IgniteRunnable}.
- * <p>
- * Remote nodes should always be started with special configuration file which
- * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-ignite.xml'}.
- * <p>
- * Alternatively you can run {@link ExampleNodeStartup} in another JVM which will start node
- * with {@code examples/config/example-ignite.xml} configuration.
- */
-public class ComputeRunnableExample {
-    /**
-     * Executes example.
-     *
-     * @param args Command line arguments, none required.
-     * @throws IgniteException If example execution failed.
-     */
-    public static void main(String[] args) throws IgniteException {
-        try (Ignite ignite = Ignition.start("examples/config/example-ignite.xml")) {
-            System.out.println();
-            System.out.println("Compute runnable example started.");
-
-            Collection<IgniteFuture> futs = new ArrayList<>();
-
-            // Enable asynchronous mode.
-            IgniteCompute compute = ignite.compute().withAsync();
-
-            // Iterate through all words in the sentence and create callable jobs.
-            for (final String word : "Print words using runnable".split(" ")) {
-                // Execute runnable on some node.
-                compute.run(new IgniteRunnable() {
-                    @Override public void run() {
-                        System.out.println();
-                        System.out.println(">>> Printing '" + word + "' on this node from ignite job.");
-                    }
-                });
-
-                futs.add(compute.future());
-            }
-
-            // Wait for all futures to complete.
-            for (IgniteFuture<?> f : futs)
-                f.get();
-
-            System.out.println();
-            System.out.println(">>> Finished printing words using runnable execution.");
-            System.out.println(">>> Check all nodes for output (this node is also part of the cluster).");
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/be0e755b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeScheduleExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeScheduleExample.java b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeScheduleExample.java
deleted file mode 100644
index 17812ec..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeScheduleExample.java
+++ /dev/null
@@ -1,81 +0,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.computegrid;
-
-import org.apache.ignite.*;
-import org.apache.ignite.examples.*;
-import org.apache.ignite.lang.*;
-import org.apache.ignite.scheduler.*;
-
-import java.util.concurrent.*;
-
-/**
- * Demonstrates a cron-based {@link Runnable} execution scheduling.
- * Test runnable object broadcasts a phrase to all cluster nodes every minute
- * three times with initial scheduling delay equal to five seconds.
- * <p>
- * Remote nodes should always be started with special configuration file which
- * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-ignite.xml'}.
- * <p>
- * Alternatively you can run {@link ExampleNodeStartup} in another JVM which will start node
- * with {@code examples/config/example-ignite.xml} configuration.
- */
-public class ComputeScheduleExample {
-    /**
-     * Executes example.
-     *
-     * @param args Command line arguments, none required.
-     * @throws IgniteException If example execution failed.
-     */
-    public static void main(String[] args) throws IgniteException {
-        try (Ignite ignite = Ignition.start("examples/config/example-ignite.xml")) {
-            System.out.println();
-            System.out.println("Compute schedule example started.");
-
-            // Schedule output message every minute.
-            SchedulerFuture<?> fut = ignite.scheduler().scheduleLocal(
-                new Callable<Integer>() {
-                    private int invocations;
-
-                    @Override public Integer call() {
-                        invocations++;
-
-                        ignite.compute().broadcast(
-                            new IgniteRunnable() {
-                                @Override public void run() {
-                                    System.out.println();
-                                    System.out.println("Howdy! :) ");
-                                }
-                            }
-                        );
-
-                        return invocations;
-                    }
-                },
-                "{5, 3} * * * * *" // Cron expression.
-            );
-
-            while (!fut.isDone())
-                System.out.println(">>> Invocation #: " + fut.get());
-
-            System.out.println();
-            System.out.println(">>> Schedule future is done and has been unscheduled.");
-            System.out.println(">>> Check all nodes for hello message output.");
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/be0e755b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeTaskMapExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeTaskMapExample.java b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeTaskMapExample.java
deleted file mode 100644
index a06299f..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeTaskMapExample.java
+++ /dev/null
@@ -1,113 +0,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.computegrid;
-
-import org.apache.ignite.*;
-import org.apache.ignite.cluster.*;
-import org.apache.ignite.compute.*;
-import org.apache.ignite.examples.*;
-import org.jetbrains.annotations.*;
-
-import java.util.*;
-
-/**
- * Demonstrates a simple use of Ignite with
- * {@link ComputeTaskAdapter}.
- * <p>
- * Phrase passed as task argument is split into words on map stage and distributed among cluster nodes.
- * Each node computes word length and returns result to master node where total phrase length is
- * calculated on reduce stage.
- * <p>
- * Remote nodes should always be started with special configuration file which
- * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-ignite.xml'}.
- * <p>
- * Alternatively you can run {@link ExampleNodeStartup} in another JVM which will start node
- * with {@code examples/config/example-ignite.xml} configuration.
- */
-public class ComputeTaskMapExample {
-    /**
-     * Executes example.
-     *
-     * @param args Command line arguments, none required.
-     * @throws IgniteException If example execution failed.
-     */
-    public static void main(String[] args) throws IgniteException {
-        try (Ignite ignite = Ignition.start("examples/config/example-ignite.xml")) {
-            System.out.println();
-            System.out.println("Compute task map example started.");
-
-            // Execute task on the cluster and wait for its completion.
-            int cnt = ignite.compute().execute(CharacterCountTask.class, "Hello Ignite Enabled World!");
-
-            System.out.println();
-            System.out.println(">>> Total number of characters in the phrase is '" + cnt + "'.");
-            System.out.println(">>> Check all nodes for output (this node is also part of the cluster).");
-        }
-    }
-
-    /**
-     * Task to count non-white-space characters in a phrase.
-     */
-    private static class CharacterCountTask extends ComputeTaskAdapter<String, Integer> {
-        /**
-         * Splits the received string to words, creates a child job for each word, and sends
-         * these jobs to other nodes for processing. Each such job simply prints out the received word.
-         *
-         * @param nodes Nodes available for this task execution.
-         * @param arg String to split into words for processing.
-         * @return Map of jobs to nodes.
-         */
-        @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> nodes, String arg) {
-            String[] words = arg.split(" ");
-
-            Map<ComputeJob, ClusterNode> map = new HashMap<>();
-
-            Iterator<ClusterNode> it = nodes.iterator();
-
-            for (final String word : arg.split(" ")) {
-                // If we used all nodes, restart the iterator.
-                if (!it.hasNext())
-                    it = nodes.iterator();
-
-                ClusterNode node = it.next();
-
-                map.put(new ComputeJobAdapter() {
-                    @Nullable @Override public Object execute() {
-                        System.out.println();
-                        System.out.println(">>> Printing '" + word + "' on this node from ignite job.");
-
-                        // Return number of letters in the word.
-                        return word.length();
-                    }
-                }, node);
-            }
-
-            return map;
-        }
-
-        /** {@inheritDoc} */
-        @Nullable @Override public Integer reduce(List<ComputeJobResult> results) {
-            int sum = 0;
-
-            for (ComputeJobResult res : results)
-                sum += res.<Integer>getData();
-
-            return sum;
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/be0e755b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeTaskSplitExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeTaskSplitExample.java b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeTaskSplitExample.java
deleted file mode 100644
index 3dd3f63..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeTaskSplitExample.java
+++ /dev/null
@@ -1,102 +0,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.computegrid;
-
-import org.apache.ignite.*;
-import org.apache.ignite.compute.*;
-import org.apache.ignite.examples.*;
-import org.jetbrains.annotations.*;
-
-import java.util.*;
-
-/**
- * Demonstrates a simple use of Ignite with {@link ComputeTaskSplitAdapter}.
- * <p>
- * Phrase passed as task argument is split into jobs each taking one word. Then jobs are distributed among
- * cluster nodes. Each node computes word length and returns result to master node where total phrase length
- * is calculated on reduce stage.
- * <p>
- * Remote nodes should always be started with special configuration file which
- * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-ignite.xml'}.
- * <p>
- * Alternatively you can run {@link ExampleNodeStartup} in another JVM which will start node
- * with {@code examples/config/example-ignite.xml} configuration.
- */
-public class ComputeTaskSplitExample {
-    /**
-     * Executes example.
-     *
-     * @param args Command line arguments, none required.
-     * @throws IgniteException If example execution failed.
-     */
-    public static void main(String[] args) throws IgniteException {
-        try (Ignite ignite = Ignition.start("examples/config/example-ignite.xml")) {
-            System.out.println();
-            System.out.println("Compute task split example started.");
-
-            // Execute task on the cluster and wait for its completion.
-            int cnt = ignite.compute().execute(CharacterCountTask.class, "Hello Ignite Enabled World!");
-
-            System.out.println();
-            System.out.println(">>> Total number of characters in the phrase is '" + cnt + "'.");
-            System.out.println(">>> Check all nodes for output (this node is also part of the cluster).");
-        }
-    }
-
-    /**
-     * Task to count non-white-space characters in a phrase.
-     */
-    private static class CharacterCountTask extends ComputeTaskSplitAdapter<String, Integer> {
-        /**
-         * Splits the received string to words, creates a child job for each word, and sends
-         * these jobs to other nodes for processing. Each such job simply prints out the received word.
-         *
-         * @param clusterSize Number of available cluster nodes. Note that returned number of
-         *      jobs can be less, equal or greater than this cluster size.
-         * @param arg Task execution argument. Can be {@code null}.
-         * @return The list of child jobs.
-         */
-        @Override protected Collection<? extends ComputeJob> split(int clusterSize, String arg) {
-            Collection<ComputeJob> jobs = new LinkedList<>();
-
-            for (final String word : arg.split(" ")) {
-                jobs.add(new ComputeJobAdapter() {
-                    @Nullable @Override public Object execute() {
-                        System.out.println();
-                        System.out.println(">>> Printing '" + word + "' on this node from ignite job.");
-
-                        // Return number of letters in the word.
-                        return word.length();
-                    }
-                });
-            }
-
-            return jobs;
-        }
-
-        /** {@inheritDoc} */
-        @Nullable @Override public Integer reduce(List<ComputeJobResult> results) {
-            int sum = 0;
-
-            for (ComputeJobResult res : results)
-                sum += res.<Integer>getData();
-
-            return sum;
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/be0e755b/examples/src/main/java/org/apache/ignite/examples/computegrid/failover/ComputeFailoverExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/computegrid/failover/ComputeFailoverExample.java b/examples/src/main/java/org/apache/ignite/examples/computegrid/failover/ComputeFailoverExample.java
deleted file mode 100644
index 9b87c70..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/computegrid/failover/ComputeFailoverExample.java
+++ /dev/null
@@ -1,137 +0,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.computegrid.failover;
-
-import org.apache.ignite.*;
-import org.apache.ignite.compute.*;
-import org.apache.ignite.examples.*;
-import org.apache.ignite.lang.*;
-import org.apache.ignite.resources.*;
-
-import java.util.*;
-
-/**
- * Demonstrates the usage of checkpoints in Ignite.
- * <p>
- * The example tries to compute phrase length. In order to mitigate possible node failures, intermediate
- * result is saved as as checkpoint after each job step.
- * <p>
- * Remote nodes must be started using {@link ComputeFailoverNodeStartup}.
- */
-public class ComputeFailoverExample {
-    /**
-     * Executes example.
-     *
-     * @param args Command line arguments, none required.
-     * @throws IgniteException If example execution failed.
-     */
-    public static void main(String[] args) throws IgniteException{
-        try (Ignite ignite = Ignition.start(ComputeFailoverNodeStartup.configuration())) {
-            if (!ExamplesUtils.checkMinTopologySize(ignite.cluster(), 2))
-                return;
-
-            System.out.println();
-            System.out.println("Compute failover example started.");
-
-            // Number of letters.
-            int charCnt = ignite.compute().apply(new CheckPointJob(), "Stage1 Stage2");
-
-            System.out.println();
-            System.out.println(">>> Finished executing fail-over example with checkpoints.");
-            System.out.println(">>> Total number of characters in the phrase is '" + charCnt + "'.");
-            System.out.println(">>> You should see exception stack trace from failed job on some node.");
-            System.out.println(">>> Failed job will be failed over to another node.");
-        }
-    }
-
-    @ComputeTaskSessionFullSupport
-    private static final class CheckPointJob implements IgniteClosure<String, Integer> {
-        /** Injected distributed task session. */
-        @TaskSessionResource
-        private ComputeTaskSession jobSes;
-
-        /** Injected ignite logger. */
-        @LoggerResource
-        private IgniteLogger log;
-
-        /** */
-        private IgniteBiTuple<Integer, Integer> state;
-
-        /** */
-        private String phrase;
-
-        /**
-         * The job will check the checkpoint with key '{@code fail}' and if
-         * it's {@code true} it will throw exception to simulate a failure.
-         * Otherwise, it will execute enabled method.
-         */
-        @Override public Integer apply(String phrase) {
-            System.out.println();
-            System.out.println(">>> Executing fail-over example job.");
-
-            this.phrase = phrase;
-
-            List<String> words = Arrays.asList(phrase.split(" "));
-
-            final String cpKey = checkpointKey();
-
-            IgniteBiTuple<Integer, Integer> state = jobSes.loadCheckpoint(cpKey);
-
-            int idx = 0;
-            int sum = 0;
-
-            if (state != null) {
-                this.state = state;
-
-                // Last processed word index and total length.
-                idx = state.get1();
-                sum = state.get2();
-            }
-
-            for (int i = idx; i < words.size(); i++) {
-                sum += words.get(i).length();
-
-                this.state = new IgniteBiTuple<>(i + 1, sum);
-
-                // Save checkpoint with scope of task execution.
-                // It will be automatically removed when task completes.
-                jobSes.saveCheckpoint(cpKey, this.state);
-
-                // For example purposes, we fail on purpose after first stage.
-                // This exception will cause job to be failed over to another node.
-                if (i == 0) {
-                    System.out.println();
-                    System.out.println(">>> Job will be failed over to another node.");
-
-                    throw new ComputeJobFailoverException("Expected example job exception.");
-                }
-            }
-
-            return sum;
-        }
-
-        /**
-         * Make reasonably unique checkpoint key.
-         *
-         * @return Checkpoint key.
-         */
-        private String checkpointKey() {
-            return getClass().getName() + '-' + phrase;
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/be0e755b/examples/src/main/java/org/apache/ignite/examples/computegrid/failover/ComputeFailoverNodeStartup.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/computegrid/failover/ComputeFailoverNodeStartup.java b/examples/src/main/java/org/apache/ignite/examples/computegrid/failover/ComputeFailoverNodeStartup.java
deleted file mode 100644
index bcd7db1..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/computegrid/failover/ComputeFailoverNodeStartup.java
+++ /dev/null
@@ -1,77 +0,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.computegrid.failover;
-
-import org.apache.ignite.*;
-import org.apache.ignite.configuration.*;
-import org.apache.ignite.spi.checkpoint.sharedfs.*;
-import org.apache.ignite.spi.discovery.tcp.*;
-import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.*;
-
-import java.util.*;
-
-/**
- * Starts up an empty node with checkpoint-enabled configuration.
- * <p>
- * The difference is that running this class from IDE adds all example classes to classpath
- * but running from command line doesn't.
- */
-public class ComputeFailoverNodeStartup {
-    /**
-     * Start up an empty node with specified configuration.
-     *
-     * @param args Command line arguments, none required.
-     * @throws IgniteException If example execution failed.
-     */
-    public static void main(String[] args) throws IgniteException {
-        Ignition.start(configuration());
-    }
-
-    /**
-     * Create Ignite configuration with configured checkpoints.
-     *
-     * @return Ignite configuration.
-     * @throws IgniteException If configuration creation failed.
-     */
-    public static IgniteConfiguration configuration() throws IgniteException {
-        IgniteConfiguration cfg = new IgniteConfiguration();
-
-        cfg.setLocalHost("127.0.0.1");
-        cfg.setPeerClassLoadingEnabled(true);
-
-        // Configure checkpoint SPI.
-        SharedFsCheckpointSpi checkpointSpi = new SharedFsCheckpointSpi();
-
-        checkpointSpi.setDirectoryPaths(Collections.singletonList("work/checkpoint/sharedfs"));
-
-        cfg.setCheckpointSpi(checkpointSpi);
-
-        // Configure discovery SPI.
-        TcpDiscoverySpi discoSpi = new TcpDiscoverySpi();
-
-        TcpDiscoveryVmIpFinder ipFinder = new TcpDiscoveryVmIpFinder();
-
-        ipFinder.setAddresses(Arrays.asList("127.0.0.1:47500..47509"));
-
-        discoSpi.setIpFinder(ipFinder);
-
-        cfg.setDiscoverySpi(discoSpi);
-
-        return cfg;
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/be0e755b/examples/src/main/java/org/apache/ignite/examples/computegrid/failover/package-info.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/computegrid/failover/package-info.java b/examples/src/main/java/org/apache/ignite/examples/computegrid/failover/package-info.java
deleted file mode 100644
index 506a2a2..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/computegrid/failover/package-info.java
+++ /dev/null
@@ -1,22 +0,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 description. -->
- * Compute failover example.
- */
-package org.apache.ignite.examples.computegrid.failover;
\ No newline at end of file


Mime
View raw message