# 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-639 Commit: dcd24e0d60f6ecd7339798acd8a5e6bae0310dd0 Parents: 3c3931f Author: Dmitiry Setrakyan <dsetrak...@gridgain.com> Authored: Tue Apr 7 00:00:24 2015 -0700 Committer: Dmitiry Setrakyan <dsetrak...@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();
