# ignite-45 - fixing streaming.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/dfc1a49c Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/dfc1a49c Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/dfc1a49c Branch: refs/heads/ignite-45 Commit: dfc1a49c69c259126c25dda15c37025dc16b50de Parents: a034ed0 Author: Dmitiry Setrakyan <dsetrak...@gridgain.com> Authored: Sat Mar 21 01:44:45 2015 -0700 Committer: Dmitiry Setrakyan <dsetrak...@gridgain.com> Committed: Sat Mar 21 01:44:45 2015 -0700 ---------------------------------------------------------------------- .../examples/java8/computegrid/ComputeTaskMapExample.java | 5 ++--- .../examples/java8/computegrid/ComputeTaskSplitExample.java | 5 ++--- 2 files changed, 4 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dfc1a49c/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeTaskMapExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeTaskMapExample.java b/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeTaskMapExample.java index bc8f305..44af4af 100644 --- a/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeTaskMapExample.java +++ b/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeTaskMapExample.java @@ -21,7 +21,6 @@ import org.apache.ignite.*; import org.apache.ignite.cluster.*; import org.apache.ignite.compute.*; import org.apache.ignite.examples.java7.*; -import org.jetbrains.annotations.*; import java.util.*; @@ -85,7 +84,7 @@ public class ComputeTaskMapExample { ClusterNode node = it.next(); map.put(new ComputeJobAdapter() { - @Nullable @Override public Object execute() { + @Override public Object execute() { System.out.println(); System.out.println(">>> Printing '" + word + "' on this node from ignite job."); @@ -99,7 +98,7 @@ public class ComputeTaskMapExample { } /** {@inheritDoc} */ - @Nullable @Override public Integer reduce(List<ComputeJobResult> results) { + @Override public Integer reduce(List<ComputeJobResult> results) { return results.stream().mapToInt(ComputeJobResult::getData).sum(); } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dfc1a49c/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..76fb380 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 @@ -20,7 +20,6 @@ package org.apache.ignite.examples.java8.computegrid; import org.apache.ignite.*; import org.apache.ignite.compute.*; import org.apache.ignite.examples.java7.*; -import org.jetbrains.annotations.*; import java.util.*; import java.util.stream.*; @@ -75,7 +74,7 @@ public class ComputeTaskSplitExample { @Override protected Collection<? extends ComputeJob> split(int clusterSize, String arg) { return Stream.of(arg.split(" ")).map(word -> new ComputeJobAdapter() { - @Nullable @Override public Object execute() { + @Override public Object execute() { System.out.println(); System.out.println(">>> Printing '" + word + "' on this node from ignite job."); @@ -86,7 +85,7 @@ public class ComputeTaskSplitExample { } /** {@inheritDoc} */ - @Nullable @Override public Integer reduce(List<ComputeJobResult> results) { + @Override public Integer reduce(List<ComputeJobResult> results) { return results.stream().mapToInt(ComputeJobResult::getData).sum(); } }
