#ignite-743: Implement IgniteCacheProxyLockFree.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/b5d6303c Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/b5d6303c Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/b5d6303c Branch: refs/heads/ignite-485 Commit: b5d6303cca2d0869ddbc02c93c017661f30750bf Parents: 66a1b3c Author: ivasilinets <ivasilin...@gridgain.com> Authored: Tue Apr 14 16:29:08 2015 +0300 Committer: ivasilinets <ivasilin...@gridgain.com> Committed: Tue Apr 14 16:29:08 2015 +0300 ---------------------------------------------------------------------- .../processors/datastreamer/DataStreamerCacheUpdaters.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b5d6303c/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerCacheUpdaters.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerCacheUpdaters.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerCacheUpdaters.java index 7f6bb5b..ed51730 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerCacheUpdaters.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerCacheUpdaters.java @@ -85,7 +85,7 @@ public class DataStreamerCacheUpdaters { // Here we assume that there are no key duplicates, so the following calls are valid. if (rmvCol != null) - ((IgniteCacheProxy<K, V>)cache).removeAll(rmvCol); + ((IgniteCacheProxyLockFree<K, V>)cache).removeAll(rmvCol); if (putMap != null) cache.putAll(putMap);
