Repository: ignite Updated Branches: refs/heads/master 6a7d079b7 -> 569dd21fc
Minor fix for StreamTransformer Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/569dd21f Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/569dd21f Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/569dd21f Branch: refs/heads/master Commit: 569dd21fc049be6cd89df0f24551818ba88f0329 Parents: 6a7d079 Author: Valentin Kulichenko <valentin.kuliche...@gmail.com> Authored: Tue Nov 10 17:45:10 2015 -0800 Committer: Valentin Kulichenko <valentin.kuliche...@gmail.com> Committed: Tue Nov 10 17:45:10 2015 -0800 ---------------------------------------------------------------------- .../main/java/org/apache/ignite/stream/StreamTransformer.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/569dd21f/modules/core/src/main/java/org/apache/ignite/stream/StreamTransformer.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/stream/StreamTransformer.java b/modules/core/src/main/java/org/apache/ignite/stream/StreamTransformer.java index f0f41bf..4435c0a 100644 --- a/modules/core/src/main/java/org/apache/ignite/stream/StreamTransformer.java +++ b/modules/core/src/main/java/org/apache/ignite/stream/StreamTransformer.java @@ -37,7 +37,7 @@ public abstract class StreamTransformer<K, V> implements StreamReceiver<K, V>, E /** {@inheritDoc} */ @Override public void receive(IgniteCache<K, V> cache, Collection<Map.Entry<K, V>> entries) throws IgniteException { for (Map.Entry<K, V> entry : entries) - cache.invoke(entry.getKey(), this); + cache.invoke(entry.getKey(), this, entry.getValue()); } /** @@ -53,4 +53,4 @@ public abstract class StreamTransformer<K, V> implements StreamReceiver<K, V>, E } }; } -} \ No newline at end of file +}
