ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [46/50] [abbrv] incubator-ignite git commit: #ignite-168: Renaming in java8 examples.
Date Wed, 04 Feb 2015 12:29:19 GMT
#ignite-168: Renaming in java8 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/8db2a83f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/8db2a83f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/8db2a83f

Branch: refs/heads/ignite-6
Commit: 8db2a83fe50ed51e4bdf5b94e7bbb0b555229403
Parents: 5190174
Author: ivasilinets <ivasilinets@gridgain.com>
Authored: Wed Feb 4 15:05:54 2015 +0300
Committer: ivasilinets <ivasilinets@gridgain.com>
Committed: Wed Feb 4 15:05:54 2015 +0300

----------------------------------------------------------------------
 .../java8/org/apache/ignite/examples/ComputeExample.java  |  6 +++---
 .../org/apache/ignite/examples/MessagingExample.java      | 10 +++++-----
 2 files changed, 8 insertions(+), 8 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8db2a83f/examples/src/main/java8/org/apache/ignite/examples/ComputeExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java8/org/apache/ignite/examples/ComputeExample.java b/examples/src/main/java8/org/apache/ignite/examples/ComputeExample.java
index f89915e..a85c22b 100644
--- a/examples/src/main/java8/org/apache/ignite/examples/ComputeExample.java
+++ b/examples/src/main/java8/org/apache/ignite/examples/ComputeExample.java
@@ -39,13 +39,13 @@ public class ComputeExample {
             System.out.println(">>> Compute broadcast example started.");
 
             // Broadcast closure to all cluster nodes.
-            ignite.compute().broadcast((IgniteRunnable) () -> System.out.println("Hello
World"));
+            ignite.compute().broadcast((IgniteRunnable)() -> System.out.println("Hello
World"));
 
             // Unicast closure to some cluster node picked by load balancer.
-            ignite.compute().run((IgniteRunnable) () -> System.out.println("Hello World"));
+            ignite.compute().run((IgniteRunnable)() -> System.out.println("Hello World"));
 
             // Unicast closure to some cluster node picked by load balancer and return result.
-            int length = ignite.compute().call((IgniteCallable<Integer>) "Hello World"::length);
+            int length = ignite.compute().call((IgniteCallable<Integer>)"Hello World"::length);
 
             System.out.println();
             System.out.println(">>> Computed length: " + length);

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8db2a83f/examples/src/main/java8/org/apache/ignite/examples/MessagingExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java8/org/apache/ignite/examples/MessagingExample.java b/examples/src/main/java8/org/apache/ignite/examples/MessagingExample.java
index 10612e5..71fa1b4 100644
--- a/examples/src/main/java8/org/apache/ignite/examples/MessagingExample.java
+++ b/examples/src/main/java8/org/apache/ignite/examples/MessagingExample.java
@@ -62,10 +62,10 @@ public final class MessagingExample {
             System.out.println(">>> Messaging example started.");
 
             // Projection for remote nodes.
-            ClusterGroup rmtPrj = ignite.cluster().forRemotes();
+            ClusterGroup rmtGrp = ignite.cluster().forRemotes();
 
             // Listen for messages from remote nodes to make sure that they received all
the messages.
-            int msgCnt = rmtPrj.nodes().size() * MESSAGES_NUM;
+            int msgCnt = rmtGrp.nodes().size() * MESSAGES_NUM;
 
             CountDownLatch orderedLatch = new CountDownLatch(msgCnt);
             CountDownLatch unorderedLatch = new CountDownLatch(msgCnt);
@@ -73,17 +73,17 @@ public final class MessagingExample {
             localListen(ignite.message(ignite.cluster().forLocal()), orderedLatch, unorderedLatch);
 
             // Register listeners on all cluster nodes.
-            startListening(ignite, ignite.message(rmtPrj));
+            startListening(ignite, ignite.message(rmtGrp));
 
             // Send unordered messages to all remote nodes.
             for (int i = 0; i < MESSAGES_NUM; i++)
-                ignite.message(rmtPrj).send(TOPIC.UNORDERED, Integer.toString(i));
+                ignite.message(rmtGrp).send(TOPIC.UNORDERED, Integer.toString(i));
 
             System.out.println(">>> Finished sending unordered messages.");
 
             // Send ordered messages to all remote nodes.
             for (int i = 0; i < MESSAGES_NUM; i++)
-                ignite.message(rmtPrj).sendOrdered(TOPIC.ORDERED, Integer.toString(i), 0);
+                ignite.message(rmtGrp).sendOrdered(TOPIC.ORDERED, Integer.toString(i), 0);
 
             System.out.println(">>> Finished sending ordered messages.");
             System.out.println(">>> Check output on all nodes for message printouts.");


Mime
View raw message