ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dsetrak...@apache.org
Subject [1/2] incubator-ignite git commit: # ignite-45 - fixing query.
Date Sat, 21 Mar 2015 06:18:16 GMT
Repository: incubator-ignite
Updated Branches:
  refs/heads/ignite-45 41d6c97df -> 3d209d7b5


# ignite-45 - fixing query.


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

Branch: refs/heads/ignite-45
Commit: 63ea553fa3d208c4a23caecbedc78d36e2de281a
Parents: 7deb146
Author: Dmitiry Setrakyan <dsetrakyan@gridgain.com>
Authored: Fri Mar 20 23:17:55 2015 -0700
Committer: Dmitiry Setrakyan <dsetrakyan@gridgain.com>
Committed: Fri Mar 20 23:17:55 2015 -0700

----------------------------------------------------------------------
 .../org/apache/ignite/cache/query/ContinuousQuery.java    | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/63ea553f/modules/core/src/main/java/org/apache/ignite/cache/query/ContinuousQuery.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/cache/query/ContinuousQuery.java
b/modules/core/src/main/java/org/apache/ignite/cache/query/ContinuousQuery.java
index dbfb5b5..4246f4f 100644
--- a/modules/core/src/main/java/org/apache/ignite/cache/query/ContinuousQuery.java
+++ b/modules/core/src/main/java/org/apache/ignite/cache/query/ContinuousQuery.java
@@ -59,16 +59,16 @@ import javax.cache.event.*;
  * You can create and execute continuous query like so:
  * <pre name="code" class="java">
  * // Create new continuous query.
- * ContinuousQuery&lt;UUID, Person&gt; qry = new ContinuousQuery&lt;&gt;();
+ * ContinuousQuery&lt;Long, Person&gt; qry = new ContinuousQuery&lt;&gt;();
  *
  * // Initial iteration query will return all persons with salary above 1000.
- * qry.setInitialQuery(new ScanQuery((UUID nodeId, Person p) -> p.getSalary() &gt;
1000));
+ * qry.setInitialQuery(new ScanQuery&lt;&gt;((id, p) -> p.getSalary() &gt;
1000));
  *
  *
  * // Callback that is called locally when update notifications are received.
  * // It simply prints out information about all created persons.
  * qry.setLocalListener((evts) -> {
- *     for (CacheEntryEvent&lt;? extends UUID, ? extends Person&gt; e : evts) {
+ *     for (CacheEntryEvent&lt;? extends Long, ? extends Person&gt; e : evts) {
  *         Person p = e.getValue();
  *
  *         System.out.println(p.getFirstName() + " " + p.getLastName() + "'s salary is "
+ p.getSalary());
@@ -76,10 +76,10 @@ import javax.cache.event.*;
  * });
  *
  * // Continuous listener will be notified for persons with salary above 1000.
- * qry.setRemoteFilter(evt -> e.getValue().getSalary() &gt; 1000);
+ * qry.setRemoteFilter(evt -> evt.getValue().getSalary() &gt; 1000);
  *
  * // Execute query and get cursor that iterates through initial data.
- * QueryCursor&lt;Cache.Entry&lt;UUID, Person&gt;&gt; cur = cache.query(qry);
+ * QueryCursor&lt;Cache.Entry&lt;Long, Person&gt;&gt; cur = cache.query(qry);
  * </pre>
  * This will execute query on all nodes that have cache you are working with and
  * listener will start to receive notifications for cache updates.


Mime
View raw message