ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vkuliche...@apache.org
Subject [1/2] incubator-ignite git commit: IGNITE-45 - Examples
Date Sat, 21 Mar 2015 09:14:35 GMT
Repository: incubator-ignite
Updated Branches:
  refs/heads/ignite-45 1496f8081 -> 24c6fed22


IGNITE-45 - 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/fbdfa726
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/fbdfa726
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/fbdfa726

Branch: refs/heads/ignite-45
Commit: fbdfa726e476553cf2aefc59f0060d7375ef2390
Parents: 093a2fc
Author: Valentin Kulichenko <vkulichenko@gridgain.com>
Authored: Sat Mar 21 02:14:39 2015 -0700
Committer: Valentin Kulichenko <vkulichenko@gridgain.com>
Committed: Sat Mar 21 02:14:39 2015 -0700

----------------------------------------------------------------------
 .../computegrid/ComputeCallableExample.java     | 11 ++++++---
 .../ComputeExecutorServiceExample.java          |  7 +++---
 .../computegrid/ComputeRunnableExample.java     | 26 +++++++++++---------
 .../computegrid/ComputeTaskSplitExample.java    | 12 ++++++---
 .../montecarlo/CreditRiskExample.java           | 12 +++------
 5 files changed, 38 insertions(+), 30 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/fbdfa726/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeCallableExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeCallableExample.java
b/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeCallableExample.java
index cedab92..c24df5e 100644
--- a/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeCallableExample.java
+++ b/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeCallableExample.java
@@ -22,7 +22,6 @@ import org.apache.ignite.examples.java7.*;
 import org.apache.ignite.lang.*;
 
 import java.util.*;
-import java.util.stream.*;
 
 /**
  * Demonstrates using of {@link IgniteCallable} job execution on the cluster.
@@ -49,16 +48,20 @@ public class ComputeCallableExample {
             System.out.println();
             System.out.println(">>> Compute callable example started.");
 
-            Stream<IgniteCallable<Integer>> calls = Stream.of("Count characters
using callable".split(" ")).map(word ->
-                (IgniteCallable<Integer>)() -> {
+            Collection<IgniteCallable<Integer>> calls = new ArrayList<>();
+
+            // Iterate through all words in the sentence and create callable jobs.
+            for (String word : "Count characters using callable".split(" ")) {
+                calls.add(() -> {
                     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.collect(Collectors.toList()));
+            Collection<Integer> res = ignite.compute().call(calls);
 
             int sum = res.stream().mapToInt(i -> i).sum();
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/fbdfa726/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeExecutorServiceExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeExecutorServiceExample.java
b/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeExecutorServiceExample.java
index 1208ce1..91ea66b 100644
--- a/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeExecutorServiceExample.java
+++ b/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeExecutorServiceExample.java
@@ -21,7 +21,6 @@ import org.apache.ignite.*;
 import org.apache.ignite.examples.java7.*;
 
 import java.util.concurrent.*;
-import java.util.stream.*;
 
 /**
  * Simple example to demonstrate usage of distributed executor service provided by Ignite.
@@ -48,12 +47,14 @@ public final class ComputeExecutorServiceExample {
             // Get ignite-enabled executor service.
             ExecutorService exec = ignite.executorService();
 
-            Stream.of("Print words using runnable".split(" ")).forEach(word -> {
+            // Iterate through all words in the sentence and create callable jobs.
+            for (String word : "Print words using runnable".split(" ")) {
+                // Execute runnable on some node.
                 exec.submit(() -> {
                     System.out.println();
                     System.out.println(">>> Printing '" + word + "' on this node
from ignite job.");
                 });
-            });
+            }
 
             exec.shutdown();
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/fbdfa726/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeRunnableExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeRunnableExample.java
b/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeRunnableExample.java
index a78c863..8abbe93 100644
--- a/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeRunnableExample.java
+++ b/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeRunnableExample.java
@@ -21,7 +21,7 @@ import org.apache.ignite.*;
 import org.apache.ignite.examples.java7.*;
 import org.apache.ignite.lang.*;
 
-import java.util.stream.*;
+import java.util.*;
 
 /**
  * Demonstrates a simple use of {@link IgniteRunnable}.
@@ -44,20 +44,24 @@ public class ComputeRunnableExample {
             System.out.println();
             System.out.println("Compute runnable example started.");
 
+            Collection<IgniteFuture> futs = new ArrayList<>();
+
             // Enable asynchronous mode.
             IgniteCompute compute = ignite.compute().withAsync();
 
-            Stream.of("Print words using runnable".split(" ")).
-                map(word -> {
-                    // Execute runnable on some node.
-                    compute.run(() -> {
-                        System.out.println();
-                        System.out.println(">>> Printing '" + word + "' on this
node from ignite job.");
-                    });
+            // 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(() -> {
+                    System.out.println();
+                    System.out.println(">>> Printing '" + word + "' on this node
from ignite job.");
+                });
+
+                futs.add(compute.future());
+            }
 
-                    return compute.future();
-                }).
-                forEach(IgniteFuture::get);
+            // Wait for all futures to complete.
+            futs.forEach(IgniteFuture::get);
 
             System.out.println();
             System.out.println(">>> Finished printing words using runnable execution.");

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/fbdfa726/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeTaskSplitExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeTaskSplitExample.java
b/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeTaskSplitExample.java
index 0b53ab9..7805728 100644
--- a/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeTaskSplitExample.java
+++ b/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeTaskSplitExample.java
@@ -23,7 +23,6 @@ import org.apache.ignite.examples.java7.*;
 import org.jetbrains.annotations.*;
 
 import java.util.*;
-import java.util.stream.*;
 
 /**
  * Demonstrates a simple use of Ignite with {@link ComputeTaskSplitAdapter}.
@@ -73,8 +72,10 @@ public class ComputeTaskSplitExample {
          * @return The list of child jobs.
          */
         @Override protected Collection<? extends ComputeJob> split(int clusterSize,
String arg) {
-            return Stream.of(arg.split(" ")).map(word ->
-                new ComputeJobAdapter() {
+            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.");
@@ -82,7 +83,10 @@ public class ComputeTaskSplitExample {
                         // Return number of letters in the word.
                         return word.length();
                     }
-            }).collect(Collectors.toList());
+                });
+            }
+
+            return jobs;
         }
 
         /** {@inheritDoc} */

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/fbdfa726/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/montecarlo/CreditRiskExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/montecarlo/CreditRiskExample.java
b/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/montecarlo/CreditRiskExample.java
index beed5a5..058536a 100644
--- a/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/montecarlo/CreditRiskExample.java
+++ b/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/montecarlo/CreditRiskExample.java
@@ -78,7 +78,8 @@ public final class CreditRiskExample {
             // 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),
+            double crdRisk = ignite.compute().call(
+                jobs(ignite.cluster().nodes().size(), portfolio, horizon, iter, percentile),
                 new IgniteReducer<Double, Double>() {
                     /** Collected values sum. */
                     private double sum;
@@ -139,13 +140,8 @@ public final class CreditRiskExample {
         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);
-                }
-            });
+            clos.add(() -> new CreditRiskManager().calculateCreditRiskMonteCarlo(
+                portfolio, horizon, nodeIter, percentile));
         }
 
         return clos;


Mime
View raw message