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/ignite-nio Commit: e4654779f0e24e5a47b830467f25abb3b61dcea3 Parents: 4f649be Author: Valentin Kulichenko <vkuliche...@gridgain.com> Authored: Fri Feb 13 17:16:23 2015 -0800 Committer: Valentin Kulichenko <vkuliche...@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);
