ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [13/28] incubator-ignite git commit: IGNITE-143 - Continuous queries refactoring (manual merge)
Date Sun, 15 Feb 2015 07:55:47 GMT
IGNITE-143 - Continuous queries refactoring (manual merge)


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

Branch: refs/heads/sprint-1
Commit: e4654779f0e24e5a47b830467f25abb3b61dcea3
Parents: 4f649be
Author: Valentin Kulichenko <vkulichenko@gridgain.com>
Authored: Fri Feb 13 17:16:23 2015 -0800
Committer: Valentin Kulichenko <vkulichenko@gridgain.com>
Committed: Fri Feb 13 17:16:23 2015 -0800

----------------------------------------------------------------------
 .../ignite/internal/processors/cache/IgniteCacheProxy.java       | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/e4654779/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java
index 53fc796..ede310a 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java
@@ -250,7 +250,7 @@ public class IgniteCacheProxy<K, V> extends AsyncSupportAdapter<IgniteCache<K,
V
         }
     }
 
-    private IgniteBiPredicate<K,V> accepAll() {
+    private IgniteBiPredicate<K,V> acceptAll() {
         return new IgniteBiPredicate<K,V>() {
             @Override public boolean apply(K k, V v) {
                 return true;
@@ -271,7 +271,7 @@ public class IgniteCacheProxy<K, V> extends AsyncSupportAdapter<IgniteCache<K,
V
         if (filter instanceof ScanQuery) {
             IgniteBiPredicate<K,V> p = ((ScanQuery)filter).getFilter();
 
-            qry = delegate.queries().createScanQuery(p != null ? p : accepAll());
+            qry = delegate.queries().createScanQuery(p != null ? p : acceptAll());
 
             if (grp != null)
                 qry.projection(grp);


Mime
View raw message