#IGNITE-53: wip
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/83a571bc Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/83a571bc Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/83a571bc Branch: refs/heads/ignite-86 Commit: 83a571bc8d5bea30d2b81114857ebaad25972961 Parents: c500eda Author: ivasilinets <ivasilin...@gridgain.com> Authored: Tue Jan 20 14:48:59 2015 +0300 Committer: ivasilinets <ivasilin...@gridgain.com> Committed: Tue Jan 20 14:48:59 2015 +0300 ---------------------------------------------------------------------- .../ignite/internal/processors/cache/IgniteCacheProxy.java | 8 +++++++- .../processors/cache/GridCacheAbstractFullApiSelfTest.java | 2 +- 2 files changed, 8 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/83a571bc/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java index fbf6904..e3f60df 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java @@ -982,7 +982,13 @@ public class IgniteCacheProxy<K, V> extends IgniteAsyncSupportAdapter implements try { ctx.itHolder().checkWeakQueue(); - GridCacheQueryFuture<Map.Entry<K, V>> fut = delegate.queries().createScanQuery(null).execute(); + GridCacheQuery<Map.Entry<K, V>> query = delegate.queries().createScanQuery(null); + + query.includeBackups(false); + query.enableDedup(true); + query.keepAll(false); + + GridCacheQueryFuture<Map.Entry<K, V>> fut = query.execute(); return ctx.itHolder().iterator(fut, new CacheIteratorConverter<Entry<K, V>, Map.Entry<K, V>>() { @Override protected Entry<K, V> convert(Map.Entry<K, V> e) { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/83a571bc/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/GridCacheAbstractFullApiSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/GridCacheAbstractFullApiSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/GridCacheAbstractFullApiSelfTest.java index d0e8d34..7367cb8 100644 --- a/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/GridCacheAbstractFullApiSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/GridCacheAbstractFullApiSelfTest.java @@ -5087,7 +5087,7 @@ public abstract class GridCacheAbstractFullApiSelfTest extends GridCacheAbstract assertFalse(cache.iterator().hasNext()); - final int SIZE = 1000; + final int SIZE = 20000; Map<String, Integer> entries = new HashMap<>();
