Return-Path: X-Original-To: apmail-ignite-commits-archive@minotaur.apache.org Delivered-To: apmail-ignite-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 253031763E for ; Mon, 20 Apr 2015 11:48:43 +0000 (UTC) Received: (qmail 69686 invoked by uid 500); 20 Apr 2015 11:48:43 -0000 Delivered-To: apmail-ignite-commits-archive@ignite.apache.org Received: (qmail 69617 invoked by uid 500); 20 Apr 2015 11:48:43 -0000 Mailing-List: contact commits-help@ignite.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@ignite.incubator.apache.org Delivered-To: mailing list commits@ignite.incubator.apache.org Received: (qmail 69596 invoked by uid 99); 20 Apr 2015 11:48:43 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 20 Apr 2015 11:48:43 +0000 X-ASF-Spam-Status: No, hits=-0.0 required=5.0 tests=SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: local policy) Received: from [54.164.171.186] (HELO mx1-us-east.apache.org) (54.164.171.186) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 20 Apr 2015 11:48:37 +0000 Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx1-us-east.apache.org (ASF Mail Server at mx1-us-east.apache.org) with SMTP id B031A43ED3 for ; Mon, 20 Apr 2015 11:48:13 +0000 (UTC) Received: (qmail 67802 invoked by uid 99); 20 Apr 2015 11:48:13 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 20 Apr 2015 11:48:13 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 00FCCE08E9; Mon, 20 Apr 2015 11:48:12 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: sboikov@apache.org To: commits@ignite.incubator.apache.org Date: Mon, 20 Apr 2015 11:48:32 -0000 Message-Id: <5ce24cf4f8ec49cba299719142c0ba74@git.apache.org> In-Reply-To: <5de91c9130ca42bb80d3237233377376@git.apache.org> References: <5de91c9130ca42bb80d3237233377376@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [21/50] [abbrv] incubator-ignite git commit: #ignite-758: remove CacheQueries. X-Virus-Checked: Checked by ClamAV on apache.org #ignite-758: remove CacheQueries. Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/6cf3da66 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/6cf3da66 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/6cf3da66 Branch: refs/heads/ignite-sprint-4 Commit: 6cf3da663d237f1bd86c141f9d3be6a5b988081f Parents: 34b5b51 Author: ivasilinets Authored: Thu Apr 16 23:28:22 2015 +0300 Committer: ivasilinets Committed: Thu Apr 16 23:28:22 2015 +0300 ---------------------------------------------------------------------- .../processors/cache/GridCacheAdapter.java | 14 ------ .../processors/cache/GridCacheProxyImpl.java | 16 ------- .../processors/cache/IgniteCacheProxy.java | 3 -- .../processors/cache/IgniteInternalCache.java | 12 ----- .../processors/cache/query/CacheQueries.java | 29 ------------ .../cache/query/CacheQueriesImpl.java | 50 -------------------- .../processors/cache/query/CacheQuery.java | 5 +- 7 files changed, 1 insertion(+), 128 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/6cf3da66/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java index 9938cbc..24da97b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java @@ -168,9 +168,6 @@ public abstract class GridCacheAdapter implements IgniteInternalCache qry; - /** Affinity impl. */ private Affinity aff; @@ -274,15 +271,9 @@ public abstract class GridCacheAdapter implements IgniteInternalCache(ctx, false); aff = new GridCacheAffinityImpl<>(ctx); } - /** {@inheritDoc} */ - @Override public void setQueryKeepPortable() { - qry = new CacheQueriesImpl<>(ctx, true); - } - /** * Prints memory stats. */ @@ -360,11 +351,6 @@ public abstract class GridCacheAdapter implements IgniteInternalCache preloader(); /** {@inheritDoc} */ - @Override public CacheQueries queries() { - return qry; - } - - /** {@inheritDoc} */ @Override public Affinity affinity() { return aff; } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/6cf3da66/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProxyImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProxyImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProxyImpl.java index 3f0e420..3db0a8f 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProxyImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProxyImpl.java @@ -24,7 +24,6 @@ import org.apache.ignite.configuration.*; import org.apache.ignite.internal.*; import org.apache.ignite.internal.processors.cache.affinity.*; import org.apache.ignite.internal.processors.cache.dr.*; -import org.apache.ignite.internal.processors.cache.query.*; import org.apache.ignite.internal.processors.cache.transactions.*; import org.apache.ignite.internal.processors.cache.version.*; import org.apache.ignite.internal.util.tostring.*; @@ -65,9 +64,6 @@ public class GridCacheProxyImpl implements IgniteInternalCache, Exte @GridToStringExclude private CacheOperationContext prj; - /** Cache queries. */ - private CacheQueries qry; - /** Affinity. */ private Affinity aff; @@ -95,7 +91,6 @@ public class GridCacheProxyImpl implements IgniteInternalCache, Exte gate = ctx.gate(); cache = ctx.cache(); - qry = new CacheQueriesImpl<>(ctx, prj != null ? prj.isKeepPortable() : false); aff = new GridCacheAffinityProxy<>(ctx, ctx.cache().affinity()); } @@ -143,16 +138,6 @@ public class GridCacheProxyImpl implements IgniteInternalCache, Exte } /** {@inheritDoc} */ - @Override public void setQueryKeepPortable() { - qry = new CacheQueriesImpl<>(ctx, true); - } - - /** {@inheritDoc} */ - @Override public CacheQueries queries() { - return qry; - } - - /** {@inheritDoc} */ @Override public Affinity affinity() { return aff; } @@ -1575,7 +1560,6 @@ public class GridCacheProxyImpl implements IgniteInternalCache, Exte gate = ctx.gate(); cache = ctx.cache(); - qry = new CacheQueriesImpl<>(ctx, prj != null ? prj.isKeepPortable() : false); aff = new GridCacheAffinityProxy<>(ctx, ctx.cache().affinity()); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/6cf3da66/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 e5add1d..9d1248b 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 @@ -110,9 +110,6 @@ public class IgniteCacheProxy extends AsyncSupportAdapter(ctx, delegate, prjCtx); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/6cf3da66/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteInternalCache.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteInternalCache.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteInternalCache.java index 6a46f9c..89da6af 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteInternalCache.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteInternalCache.java @@ -208,18 +208,6 @@ public interface IgniteInternalCache extends Iterable> { public boolean skipStore(); /** - * Set keep portable flag for queries. - */ - public void setQueryKeepPortable(); - - /** - * Returns queries facade responsible for creating various SQL, TEXT, or SCAN queries. - - * @return Queries facade responsible for creating various SQL, TEXT, or SCAN queries. - */ - public CacheQueries queries(); - - /** * @param skipStore Skip store flag. * @return New projection based on this one, but with skip store flag enabled. */ http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/6cf3da66/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/CacheQueries.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/CacheQueries.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/CacheQueries.java deleted file mode 100644 index 0fe373a..0000000 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/CacheQueries.java +++ /dev/null @@ -1,29 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.ignite.internal.processors.cache.query; - -import org.apache.ignite.lang.*; -import org.jetbrains.annotations.*; - -import java.util.*; - -/** - * Internal queries interface. - */ -public interface CacheQueries { -} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/6cf3da66/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/CacheQueriesImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/CacheQueriesImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/CacheQueriesImpl.java deleted file mode 100644 index 99017cd..0000000 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/CacheQueriesImpl.java +++ /dev/null @@ -1,50 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.ignite.internal.processors.cache.query; - -import org.apache.ignite.internal.processors.cache.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.lang.*; -import org.apache.ignite.spi.indexing.*; -import org.jetbrains.annotations.*; - -import java.util.*; - -import static org.apache.ignite.internal.processors.cache.query.GridCacheQueryType.*; - -/** - * {@link CacheQueries} implementation. - */ -public class CacheQueriesImpl implements CacheQueries { - /** */ - private GridCacheContext ctx; - - /** */ - private boolean keepPortable; - - /** - * @param ctx Context. - * @param keepPortable Keep portable flag. - */ - public CacheQueriesImpl(GridCacheContext ctx, boolean keepPortable) { - assert ctx != null; - - this.ctx = ctx; - this.keepPortable = keepPortable; - } -} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/6cf3da66/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/CacheQuery.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/CacheQuery.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/CacheQuery.java index bab6db6..0658828 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/CacheQuery.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/CacheQuery.java @@ -27,8 +27,6 @@ import org.jetbrains.annotations.*; /** * Main API for configuring and executing cache queries. *

- * Cache queries are created from {@link CacheQueries} API via any of the available - * {@code createXXXQuery(...)} methods. *

SQL Queries

* {@code SQL} query allows to execute distributed cache * queries using standard SQL syntax. All values participating in where clauses @@ -60,8 +58,7 @@ import org.jetbrains.annotations.*; *

Scan Queries

* Sometimes when it is known in advance that SQL query will cause a full data scan, or whenever data set * is relatively small, the full scan query may be used. This query will iterate over all cache - * entries, skipping over entries that don't pass the optionally provided key-value filter - * (see {@link CacheQueries#createScanQuery(org.apache.ignite.lang.IgniteBiPredicate)} method). + * entries, skipping over entries that don't pass the optionally provided key-value filter. *

Limitations

* Data in Ignite cache is usually distributed across several nodes, * so some queries may not work as expected. Keep in mind following limitations