ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [31/48] incubator-ignite git commit: #IGNITE-53: wip
Date Fri, 23 Jan 2015 17:18:05 GMT
#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/sprint-1
Commit: 83a571bc8d5bea30d2b81114857ebaad25972961
Parents: c500eda
Author: ivasilinets <ivasilinets@gridgain.com>
Authored: Tue Jan 20 14:48:59 2015 +0300
Committer: ivasilinets <ivasilinets@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<>();
 


Mime
View raw message