# 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/ignite-189 Commit: 03890cc6fcd0f3c601d89ef97c16607a5dc61329 Parents: 533944a Author: sboikov <sboi...@gridgain.com> Authored: Thu Feb 12 11:22:59 2015 +0300 Committer: sboikov <sboi...@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 {
