Repository: incubator-ignite Updated Branches: refs/heads/ignite-112 [created] 4c1e6e66a
ignite-112 - api changes Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/4c1e6e66 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/4c1e6e66 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/4c1e6e66 Branch: refs/heads/ignite-112 Commit: 4c1e6e66a45aade2e78bb497cc1ac3202746eeb9 Parents: 09c52dd Author: S.Vladykin <svlady...@gridgain.com> Authored: Wed Jan 21 18:02:59 2015 +0300 Committer: S.Vladykin <svlady...@gridgain.com> Committed: Wed Jan 21 18:02:59 2015 +0300 ---------------------------------------------------------------------- modules/core/src/main/java/org/apache/ignite/IgniteCache.java | 4 ---- .../main/java/org/apache/ignite/cache/query/QueryCursor.java | 7 ++++++- 2 files changed, 6 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4c1e6e66/modules/core/src/main/java/org/apache/ignite/IgniteCache.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteCache.java b/modules/core/src/main/java/org/apache/ignite/IgniteCache.java index 1398ebe..b328101 100644 --- a/modules/core/src/main/java/org/apache/ignite/IgniteCache.java +++ b/modules/core/src/main/java/org/apache/ignite/IgniteCache.java @@ -226,12 +226,8 @@ public interface IgniteCache<K, V> extends javax.cache.Cache<K, V>, IgniteAsyncS public QueryCursor<Entry<K, V>> query(QueryPredicate<K, V> filter); - public <R> QueryCursor<R> query(QueryReducer<Entry<K, V>, R> rmtRdc, QueryPredicate<K, V> filter); - public QueryCursor<List<?>> queryFields(QuerySqlPredicate<K, V> filter); - public <R> QueryCursor<R> queryFields(QueryReducer<List<?>, R> rmtRdc, QuerySqlPredicate<K, V> filter); - public QueryCursor<Entry<K, V>> localQuery(QueryPredicate<K, V> filter); public QueryCursor<List<?>> localQueryFields(QuerySqlPredicate<K, V> filter); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4c1e6e66/modules/core/src/main/java/org/apache/ignite/cache/query/QueryCursor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/query/QueryCursor.java b/modules/core/src/main/java/org/apache/ignite/cache/query/QueryCursor.java index 9d7f64a..fd0818e 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/query/QueryCursor.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/query/QueryCursor.java @@ -25,7 +25,7 @@ import java.util.*; * @author @java.author * @version @java.version */ -public interface QueryCursor<T> extends Iterable<T> { +public interface QueryCursor<T> extends Iterable<T>, AutoCloseable { /** * Gets all query results and stores them in the collection. * Use this method when you know in advance that query result is @@ -34,4 +34,9 @@ public interface QueryCursor<T> extends Iterable<T> { * @return Collection containing full query result. */ public Collection<T> getAll(); + + /** + * Closes cursor. + */ + @Override public void close(); }
