ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [06/17] incubator-ignite git commit: #ignite-743: Implement IgniteCacheProxyLockFree.
Date Fri, 17 Apr 2015 11:01:11 GMT
#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-sprint-4
Commit: b5d6303cca2d0869ddbc02c93c017661f30750bf
Parents: 66a1b3c
Author: ivasilinets <ivasilinets@gridgain.com>
Authored: Tue Apr 14 16:29:08 2015 +0300
Committer: ivasilinets <ivasilinets@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);


Mime
View raw message