ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [12/50] [abbrv] incubator-ignite git commit: # sprint-2 - Example fix.
Date Fri, 27 Feb 2015 14:58:47 GMT
# sprint-2 - Example fix.


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

Branch: refs/heads/ignite-290
Commit: 98f177f6195ed8b1a8d2e24e8ed035a8666a8f2e
Parents: e92b602
Author: Dmitiry Setrakyan <dsetrakyan@gridgain.com>
Authored: Wed Feb 25 02:41:05 2015 -0500
Committer: Dmitiry Setrakyan <dsetrakyan@gridgain.com>
Committed: Wed Feb 25 02:41:05 2015 -0500

----------------------------------------------------------------------
 .../ignite/examples/datagrid/CacheContinuousQueryExample.java  | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/98f177f6/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheContinuousQueryExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheContinuousQueryExample.java
b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheContinuousQueryExample.java
index ec7a040..23a23f7 100644
--- a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheContinuousQueryExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheContinuousQueryExample.java
@@ -60,9 +60,9 @@ public class CacheContinuousQueryExample {
                 cache.put(i, Integer.toString(i));
 
             // Create new continuous query.
-            ContinuousQuery<Integer, String> qry = Query.continuous();
+            ContinuousQuery<Integer, String> qry = new ContinuousQuery<>();
 
-            qry.setInitialPredicate(Query.scan(new IgniteBiPredicate<Integer, String>()
{
+            qry.setInitialPredicate(new ScanQuery<>(new IgniteBiPredicate<Integer,
String>() {
                 @Override public boolean apply(Integer key, String val) {
                     return key > 10;
                 }
@@ -80,7 +80,7 @@ public class CacheContinuousQueryExample {
             // Entry that pass this filter will be sent to the caller.
             qry.setRemoteFilter(new CacheEntryEventFilter<Integer, String>() {
                 @Override public boolean evaluate(CacheEntryEvent<? extends Integer, ?
extends String> e) {
-                    return e.getKey() > 25;
+                    return e.getKey() > 10;
                 }
             });
 


Mime
View raw message