ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dsetrak...@apache.org
Subject [6/6] incubator-ignite git commit: sprint-1 - Renaming ManagedServices to IgniteServices.
Date Fri, 06 Feb 2015 00:32:17 GMT
sprint-1 - Renaming ManagedServices to IgniteServices.


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

Branch: refs/heads/ignite-188
Commit: 9200ef5e8cab12a516230bd708aad7bb0af27728
Parents: ce0c304
Author: Dmitiry Setrakyan <dsetrakyan@gridgain.com>
Authored: Thu Feb 5 16:19:04 2015 -0800
Committer: Dmitiry Setrakyan <dsetrakyan@gridgain.com>
Committed: Thu Feb 5 16:19:04 2015 -0800

----------------------------------------------------------------------
 .../compute/ComputeBroadcastExample.java        | 114 ------
 .../compute/ComputeCallableExample.java         |  79 ----
 .../examples/compute/ComputeClosureExample.java |  77 ----
 .../compute/ComputeContinuousMapperExample.java | 158 --------
 .../compute/ComputeExecutorServiceExample.java  |  71 ----
 .../ComputeFibonacciContinuationExample.java    | 183 ----------
 .../compute/ComputeProjectionExample.java       |  93 -----
 .../examples/compute/ComputeReducerExample.java |  89 -----
 .../compute/ComputeRunnableExample.java         |  74 ----
 .../compute/ComputeScheduleExample.java         |  81 -----
 .../examples/compute/ComputeTaskMapExample.java | 113 ------
 .../compute/ComputeTaskSplitExample.java        | 102 ------
 .../failover/ComputeFailoverExample.java        | 137 -------
 .../failover/ComputeFailoverNodeStartup.java    |  77 ----
 .../examples/compute/failover/package.html      |  23 --
 .../examples/compute/montecarlo/Credit.java     | 110 ------
 .../compute/montecarlo/CreditRiskExample.java   | 153 --------
 .../compute/montecarlo/CreditRiskManager.java   | 143 --------
 .../examples/compute/montecarlo/package.html    |  24 --
 .../apache/ignite/examples/compute/package.html |  23 --
 .../computegrid/ComputeBroadcastExample.java    | 114 ++++++
 .../computegrid/ComputeCallableExample.java     |  79 ++++
 .../computegrid/ComputeClosureExample.java      |  77 ++++
 .../ComputeContinuousMapperExample.java         | 158 ++++++++
 .../ComputeExecutorServiceExample.java          |  71 ++++
 .../ComputeFibonacciContinuationExample.java    | 183 ++++++++++
 .../computegrid/ComputeProjectionExample.java   |  93 +++++
 .../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 ++++
 .../examples/computegrid/failover/package.html  |  23 ++
 .../examples/computegrid/montecarlo/Credit.java | 110 ++++++
 .../montecarlo/CreditRiskExample.java           | 153 ++++++++
 .../montecarlo/CreditRiskManager.java           | 143 ++++++++
 .../computegrid/montecarlo/package.html         |  24 ++
 .../ignite/examples/computegrid/package.html    |  23 ++
 .../datastructures/IgniteAtomicLongExample.java |  74 ----
 .../IgniteAtomicReferenceExample.java           | 110 ------
 .../IgniteAtomicSequenceExample.java            |  96 -----
 .../IgniteAtomicStampedExample.java             | 117 ------
 .../IgniteCountDownLatchExample.java            |  96 -----
 .../datastructures/IgniteQueueExample.java      | 206 -----------
 .../datastructures/IgniteSetExample.java        | 186 ----------
 .../datagrid/datastructures/package.html        |  23 --
 .../datastructures/IgniteAtomicLongExample.java |  74 ++++
 .../IgniteAtomicReferenceExample.java           | 110 ++++++
 .../IgniteAtomicSequenceExample.java            |  96 +++++
 .../IgniteAtomicStampedExample.java             | 117 ++++++
 .../IgniteCountDownLatchExample.java            |  96 +++++
 .../datastructures/IgniteQueueExample.java      | 206 +++++++++++
 .../datastructures/IgniteSetExample.java        | 186 ++++++++++
 .../ignite/examples/datastructures/package.html |  23 ++
 .../examples/servicegrid/ServicesExample.java   | 167 +++++++++
 .../examples/servicegrid/SimpleMapService.java  |  49 +++
 .../servicegrid/SimpleMapServiceImpl.java       |  71 ++++
 .../examples/services/ServicesExample.java      | 167 ---------
 .../examples/services/SimpleMapService.java     |  49 ---
 .../examples/services/SimpleMapServiceImpl.java |  71 ----
 .../ignite/examples/BasicExamplesSelfTest.java  |   2 +-
 .../ignite/examples/CacheExamplesSelfTest.java  |   2 +-
 .../examples/CheckpointExamplesSelfTest.java    |   2 +-
 .../examples/ContinuationExamplesSelfTest.java  |   2 +-
 .../ContinuousMapperExamplesSelfTest.java       |   2 +-
 .../examples/MonteCarloExamplesSelfTest.java    |   2 +-
 .../examples/ProjectionExampleSelfTest.java     |   2 +-
 .../ignite/examples/TaskExamplesSelfTest.java   |   2 +-
 .../src/main/java/org/apache/ignite/Ignite.java |  39 +-
 .../java/org/apache/ignite/IgniteManaged.java   | 361 -------------------
 .../java/org/apache/ignite/IgniteServices.java  | 361 +++++++++++++++++++
 .../configuration/IgniteConfiguration.java      |  15 +-
 .../ignite/internal/ClusterGroupAdapter.java    |   8 +-
 .../apache/ignite/internal/IgniteKernal.java    |  16 +-
 .../ignite/internal/IgniteManagedImpl.java      | 284 ---------------
 .../ignite/internal/IgniteServicesImpl.java     | 284 +++++++++++++++
 .../resource/GridResourceProcessor.java         |   8 +-
 .../resource/GridResourceServiceInjector.java   |  12 +-
 .../service/GridServiceAssignments.java         |  10 +-
 .../service/GridServiceDeployment.java          |   8 +-
 .../service/GridServiceDeploymentFuture.java    |   8 +-
 .../service/GridServiceProcessor.java           |  74 ++--
 .../processors/service/GridServiceProxy.java    |  10 +-
 .../service/ManagedServiceContextImpl.java      | 156 --------
 .../service/ManagedServiceDescriptorImpl.java   | 101 ------
 .../processors/service/ServiceContextImpl.java  | 156 ++++++++
 .../service/ServiceDescriptorImpl.java          | 101 ++++++
 .../apache/ignite/managed/ManagedService.java   | 123 -------
 .../managed/ManagedServiceConfiguration.java    | 305 ----------------
 .../ignite/managed/ManagedServiceContext.java   |  68 ----
 .../managed/ManagedServiceDescriptor.java       |  90 -----
 .../java/org/apache/ignite/managed/package.html |  23 --
 .../ignite/resources/IgniteServiceResource.java |   4 +-
 .../org/apache/ignite/services/Service.java     | 123 +++++++
 .../ignite/services/ServiceConfiguration.java   | 305 ++++++++++++++++
 .../apache/ignite/services/ServiceContext.java  |  68 ++++
 .../ignite/services/ServiceDescriptor.java      |  90 +++++
 .../org/apache/ignite/services/package.html     |  23 ++
 .../processors/service/DummyService.java        |  10 +-
 .../GridServiceProcessorAbstractSelfTest.java   |  74 ++--
 ...ServiceProcessorMultiNodeConfigSelfTest.java |  22 +-
 .../GridServiceProcessorMultiNodeSelfTest.java  |  14 +-
 .../GridServiceProcessorProxySelfTest.java      |  74 ++--
 .../GridServiceProcessorSingleNodeSelfTest.java |   4 +-
 .../GridServiceReassignmentSelfTest.java        |   6 +-
 .../marshaller/GridMarshallerAbstractTest.java  |   8 +-
 .../ignite/testframework/junits/IgniteMock.java |  10 +-
 .../org/apache/ignite/IgniteSpringBean.java     |  20 +-
 .../resource/GridServiceInjectionSelfTest.java  |  26 +-
 pom.xml                                         |   4 +-
 112 files changed, 4875 insertions(+), 4885 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/9200ef5e/examples/src/main/java/org/apache/ignite/examples/compute/ComputeBroadcastExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeBroadcastExample.java b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeBroadcastExample.java
deleted file mode 100644
index bb23410..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/compute/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.compute;
-
-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 projection.
- * <p>
- * Remote nodes should always be started with special configuration file which
- * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-compute.xml'}.
- * <p>
- * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start node
- * with {@code examples/config/example-compute.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-compute.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/9200ef5e/examples/src/main/java/org/apache/ignite/examples/compute/ComputeCallableExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeCallableExample.java b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeCallableExample.java
deleted file mode 100644
index 9e39633..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/compute/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.compute;
-
-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-compute.xml'}.
- * <p>
- * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start node
- * with {@code examples/config/example-compute.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-compute.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/9200ef5e/examples/src/main/java/org/apache/ignite/examples/compute/ComputeClosureExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeClosureExample.java b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeClosureExample.java
deleted file mode 100644
index 13c9359..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/compute/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.compute;
-
-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-compute.xml'}.
- * <p>
- * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start node
- * with {@code examples/config/example-compute.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-compute.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/9200ef5e/examples/src/main/java/org/apache/ignite/examples/compute/ComputeContinuousMapperExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeContinuousMapperExample.java b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeContinuousMapperExample.java
deleted file mode 100644
index ad0775a..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/compute/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.compute;
-
-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 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-compute.xml'}.
- * <p>
- * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start node
- * with {@code examples/config/example-compute.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-compute.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. */
-        @IgniteTaskContinuousMapperResource
-        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/9200ef5e/examples/src/main/java/org/apache/ignite/examples/compute/ComputeExecutorServiceExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeExecutorServiceExample.java b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeExecutorServiceExample.java
deleted file mode 100644
index 75fda35..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/compute/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.compute;
-
-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-compute.xml'}.
- * <p>
- * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start node
- * with {@code examples/config/example-compute.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-compute.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/9200ef5e/examples/src/main/java/org/apache/ignite/examples/compute/ComputeFibonacciContinuationExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeFibonacciContinuationExample.java b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeFibonacciContinuationExample.java
deleted file mode 100644
index 2bae3c0..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeFibonacciContinuationExample.java
+++ /dev/null
@@ -1,183 +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.compute;
-
-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.*;
-
-/**
- * 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 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-compute.xml'}.
- * <p>
- * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start node
- * with {@code examples/config/example-compute.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-compute.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. */
-        @IgniteJobContextResource
-        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.
-                ClusterNodeLocalMap<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);
-
-                    fut1 = locMap.addIfAbsent(n - 1, compute.<BigInteger>future());
-                }
-
-                // If future is not cached in node-local-map, cache it.
-                if (fut2 == null) {
-                    compute.apply(new FibonacciClosure(nodeFilter), n - 2);
-
-                    fut2 = locMap.addIfAbsent(n - 2, compute.<BigInteger>future());
-                }
-
-                // 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.listenAsync(lsnr);
-                    fut2.listenAsync(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/9200ef5e/examples/src/main/java/org/apache/ignite/examples/compute/ComputeProjectionExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeProjectionExample.java b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeProjectionExample.java
deleted file mode 100644
index 7465429..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeProjectionExample.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.compute;
-
-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-compute.xml'}.
- * <p>
- * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start node
- * with {@code examples/config/example-compute.xml} configuration.
- */
-public class ComputeProjectionExample {
-    /**
-     * 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-compute.xml")) {
-            if (!ExamplesUtils.checkMinTopologySize(ignite.cluster(), 2))
-                return;
-
-            System.out.println();
-            System.out.println("Compute projection 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 projection 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/9200ef5e/examples/src/main/java/org/apache/ignite/examples/compute/ComputeReducerExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeReducerExample.java b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeReducerExample.java
deleted file mode 100644
index 1f020c4..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/compute/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.compute;
-
-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-compute.xml'}.
- * <p>
- * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start Ignite node
- * with {@code examples/config/example-compute.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-compute.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/9200ef5e/examples/src/main/java/org/apache/ignite/examples/compute/ComputeRunnableExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeRunnableExample.java b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeRunnableExample.java
deleted file mode 100644
index 2921970..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/compute/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.compute;
-
-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-compute.xml'}.
- * <p>
- * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start node
- * with {@code examples/config/example-compute.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-compute.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/9200ef5e/examples/src/main/java/org/apache/ignite/examples/compute/ComputeScheduleExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeScheduleExample.java b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeScheduleExample.java
deleted file mode 100644
index 6dc3892..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/compute/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.compute;
-
-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-compute.xml'}.
- * <p>
- * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start node
- * with {@code examples/config/example-compute.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-compute.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/9200ef5e/examples/src/main/java/org/apache/ignite/examples/compute/ComputeTaskMapExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeTaskMapExample.java b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeTaskMapExample.java
deleted file mode 100644
index 52773fb..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/compute/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.compute;
-
-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-compute.xml'}.
- * <p>
- * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start node
- * with {@code examples/config/example-compute.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-compute.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/9200ef5e/examples/src/main/java/org/apache/ignite/examples/compute/ComputeTaskSplitExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/compute/ComputeTaskSplitExample.java b/examples/src/main/java/org/apache/ignite/examples/compute/ComputeTaskSplitExample.java
deleted file mode 100644
index 9b6cc70..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/compute/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.compute;
-
-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-compute.xml'}.
- * <p>
- * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start node
- * with {@code examples/config/example-compute.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-compute.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/9200ef5e/examples/src/main/java/org/apache/ignite/examples/compute/failover/ComputeFailoverExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/compute/failover/ComputeFailoverExample.java b/examples/src/main/java/org/apache/ignite/examples/compute/failover/ComputeFailoverExample.java
deleted file mode 100644
index 46923eb..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/compute/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.compute.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. */
-        @IgniteTaskSessionResource
-        private ComputeTaskSession jobSes;
-
-        /** Injected ignite logger. */
-        @IgniteLoggerResource
-        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/9200ef5e/examples/src/main/java/org/apache/ignite/examples/compute/failover/ComputeFailoverNodeStartup.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/compute/failover/ComputeFailoverNodeStartup.java b/examples/src/main/java/org/apache/ignite/examples/compute/failover/ComputeFailoverNodeStartup.java
deleted file mode 100644
index 9eba616..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/compute/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.compute.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/9200ef5e/examples/src/main/java/org/apache/ignite/examples/compute/failover/package.html
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/compute/failover/package.html b/examples/src/main/java/org/apache/ignite/examples/compute/failover/package.html
deleted file mode 100644
index 2d7510e..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/compute/failover/package.html
+++ /dev/null
@@ -1,23 +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.
-  -->
-<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
-<html>
-<body>
-    <!-- Package description. -->
-    Compute failover example.
-</body>
-</html>

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/9200ef5e/examples/src/main/java/org/apache/ignite/examples/compute/montecarlo/Credit.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/compute/montecarlo/Credit.java b/examples/src/main/java/org/apache/ignite/examples/compute/montecarlo/Credit.java
deleted file mode 100644
index 2e0a7f8..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/compute/montecarlo/Credit.java
+++ /dev/null
@@ -1,110 +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.compute.montecarlo;
-
-import java.io.*;
-
-/**
- * This class provides a simple model for a credit contract (or a loan). It is basically
- * defines as remaining crediting amount to date, credit remaining term, APR and annual
- * probability on default. Although this model is simplified for the purpose
- * of this example, it is close enough to emulate the real-life credit
- * risk assessment application.
- */
-public class Credit implements Serializable {
-    /** Remaining crediting amount. */
-    private final double remAmnt;
-
-    /** Remaining crediting remTerm. */
-    private final int remTerm;
-
-    /** Annual percentage rate (APR). */
-    private final double apr;
-
-    /** Expected annual probability of default (EaDF). */
-    private final double edf;
-
-    /**
-     * Creates new credit instance with given information.
-     *
-     * @param remAmnt Remained crediting amount.
-     * @param remTerm Remained crediting remTerm.
-     * @param apr Annual percentage rate (APR).
-     * @param edf Expected annual probability of default (EaDF).
-     */
-    public Credit(double remAmnt, int remTerm, double apr, double edf) {
-        this.remAmnt = remAmnt;
-        this.remTerm = remTerm;
-        this.apr = apr;
-        this.edf = edf;
-    }
-
-    /**
-     * Gets remained crediting amount.
-     *
-     * @return Remained amount of credit.
-     */
-    double getRemainingAmount() {
-        return remAmnt;
-    }
-
-    /**
-     * Gets remained crediting remTerm.
-     *
-     * @return Remained crediting remTerm in days.
-     */
-    int getRemainingTerm() {
-        return remTerm;
-    }
-
-    /**
-     * Gets annual percentage rate.
-     *
-     * @return Annual percentage rate in relative percents (percentage / 100).
-     */
-    double getAnnualRate() {
-        return apr;
-    }
-
-    /**
-     * Gets either credit probability of default for the given period of time
-     * if remaining term is less than crediting time or probability of default
-     * for whole remained crediting time.
-     *
-     * @param term Default term.
-     * @return Credit probability of default in relative percents
-     *     (percentage / 100).
-     */
-    double getDefaultProbability(int term) {
-        return 1 - Math.exp(Math.log(1 - edf) * Math.min(remTerm, term) / 365.0);
-    }
-
-    /** {@inheritDoc} */
-    @Override public String toString() {
-        StringBuilder buf = new StringBuilder();
-
-        buf.append(getClass().getName());
-        buf.append(" [remAmnt=").append(remAmnt);
-        buf.append(", remTerm=").append(remTerm);
-        buf.append(", apr=").append(apr);
-        buf.append(", edf=").append(edf);
-        buf.append(']');
-
-        return buf.toString();
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/9200ef5e/examples/src/main/java/org/apache/ignite/examples/compute/montecarlo/CreditRiskExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/compute/montecarlo/CreditRiskExample.java b/examples/src/main/java/org/apache/ignite/examples/compute/montecarlo/CreditRiskExample.java
deleted file mode 100644
index 3db5b33..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/compute/montecarlo/CreditRiskExample.java
+++ /dev/null
@@ -1,153 +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.compute.montecarlo;
-
-import org.apache.ignite.*;
-import org.apache.ignite.examples.*;
-import org.apache.ignite.lang.*;
-
-import java.util.*;
-
-/**
- * Monte-Carlo example. Demonstrates distributed credit risk calculation.
- * <p>
- * Remote nodes should always be started with special configuration file which
- * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-compute.xml'}.
- * <p>
- * Alternatively you can run {@link ComputeNodeStartup} in another JVM which will start node
- * with {@code examples/config/example-compute.xml} configuration.
- */
-public final class CreditRiskExample {
-    /**
-     * 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-compute.xml")) {
-            System.out.println();
-            System.out.println("Credit risk example started.");
-
-            // Create portfolio.
-            Credit[] portfolio = new Credit[5000];
-
-            Random rnd = new Random();
-
-            // Generate some test portfolio items.
-            for (int i = 0; i < portfolio.length; i++) {
-                portfolio[i] = new Credit(
-                    50000 * rnd.nextDouble(), // Credit amount.
-                    rnd.nextInt(1000), // Credit term in days.
-                    rnd.nextDouble() / 10, // APR.
-                    rnd.nextDouble() / 20 + 0.02 // EDF.
-                );
-            }
-
-            // Forecast horizon in days.
-            int horizon = 365;
-
-            // Number of Monte-Carlo iterations.
-            int iter = 10000;
-
-            // Percentile.
-            double percentile = 0.95;
-
-            // Mark the stopwatch.
-            long start = System.currentTimeMillis();
-
-            // Calculate credit risk and print it out.
-            // As you can see the ignite enabling is completely hidden from the caller
-            // and it is fully transparent to him. In fact, the caller is never directly
-            // aware if method was executed just locally or on the 100s of cluster nodes.
-            // Credit risk crdRisk is the minimal amount that creditor has to have
-            // available to cover possible defaults.
-
-            double crdRisk = ignite.compute().call(jobs(ignite.cluster().nodes().size(), portfolio, horizon, iter, percentile),
-                new IgniteReducer<Double, Double>() {
-                    /** Collected values sum. */
-                    private double sum;
-
-                    /** Collected values count. */
-                    private int cnt;
-
-                    /** {@inheritDoc} */
-                    @Override public synchronized boolean collect(Double e) {
-                        sum += e;
-                        cnt++;
-
-                        return true;
-                    }
-
-                    /** {@inheritDoc} */
-                    @Override public synchronized Double reduce() {
-                        return sum / cnt;
-                    }
-                });
-
-            System.out.println();
-            System.out.println("Credit risk [crdRisk=" + crdRisk + ", duration=" +
-                (System.currentTimeMillis() - start) + "ms]");
-        }
-        // We specifically don't do any error handling here to
-        // simplify the example. Real application may want to
-        // add error handling and application specific recovery.
-    }
-
-    /**
-     * Creates closures for calculating credit risks.
-     *
-     * @param clusterSize Size of the cluster.
-     * @param portfolio Portfolio.
-     * @param horizon Forecast horizon in days.
-     * @param iter Number of Monte-Carlo iterations.
-     * @param percentile Percentile.
-     * @return Collection of closures.
-     */
-    private static Collection<IgniteCallable<Double>> jobs(int clusterSize, final Credit[] portfolio,
-        final int horizon, int iter, final double percentile) {
-        // Number of iterations should be done by each node.
-        int iterPerNode = Math.round(iter / (float)clusterSize);
-
-        // Number of iterations for the last/the only node.
-        int lastNodeIter = iter - (clusterSize - 1) * iterPerNode;
-
-        Collection<IgniteCallable<Double>> clos = new ArrayList<>(clusterSize);
-
-        // Note that for the purpose of this example we perform a simple homogeneous
-        // (non weighted) split assuming that all computing resources in this split
-        // will be identical. In real life scenarios when heterogeneous environment
-        // is used a split that is weighted by, for example, CPU benchmarks of each
-        // node in the split will be more efficient. It is fairly easy addition and
-        // Ignite comes with convenient Spring-compatible benchmark that can be
-        // used for weighted splits.
-        for (int i = 0; i < clusterSize; i++) {
-            final int nodeIter = i == clusterSize - 1 ? lastNodeIter : iterPerNode;
-
-            clos.add(new IgniteCallable<Double>() {
-                /** {@inheritDoc} */
-                @Override public Double call() {
-                    return new CreditRiskManager().calculateCreditRiskMonteCarlo(
-                        portfolio, horizon, nodeIter, percentile);
-                }
-            });
-        }
-
-        return clos;
-    }
-}


Mime
View raw message