You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by se...@apache.org on 2015/04/08 00:55:05 UTC
[16/50] [abbrv] incubator-ignite git commit: # sprint-3 - Updated
streaming examples.
# 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-624
Commit: dcd24e0d60f6ecd7339798acd8a5e6bae0310dd0
Parents: 3c3931f
Author: Dmitiry Setrakyan <ds...@gridgain.com>
Authored: Tue Apr 7 00:00:24 2015 -0700
Committer: Dmitiry Setrakyan <ds...@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();