ignite-sql-old - fixes
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/23781f3b Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/23781f3b Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/23781f3b Branch: refs/heads/ignite-nio Commit: 23781f3bfb4ece965bda8d67aec13609271e7de9 Parents: a0f9e67 Author: S.Vladykin <svlady...@gridgain.com> Authored: Sat Feb 14 14:09:28 2015 +0300 Committer: S.Vladykin <svlady...@gridgain.com> Committed: Sat Feb 14 14:09:28 2015 +0300 ---------------------------------------------------------------------- .../ignite/internal/processors/cache/IgniteCacheProxy.java | 6 +++--- .../internal/processors/cache/query/QueryCursorImpl.java | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/23781f3b/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 023b039..b4cfc09 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 @@ -299,7 +299,7 @@ public class IgniteCacheProxy<K, V> extends AsyncSupportAdapter<IgniteCache<K, V else throw new IgniteException("Unsupported query predicate: " + filter); - return new org.apache.ignite.internal.processors.cache.QueryCursorImpl<>(new GridCloseableIteratorAdapter<Entry<K,V>>() { + return new QueryCursorImpl<>(new GridCloseableIteratorAdapter<Entry<K,V>>() { /** */ Map.Entry<K,V> cur; @@ -447,7 +447,7 @@ public class IgniteCacheProxy<K, V> extends AsyncSupportAdapter<IgniteCache<K, V */ private QueryCursor<Entry<K,V>> doLocalQuery(SqlQuery p) { return null; // TODO -// new org.apache.ignite.internal.processors.cache.QueryCursorImpl<>(ctx.kernalContext().query().<K,V>queryLocal( +// new QueryCursorImpl<>(ctx.kernalContext().query().<K,V>queryLocal( // ctx.name(), p.getType(), p.getSql(), p.getArgs())); } @@ -457,7 +457,7 @@ public class IgniteCacheProxy<K, V> extends AsyncSupportAdapter<IgniteCache<K, V */ private QueryCursor<List<?>> doLocalFieldsQuery(SqlFieldsQuery q) { return null; // TODO -// new org.apache.ignite.internal.processors.cache.QueryCursorImpl<>(ctx.kernalContext().query().queryLocalFields( +// new QueryCursorImpl<>(ctx.kernalContext().query().queryLocalFields( // ctx.name(), q.getSql(), q.getArgs())); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/23781f3b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/QueryCursorImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/QueryCursorImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/QueryCursorImpl.java index cc1af78..d7691e6 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/QueryCursorImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/QueryCursorImpl.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package org.apache.ignite.internal.processors.cache; +package org.apache.ignite.internal.processors.cache.query; import org.apache.ignite.*; import org.apache.ignite.cache.query.*;
