Repository: incubator-ignite Updated Branches: refs/heads/ignite-45 f78883332 -> 08e65e9d8
# IGNITE-45 - 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/08e65e9d Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/08e65e9d Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/08e65e9d Branch: refs/heads/ignite-45 Commit: 08e65e9d80a691d3dd9d4f2a2867ab1b919356a8 Parents: f788833 Author: Valentin Kulichenko <vkuliche...@gridgain.com> Authored: Sat Mar 21 17:40:59 2015 -0700 Committer: Valentin Kulichenko <vkuliche...@gridgain.com> Committed: Sat Mar 21 17:40:59 2015 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/ignite/stream/StreamVisitor.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/08e65e9d/modules/core/src/main/java/org/apache/ignite/stream/StreamVisitor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/stream/StreamVisitor.java b/modules/core/src/main/java/org/apache/ignite/stream/StreamVisitor.java index 105607a..44bc818 100644 --- a/modules/core/src/main/java/org/apache/ignite/stream/StreamVisitor.java +++ b/modules/core/src/main/java/org/apache/ignite/stream/StreamVisitor.java @@ -42,8 +42,9 @@ public abstract class StreamVisitor<K, V> implements StreamReceiver<K, V> { * * @param cache Cache. * @param entry Visited entry. + * @throws IgniteException In case of error. */ - protected abstract void visit(IgniteCache<K, V> cache, Map.Entry<K, V> entry); + protected abstract void visit(IgniteCache<K, V> cache, Map.Entry<K, V> entry) throws IgniteException; /** * Creates a new visitor based on instance of {@link IgniteBiInClosure}.
