Skip to content

Commit

Permalink
IGNITE-143 - Continuous queries refactoring (manual merge)
Browse files Browse the repository at this point in the history
  • Loading branch information
Valentin Kulichenko committed Feb 14, 2015
1 parent 4f649be commit e465477
Showing 1 changed file with 2 additions and 2 deletions.
Expand Up @@ -250,7 +250,7 @@ public GridCacheContext<K, V> context() {
} }
} }


private IgniteBiPredicate<K,V> accepAll() { private IgniteBiPredicate<K,V> acceptAll() {
return new IgniteBiPredicate<K,V>() { return new IgniteBiPredicate<K,V>() {
@Override public boolean apply(K k, V v) { @Override public boolean apply(K k, V v) {
return true; return true;
Expand All @@ -271,7 +271,7 @@ private QueryCursor<Entry<K,V>> query(Query filter, @Nullable ClusterGroup grp)
if (filter instanceof ScanQuery) { if (filter instanceof ScanQuery) {
IgniteBiPredicate<K,V> p = ((ScanQuery)filter).getFilter(); 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) if (grp != null)
qry.projection(grp); qry.projection(grp);
Expand Down

0 comments on commit e465477

Please sign in to comment.