ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vkuliche...@apache.org
Subject [18/50] [abbrv] incubator-ignite git commit: # sprint-3 - Updated streaming examples.
Date Wed, 08 Apr 2015 01:52:18 GMT
# sprint-3 - Updated streaming 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/dcd24e0d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/dcd24e0d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/dcd24e0d

Branch: refs/heads/ignite-471
Commit: dcd24e0d60f6ecd7339798acd8a5e6bae0310dd0
Parents: 3c3931f
Author: Dmitiry Setrakyan <dsetrakyan@gridgain.com>
Authored: Tue Apr 7 00:00:24 2015 -0700
Committer: Dmitiry Setrakyan <dsetrakyan@gridgain.com>
Committed: Tue Apr 7 00:00:24 2015 -0700

----------------------------------------------------------------------
 .../apache/ignite/examples/streaming/StreamTransformerExample.java | 2 +-
 .../ignite/examples/java8/streaming/StreamTransformerExample.java  | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dcd24e0d/examples/src/main/java/org/apache/ignite/examples/streaming/StreamTransformerExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/streaming/StreamTransformerExample.java
b/examples/src/main/java/org/apache/ignite/examples/streaming/StreamTransformerExample.java
index d5f619b..5901984 100644
--- a/examples/src/main/java/org/apache/ignite/examples/streaming/StreamTransformerExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/streaming/StreamTransformerExample.java
@@ -62,7 +62,7 @@ public class StreamTransformerExample {
                     // Allow data updates.
                     stmr.allowOverwrite(true);
 
-                    // Configure data transformation to count instances of the same number.
+                    // Configure data transformation to count random numbers added to the
stream.
                     stmr.receiver(new StreamTransformer<Integer, Long>() {
                         @Override
                         public Object process(MutableEntry<Integer, Long> e, Object...
args) {

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dcd24e0d/examples/src/main/java8/org/apache/ignite/examples/java8/streaming/StreamTransformerExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java8/org/apache/ignite/examples/java8/streaming/StreamTransformerExample.java
b/examples/src/main/java8/org/apache/ignite/examples/java8/streaming/StreamTransformerExample.java
index fa13d20..f66f9ea 100644
--- a/examples/src/main/java8/org/apache/ignite/examples/java8/streaming/StreamTransformerExample.java
+++ b/examples/src/main/java8/org/apache/ignite/examples/java8/streaming/StreamTransformerExample.java
@@ -61,7 +61,7 @@ public class StreamTransformerExample {
                     // Allow data updates.
                     stmr.allowOverwrite(true);
 
-                    // Configure data transformation to count instances of the same number.
+                    // Configure data transformation to count random numbers added to the
stream.
                     stmr.receiver(StreamTransformer.from((e, arg) -> {
                         // Get current count.
                         Long val = e.getValue();


Mime
View raw message