# 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-sql-tests Commit: 98f177f6195ed8b1a8d2e24e8ed035a8666a8f2e Parents: e92b602 Author: Dmitiry Setrakyan <dsetrak...@gridgain.com> Authored: Wed Feb 25 02:41:05 2015 -0500 Committer: Dmitiry Setrakyan <dsetrak...@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; } });
