ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vkuliche...@apache.org
Subject [23/50] [abbrv] incubator-ignite git commit: IGNITE-SQL Fixed tests.
Date Fri, 13 Feb 2015 17:24:59 GMT
IGNITE-SQL Fixed tests.


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

Branch: refs/heads/ignite-143
Commit: 426e48ef7d15ebfb5e9f0c16879e8eb5d3260b30
Parents: d7df9b3
Author: nikolay_tikhonov <ntikhonov@gridgain.com>
Authored: Fri Feb 13 17:18:54 2015 +0300
Committer: nikolay_tikhonov <ntikhonov@gridgain.com>
Committed: Fri Feb 13 17:18:54 2015 +0300

----------------------------------------------------------------------
 .../cache/IgniteCacheQueryLoadSelfTest.java      | 19 ++++++++++++-------
 1 file changed, 12 insertions(+), 7 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/426e48ef/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheQueryLoadSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheQueryLoadSelfTest.java
b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheQueryLoadSelfTest.java
index 0a62efb..356547a 100644
--- a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheQueryLoadSelfTest.java
+++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheQueryLoadSelfTest.java
@@ -131,11 +131,13 @@ public class IgniteCacheQueryLoadSelfTest extends GridCommonAbstractTest
{
      * @throws Exception If failed.
      */
     public void testLoadCacheAsync() throws Exception {
-        IgniteCache<Integer, ValueObject> cache = grid(0).jcache(null);
+        IgniteCache<Integer, ValueObject> cache = grid().jcache(null);
+
+        IgniteCache<Integer, ValueObject> asyncCache = cache.withAsync();
 
-        cache.withAsync().loadCache(null, 0);
+        asyncCache.loadCache(null, 0);
 
-        cache.future().get();
+        asyncCache.future().get();
 
         assert cache.size() == PUT_CNT;
 
@@ -175,15 +177,18 @@ public class IgniteCacheQueryLoadSelfTest extends GridCommonAbstractTest
{
     public void testLoadCacheAsyncFiltered() throws Exception {
         IgniteCache<Integer, ValueObject> cache = grid().jcache(null);
 
-        cache.withAsync().loadCache(new P2<Integer, ValueObject>() {
-            @Override public boolean apply(Integer key, ValueObject val) {
+        IgniteCache<Integer, ValueObject> asyncCache = cache.withAsync();
+
+        asyncCache.loadCache(new P2<Integer, ValueObject>() {
+            @Override
+            public boolean apply(Integer key, ValueObject val) {
                 return key >= 5;
             }
         }, 0);
 
-        cache.future().get();
+        asyncCache.future().get();
 
-        assert cache.size() == PUT_CNT - 5;
+        assert cache.localSize() == PUT_CNT - 5;
 
         Collection<Cache.Entry<Integer, ValueObject>> res =
             cache.query(new SqlQuery(ValueObject.class, "val >= 0")).getAll();


Mime
View raw message