ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject incubator-ignite git commit: # sprint-1 Use batch updater for removeAll
Date Thu, 12 Feb 2015 08:23:16 GMT
Repository: incubator-ignite
Updated Branches:
  refs/heads/sprint-1 533944a5a -> 03890cc6f


# sprint-1 Use batch updater for removeAll


Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/03890cc6
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/03890cc6
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/03890cc6

Branch: refs/heads/sprint-1
Commit: 03890cc6fcd0f3c601d89ef97c16607a5dc61329
Parents: 533944a
Author: sboikov <sboikov@gridgain.com>
Authored: Thu Feb 12 11:22:59 2015 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Thu Feb 12 11:22:59 2015 +0300

----------------------------------------------------------------------
 .../processors/cache/distributed/GridDistributedCacheAdapter.java | 3 +++
 .../processors/cache/GridCacheAbstractFullApiSelfTest.java        | 1 +
 2 files changed, 4 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/03890cc6/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedCacheAdapter.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedCacheAdapter.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedCacheAdapter.java
index eea1df1..1e53022 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedCacheAdapter.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedCacheAdapter.java
@@ -27,6 +27,7 @@ import org.apache.ignite.internal.processors.cache.distributed.dht.*;
 import org.apache.ignite.internal.processors.cache.distributed.near.*;
 import org.apache.ignite.internal.processors.cache.transactions.*;
 import org.apache.ignite.internal.processors.cache.version.*;
+import org.apache.ignite.internal.processors.dataload.*;
 import org.apache.ignite.internal.processors.task.*;
 import org.apache.ignite.internal.util.future.*;
 import org.apache.ignite.internal.util.typedef.internal.*;
@@ -277,6 +278,8 @@ public abstract class GridDistributedCacheAdapter<K, V> extends
GridCacheAdapter
                     dht = (GridDhtCacheAdapter<K, V>)cacheAdapter;
 
                 try (IgniteDataLoader<K, V> dataLdr = ignite.dataLoader(cacheName))
{
+                    dataLdr.updater(GridDataLoadCacheUpdaters.<K, V>batched());
+
                     for (GridDhtLocalPartition<K, V> locPart : dht.topology().currentLocalPartitions())
{
                         if (!locPart.isEmpty() && locPart.primary(topVer)) {
                             for (GridDhtCacheEntry<K, V> o : locPart.entries()) {

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/03890cc6/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java
b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java
index f579998..e3cdd64 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java
@@ -2194,6 +2194,7 @@ public abstract class GridCacheAbstractFullApiSelfTest extends GridCacheAbstract
     }
 
     /**
+     * @param async If {@code true} uses asynchronous operation.
      * @throws Exception In case of error.
      */
     private void globalRemoveAll(boolean async) throws Exception {


Mime
View raw message