ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [03/39] incubator-ignite git commit: #ignite-738: IgniteTxMultiNodeAbstractTest uses new query Api.
Date Thu, 16 Apr 2015 17:36:53 GMT
#ignite-738: IgniteTxMultiNodeAbstractTest uses new query Api.


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

Branch: refs/heads/ignite-485
Commit: aad30f7ff8ee14e519e271dc124352f7aef4ed08
Parents: 0cdd605
Author: ivasilinets <ivasilinets@gridgain.com>
Authored: Mon Apr 13 16:38:03 2015 +0300
Committer: ivasilinets <ivasilinets@gridgain.com>
Committed: Mon Apr 13 16:38:03 2015 +0300

----------------------------------------------------------------------
 .../processors/cache/IgniteTxMultiNodeAbstractTest.java      | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/aad30f7f/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteTxMultiNodeAbstractTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteTxMultiNodeAbstractTest.java
b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteTxMultiNodeAbstractTest.java
index a9aa484..9995099 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteTxMultiNodeAbstractTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteTxMultiNodeAbstractTest.java
@@ -294,15 +294,15 @@ public abstract class IgniteTxMultiNodeAbstractTest extends GridCommonAbstractTe
             }
 
             while (true) {
-                CacheQuery<Map.Entry<String, Integer>> qry =
-                    ((IgniteKernal)ignite).<String, Integer>getCache(null).queries()
-                        .createSqlQuery(Integer.class, "_key != 'RMVD_CNTR_KEY' and _val
>= 0");
+
+                SqlQuery<String, Integer> qry =
+                    new SqlQuery<>(Integer.class, "_key != 'RMVD_CNTR_KEY' and _val
>= 0");
 
                 if (DEBUG)
                     ignite.log().info("Before executing query [retry=" + retry + ", locId="
+ locId +
                         ", txId=" + tx.xid() + ']');
 
-                Map.Entry<String, Integer> entry = qry.execute().next();
+                Cache.Entry<String, Integer> entry = F.first(cache.query(qry).getAll());
 
                 if (entry == null) {
                     ignite.log().info("*** Queue is empty.");


Mime
View raw message