http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/CountPRQueryNode.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/CountPRQueryNode.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/CountPRQueryNode.java index 50eb07b..abed999 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/CountPRQueryNode.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/CountPRQueryNode.java @@ -14,9 +14,9 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal.aggregate; +package org.apache.geode.cache.query.internal.aggregate; -import com.gemstone.gemfire.cache.query.Aggregator; +import org.apache.geode.cache.query.Aggregator; /** * Computes the count of the rows on the PR query node
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/DistinctAggregator.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/DistinctAggregator.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/DistinctAggregator.java index 2720897..8cd84b5 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/DistinctAggregator.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/DistinctAggregator.java @@ -14,12 +14,12 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal.aggregate; +package org.apache.geode.cache.query.internal.aggregate; import java.util.HashSet; import java.util.Set; -import com.gemstone.gemfire.cache.query.QueryService; +import org.apache.geode.cache.query.QueryService; /** * The class used to hold the distinct values. This will get instantiated on the http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/MaxMin.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/MaxMin.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/MaxMin.java index b643c9c..ee98649 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/MaxMin.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/MaxMin.java @@ -14,10 +14,10 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal.aggregate; +package org.apache.geode.cache.query.internal.aggregate; -import com.gemstone.gemfire.cache.query.Aggregator; -import com.gemstone.gemfire.cache.query.QueryService; +import org.apache.geode.cache.query.Aggregator; +import org.apache.geode.cache.query.QueryService; /** * Computes the Max or Min http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/Sum.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/Sum.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/Sum.java index 96f80b8..387929a 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/Sum.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/Sum.java @@ -14,9 +14,9 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal.aggregate; +package org.apache.geode.cache.query.internal.aggregate; -import com.gemstone.gemfire.cache.query.QueryService; +import org.apache.geode.cache.query.QueryService; /** * Computes the sum for replicated & PR based queries. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/SumDistinct.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/SumDistinct.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/SumDistinct.java index 57c2a9a..b166170 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/SumDistinct.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/SumDistinct.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal.aggregate; +package org.apache.geode.cache.query.internal.aggregate; /** * Computes the sum of distinct values for replicated region based queries. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/SumDistinctPRQueryNode.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/SumDistinctPRQueryNode.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/SumDistinctPRQueryNode.java index bee5df2..174c0e6 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/SumDistinctPRQueryNode.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/SumDistinctPRQueryNode.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal.aggregate; +package org.apache.geode.cache.query.internal.aggregate; import java.util.Set; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/ClientCQ.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/ClientCQ.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/ClientCQ.java index 44d6ed9..50a1729 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/ClientCQ.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/ClientCQ.java @@ -14,13 +14,13 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal.cq; +package org.apache.geode.cache.query.internal.cq; -import com.gemstone.gemfire.cache.client.internal.Connection; -import com.gemstone.gemfire.cache.client.internal.ProxyCache; -import com.gemstone.gemfire.cache.query.CqClosedException; -import com.gemstone.gemfire.cache.query.CqException; -import com.gemstone.gemfire.cache.query.CqQuery; +import org.apache.geode.cache.client.internal.Connection; +import org.apache.geode.cache.client.internal.ProxyCache; +import org.apache.geode.cache.query.CqClosedException; +import org.apache.geode.cache.query.CqException; +import org.apache.geode.cache.query.CqQuery; public interface ClientCQ extends InternalCqQuery { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/CqAttributesImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/CqAttributesImpl.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/CqAttributesImpl.java index cab855e..4e176aa 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/CqAttributesImpl.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/CqAttributesImpl.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal.cq; +package org.apache.geode.cache.query.internal.cq; import java.io.Serializable; import java.util.ArrayList; @@ -22,14 +22,14 @@ import java.util.Arrays; import java.util.Iterator; import java.util.List; -import com.gemstone.gemfire.SystemFailure; -import com.gemstone.gemfire.cache.CacheCallback; -import com.gemstone.gemfire.cache.query.CqAttributes; -import com.gemstone.gemfire.cache.query.CqAttributesMutator; -import com.gemstone.gemfire.cache.query.CqListener; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; +import org.apache.geode.SystemFailure; +import org.apache.geode.cache.CacheCallback; +import org.apache.geode.cache.query.CqAttributes; +import org.apache.geode.cache.query.CqAttributesMutator; +import org.apache.geode.cache.query.CqListener; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; import org.apache.logging.log4j.Logger; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/CqService.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/CqService.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/CqService.java index d6fba13..0faa845 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/CqService.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/CqService.java @@ -14,31 +14,31 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal.cq; +package org.apache.geode.cache.query.internal.cq; import java.util.Collection; import java.util.HashMap; import java.util.List; import java.util.Map; -import com.gemstone.gemfire.cache.CacheEvent; -import com.gemstone.gemfire.cache.client.Pool; -import com.gemstone.gemfire.cache.client.internal.InternalPool; -import com.gemstone.gemfire.cache.client.internal.QueueManager; -import com.gemstone.gemfire.cache.client.internal.UserAttributes; -import com.gemstone.gemfire.cache.query.CqAttributes; -import com.gemstone.gemfire.cache.query.CqClosedException; -import com.gemstone.gemfire.cache.query.CqException; -import com.gemstone.gemfire.cache.query.CqExistsException; -import com.gemstone.gemfire.cache.query.CqQuery; -import com.gemstone.gemfire.cache.query.CqServiceStatistics; -import com.gemstone.gemfire.cache.query.QueryInvalidException; -import com.gemstone.gemfire.cache.query.RegionNotFoundException; -import com.gemstone.gemfire.distributed.internal.DistributionAdvisor.Profile; -import com.gemstone.gemfire.internal.cache.EventID; -import com.gemstone.gemfire.internal.cache.FilterRoutingInfo; -import com.gemstone.gemfire.internal.cache.tier.sockets.CacheClientNotifier; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.cache.CacheEvent; +import org.apache.geode.cache.client.Pool; +import org.apache.geode.cache.client.internal.InternalPool; +import org.apache.geode.cache.client.internal.QueueManager; +import org.apache.geode.cache.client.internal.UserAttributes; +import org.apache.geode.cache.query.CqAttributes; +import org.apache.geode.cache.query.CqClosedException; +import org.apache.geode.cache.query.CqException; +import org.apache.geode.cache.query.CqExistsException; +import org.apache.geode.cache.query.CqQuery; +import org.apache.geode.cache.query.CqServiceStatistics; +import org.apache.geode.cache.query.QueryInvalidException; +import org.apache.geode.cache.query.RegionNotFoundException; +import org.apache.geode.distributed.internal.DistributionAdvisor.Profile; +import org.apache.geode.internal.cache.EventID; +import org.apache.geode.internal.cache.FilterRoutingInfo; +import org.apache.geode.internal.cache.tier.sockets.CacheClientNotifier; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; public interface CqService { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/CqServiceProvider.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/CqServiceProvider.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/CqServiceProvider.java index d31ec8a..1f1c0e9 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/CqServiceProvider.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/CqServiceProvider.java @@ -14,11 +14,11 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal.cq; +package org.apache.geode.cache.query.internal.cq; -import com.gemstone.gemfire.cache.query.internal.cq.spi.CqServiceFactory; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; +import org.apache.geode.cache.query.internal.cq.spi.CqServiceFactory; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.internal.cache.GemFireCacheImpl; import java.io.DataInput; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/InternalCqQuery.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/InternalCqQuery.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/InternalCqQuery.java index eea22ab..310da6d 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/InternalCqQuery.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/InternalCqQuery.java @@ -14,15 +14,15 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal.cq; +package org.apache.geode.cache.query.internal.cq; -import com.gemstone.gemfire.cache.query.CqClosedException; -import com.gemstone.gemfire.cache.query.CqException; -import com.gemstone.gemfire.cache.query.CqQuery; -import com.gemstone.gemfire.cache.query.CqState; -import com.gemstone.gemfire.cache.query.internal.CqQueryVsdStats; -import com.gemstone.gemfire.cache.query.internal.CqStateImpl; -import com.gemstone.gemfire.internal.cache.LocalRegion; +import org.apache.geode.cache.query.CqClosedException; +import org.apache.geode.cache.query.CqException; +import org.apache.geode.cache.query.CqQuery; +import org.apache.geode.cache.query.CqState; +import org.apache.geode.cache.query.internal.CqQueryVsdStats; +import org.apache.geode.cache.query.internal.CqStateImpl; +import org.apache.geode.internal.cache.LocalRegion; public interface InternalCqQuery extends CqQuery { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/MissingCqService.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/MissingCqService.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/MissingCqService.java index 3299947..bade4af 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/MissingCqService.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/MissingCqService.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal.cq; +package org.apache.geode.cache.query.internal.cq; import java.util.Collection; import java.util.Collections; @@ -22,24 +22,24 @@ import java.util.HashMap; import java.util.List; import java.util.Map; -import com.gemstone.gemfire.cache.CacheEvent; -import com.gemstone.gemfire.cache.client.Pool; -import com.gemstone.gemfire.cache.client.internal.InternalPool; -import com.gemstone.gemfire.cache.client.internal.QueueManager; -import com.gemstone.gemfire.cache.client.internal.UserAttributes; -import com.gemstone.gemfire.cache.query.CqAttributes; -import com.gemstone.gemfire.cache.query.CqClosedException; -import com.gemstone.gemfire.cache.query.CqException; -import com.gemstone.gemfire.cache.query.CqExistsException; -import com.gemstone.gemfire.cache.query.CqQuery; -import com.gemstone.gemfire.cache.query.CqServiceStatistics; -import com.gemstone.gemfire.cache.query.QueryInvalidException; -import com.gemstone.gemfire.cache.query.RegionNotFoundException; -import com.gemstone.gemfire.distributed.internal.DistributionAdvisor.Profile; -import com.gemstone.gemfire.internal.cache.EventID; -import com.gemstone.gemfire.internal.cache.FilterRoutingInfo; -import com.gemstone.gemfire.internal.cache.tier.sockets.CacheClientNotifier; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.cache.CacheEvent; +import org.apache.geode.cache.client.Pool; +import org.apache.geode.cache.client.internal.InternalPool; +import org.apache.geode.cache.client.internal.QueueManager; +import org.apache.geode.cache.client.internal.UserAttributes; +import org.apache.geode.cache.query.CqAttributes; +import org.apache.geode.cache.query.CqClosedException; +import org.apache.geode.cache.query.CqException; +import org.apache.geode.cache.query.CqExistsException; +import org.apache.geode.cache.query.CqQuery; +import org.apache.geode.cache.query.CqServiceStatistics; +import org.apache.geode.cache.query.QueryInvalidException; +import org.apache.geode.cache.query.RegionNotFoundException; +import org.apache.geode.distributed.internal.DistributionAdvisor.Profile; +import org.apache.geode.internal.cache.EventID; +import org.apache.geode.internal.cache.FilterRoutingInfo; +import org.apache.geode.internal.cache.tier.sockets.CacheClientNotifier; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; public class MissingCqService implements CqService { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/MissingCqServiceStatistics.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/MissingCqServiceStatistics.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/MissingCqServiceStatistics.java index da69d3a..cf98d0b 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/MissingCqServiceStatistics.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/MissingCqServiceStatistics.java @@ -14,9 +14,9 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal.cq; +package org.apache.geode.cache.query.internal.cq; -import com.gemstone.gemfire.cache.query.CqServiceStatistics; +import org.apache.geode.cache.query.CqServiceStatistics; public class MissingCqServiceStatistics implements CqServiceStatistics { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/ServerCQ.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/ServerCQ.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/ServerCQ.java index e956bd5..ad8e8b1 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/ServerCQ.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/ServerCQ.java @@ -14,13 +14,13 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal.cq; +package org.apache.geode.cache.query.internal.cq; -import com.gemstone.gemfire.cache.query.CqClosedException; -import com.gemstone.gemfire.cache.query.CqException; -import com.gemstone.gemfire.cache.query.RegionNotFoundException; -import com.gemstone.gemfire.internal.cache.tier.sockets.CacheClientNotifier; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.cache.query.CqClosedException; +import org.apache.geode.cache.query.CqException; +import org.apache.geode.cache.query.RegionNotFoundException; +import org.apache.geode.internal.cache.tier.sockets.CacheClientNotifier; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; public interface ServerCQ extends InternalCqQuery { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/spi/CqServiceFactory.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/spi/CqServiceFactory.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/spi/CqServiceFactory.java index 4df0b77..16781c6 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/spi/CqServiceFactory.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/spi/CqServiceFactory.java @@ -14,14 +14,14 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal.cq.spi; +package org.apache.geode.cache.query.internal.cq.spi; import java.io.DataInput; import java.io.IOException; -import com.gemstone.gemfire.cache.query.internal.cq.CqService; -import com.gemstone.gemfire.cache.query.internal.cq.ServerCQ; -import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; +import org.apache.geode.cache.query.internal.cq.CqService; +import org.apache.geode.cache.query.internal.cq.ServerCQ; +import org.apache.geode.internal.cache.GemFireCacheImpl; public interface CqServiceFactory { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/AbstractIndex.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/AbstractIndex.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/AbstractIndex.java index 6c0d509..32a6d19 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/AbstractIndex.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/AbstractIndex.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal.index; +package org.apache.geode.cache.query.internal.index; import java.util.ArrayList; import java.util.Arrays; @@ -30,56 +30,56 @@ import java.util.concurrent.locks.ReentrantReadWriteLock; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.query.AmbiguousNameException; -import com.gemstone.gemfire.cache.query.FunctionDomainException; -import com.gemstone.gemfire.cache.query.Index; -import com.gemstone.gemfire.cache.query.IndexStatistics; -import com.gemstone.gemfire.cache.query.NameResolutionException; -import com.gemstone.gemfire.cache.query.QueryInvocationTargetException; -import com.gemstone.gemfire.cache.query.QueryService; -import com.gemstone.gemfire.cache.query.SelectResults; -import com.gemstone.gemfire.cache.query.Struct; -import com.gemstone.gemfire.cache.query.TypeMismatchException; -import com.gemstone.gemfire.cache.query.internal.Bag; -import com.gemstone.gemfire.cache.query.internal.CompiledID; -import com.gemstone.gemfire.cache.query.internal.CompiledIndexOperation; -import com.gemstone.gemfire.cache.query.internal.CompiledIteratorDef; -import com.gemstone.gemfire.cache.query.internal.CompiledOperation; -import com.gemstone.gemfire.cache.query.internal.CompiledPath; -import com.gemstone.gemfire.cache.query.internal.CompiledValue; -import com.gemstone.gemfire.cache.query.internal.CqEntry; -import com.gemstone.gemfire.cache.query.internal.DefaultQuery; -import com.gemstone.gemfire.cache.query.internal.ExecutionContext; -import com.gemstone.gemfire.cache.query.internal.IndexInfo; -import com.gemstone.gemfire.cache.query.internal.QRegion; -import com.gemstone.gemfire.cache.query.internal.QueryMonitor; -import com.gemstone.gemfire.cache.query.internal.QueryUtils; -import com.gemstone.gemfire.cache.query.internal.RuntimeIterator; -import com.gemstone.gemfire.cache.query.internal.StructFields; -import com.gemstone.gemfire.cache.query.internal.StructImpl; -import com.gemstone.gemfire.cache.query.internal.Support; -import com.gemstone.gemfire.cache.query.internal.index.IndexStore.IndexStoreEntry; -import com.gemstone.gemfire.cache.query.internal.parse.OQLLexerTokenTypes; -import com.gemstone.gemfire.cache.query.internal.types.StructTypeImpl; -import com.gemstone.gemfire.cache.query.internal.types.TypeUtils; -import com.gemstone.gemfire.cache.query.types.ObjectType; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.cache.BucketRegion; -import com.gemstone.gemfire.internal.cache.CachedDeserializable; -import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; -import com.gemstone.gemfire.internal.cache.LocalRegion; -import com.gemstone.gemfire.internal.cache.PartitionedRegion; -import com.gemstone.gemfire.internal.cache.RegionEntry; -import com.gemstone.gemfire.internal.cache.persistence.query.CloseableIterator; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.offheap.StoredObject; -import com.gemstone.gemfire.internal.offheap.annotations.Released; -import com.gemstone.gemfire.internal.offheap.annotations.Retained; -import com.gemstone.gemfire.pdx.PdxInstance; -import com.gemstone.gemfire.pdx.internal.PdxString; +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.query.AmbiguousNameException; +import org.apache.geode.cache.query.FunctionDomainException; +import org.apache.geode.cache.query.Index; +import org.apache.geode.cache.query.IndexStatistics; +import org.apache.geode.cache.query.NameResolutionException; +import org.apache.geode.cache.query.QueryInvocationTargetException; +import org.apache.geode.cache.query.QueryService; +import org.apache.geode.cache.query.SelectResults; +import org.apache.geode.cache.query.Struct; +import org.apache.geode.cache.query.TypeMismatchException; +import org.apache.geode.cache.query.internal.Bag; +import org.apache.geode.cache.query.internal.CompiledID; +import org.apache.geode.cache.query.internal.CompiledIndexOperation; +import org.apache.geode.cache.query.internal.CompiledIteratorDef; +import org.apache.geode.cache.query.internal.CompiledOperation; +import org.apache.geode.cache.query.internal.CompiledPath; +import org.apache.geode.cache.query.internal.CompiledValue; +import org.apache.geode.cache.query.internal.CqEntry; +import org.apache.geode.cache.query.internal.DefaultQuery; +import org.apache.geode.cache.query.internal.ExecutionContext; +import org.apache.geode.cache.query.internal.IndexInfo; +import org.apache.geode.cache.query.internal.QRegion; +import org.apache.geode.cache.query.internal.QueryMonitor; +import org.apache.geode.cache.query.internal.QueryUtils; +import org.apache.geode.cache.query.internal.RuntimeIterator; +import org.apache.geode.cache.query.internal.StructFields; +import org.apache.geode.cache.query.internal.StructImpl; +import org.apache.geode.cache.query.internal.Support; +import org.apache.geode.cache.query.internal.index.IndexStore.IndexStoreEntry; +import org.apache.geode.cache.query.internal.parse.OQLLexerTokenTypes; +import org.apache.geode.cache.query.internal.types.StructTypeImpl; +import org.apache.geode.cache.query.internal.types.TypeUtils; +import org.apache.geode.cache.query.types.ObjectType; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.cache.BucketRegion; +import org.apache.geode.internal.cache.CachedDeserializable; +import org.apache.geode.internal.cache.GemFireCacheImpl; +import org.apache.geode.internal.cache.LocalRegion; +import org.apache.geode.internal.cache.PartitionedRegion; +import org.apache.geode.internal.cache.RegionEntry; +import org.apache.geode.internal.cache.persistence.query.CloseableIterator; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.offheap.StoredObject; +import org.apache.geode.internal.offheap.annotations.Released; +import org.apache.geode.internal.offheap.annotations.Retained; +import org.apache.geode.pdx.PdxInstance; +import org.apache.geode.pdx.internal.PdxString; /** * This class implements abstract algorithms common to all indexes, such as http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/AbstractMapIndex.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/AbstractMapIndex.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/AbstractMapIndex.java index 355bb6d..bfd5551 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/AbstractMapIndex.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/AbstractMapIndex.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal.index; +package org.apache.geode.cache.query.internal.index; import java.util.Collection; import java.util.Collections; @@ -24,25 +24,25 @@ import java.util.Map; import java.util.Set; import java.util.concurrent.ConcurrentHashMap; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.RegionAttributes; -import com.gemstone.gemfire.cache.query.AmbiguousNameException; -import com.gemstone.gemfire.cache.query.FunctionDomainException; -import com.gemstone.gemfire.cache.query.IndexStatistics; -import com.gemstone.gemfire.cache.query.IndexType; -import com.gemstone.gemfire.cache.query.NameResolutionException; -import com.gemstone.gemfire.cache.query.QueryException; -import com.gemstone.gemfire.cache.query.QueryInvocationTargetException; -import com.gemstone.gemfire.cache.query.QueryService; -import com.gemstone.gemfire.cache.query.SelectResults; -import com.gemstone.gemfire.cache.query.TypeMismatchException; -import com.gemstone.gemfire.cache.query.internal.CompiledValue; -import com.gemstone.gemfire.cache.query.internal.ExecutionContext; -import com.gemstone.gemfire.cache.query.internal.MapIndexable; -import com.gemstone.gemfire.cache.query.internal.RuntimeIterator; -import com.gemstone.gemfire.cache.query.types.ObjectType; -import com.gemstone.gemfire.internal.cache.BucketRegion; -import com.gemstone.gemfire.internal.cache.RegionEntry; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.RegionAttributes; +import org.apache.geode.cache.query.AmbiguousNameException; +import org.apache.geode.cache.query.FunctionDomainException; +import org.apache.geode.cache.query.IndexStatistics; +import org.apache.geode.cache.query.IndexType; +import org.apache.geode.cache.query.NameResolutionException; +import org.apache.geode.cache.query.QueryException; +import org.apache.geode.cache.query.QueryInvocationTargetException; +import org.apache.geode.cache.query.QueryService; +import org.apache.geode.cache.query.SelectResults; +import org.apache.geode.cache.query.TypeMismatchException; +import org.apache.geode.cache.query.internal.CompiledValue; +import org.apache.geode.cache.query.internal.ExecutionContext; +import org.apache.geode.cache.query.internal.MapIndexable; +import org.apache.geode.cache.query.internal.RuntimeIterator; +import org.apache.geode.cache.query.types.ObjectType; +import org.apache.geode.internal.cache.BucketRegion; +import org.apache.geode.internal.cache.RegionEntry; public abstract class AbstractMapIndex extends AbstractIndex { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/CompactMapRangeIndex.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/CompactMapRangeIndex.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/CompactMapRangeIndex.java index a089853..ce1ea08 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/CompactMapRangeIndex.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/CompactMapRangeIndex.java @@ -14,18 +14,18 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal.index; +package org.apache.geode.cache.query.internal.index; import java.util.HashMap; import java.util.Iterator; import java.util.Map; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.RegionAttributes; -import com.gemstone.gemfire.cache.query.IndexStatistics; -import com.gemstone.gemfire.cache.query.QueryService; -import com.gemstone.gemfire.cache.query.internal.index.AbstractIndex.InternalIndexStatistics; -import com.gemstone.gemfire.internal.cache.BucketRegion; -import com.gemstone.gemfire.internal.cache.RegionEntry; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.RegionAttributes; +import org.apache.geode.cache.query.IndexStatistics; +import org.apache.geode.cache.query.QueryService; +import org.apache.geode.cache.query.internal.index.AbstractIndex.InternalIndexStatistics; +import org.apache.geode.internal.cache.BucketRegion; +import org.apache.geode.internal.cache.RegionEntry; public class CompactMapRangeIndex extends AbstractMapIndex { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/CompactRangeIndex.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/CompactRangeIndex.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/CompactRangeIndex.java index ecfafb1..d5dd5a6 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/CompactRangeIndex.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/CompactRangeIndex.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal.index; +package org.apache.geode.cache.query.internal.index; import java.util.ArrayList; import java.util.Collection; import java.util.HashSet; @@ -25,51 +25,51 @@ import java.util.Map; import java.util.NoSuchElementException; import java.util.Set; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.cache.CacheException; -import com.gemstone.gemfire.cache.EntryDestroyedException; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.query.AmbiguousNameException; -import com.gemstone.gemfire.cache.query.FunctionDomainException; -import com.gemstone.gemfire.cache.query.IndexStatistics; -import com.gemstone.gemfire.cache.query.IndexType; -import com.gemstone.gemfire.cache.query.NameResolutionException; -import com.gemstone.gemfire.cache.query.QueryInvocationTargetException; -import com.gemstone.gemfire.cache.query.QueryService; -import com.gemstone.gemfire.cache.query.SelectResults; -import com.gemstone.gemfire.cache.query.TypeMismatchException; -import com.gemstone.gemfire.cache.query.internal.CompiledBindArgument; -import com.gemstone.gemfire.cache.query.internal.CompiledIteratorDef; -import com.gemstone.gemfire.cache.query.internal.CompiledLiteral; -import com.gemstone.gemfire.cache.query.internal.CompiledPath; -import com.gemstone.gemfire.cache.query.internal.CompiledSortCriterion; -import com.gemstone.gemfire.cache.query.internal.CompiledValue; -import com.gemstone.gemfire.cache.query.internal.CqEntry; -import com.gemstone.gemfire.cache.query.internal.ExecutionContext; -import com.gemstone.gemfire.cache.query.internal.IndexInfo; -import com.gemstone.gemfire.cache.query.internal.QRegion; -import com.gemstone.gemfire.cache.query.internal.QueryMonitor; -import com.gemstone.gemfire.cache.query.internal.QueryObserver; -import com.gemstone.gemfire.cache.query.internal.QueryObserverHolder; -import com.gemstone.gemfire.cache.query.internal.QueryUtils; -import com.gemstone.gemfire.cache.query.internal.RuntimeIterator; -import com.gemstone.gemfire.cache.query.internal.StructImpl; -import com.gemstone.gemfire.cache.query.internal.Support; -import com.gemstone.gemfire.cache.query.internal.index.IndexManager.TestHook; -import com.gemstone.gemfire.cache.query.internal.index.IndexStore.IndexStoreEntry; -import com.gemstone.gemfire.cache.query.internal.index.MemoryIndexStore.MemoryIndexStoreEntry; -import com.gemstone.gemfire.cache.query.internal.parse.OQLLexerTokenTypes; -import com.gemstone.gemfire.cache.query.internal.types.StructTypeImpl; -import com.gemstone.gemfire.cache.query.internal.types.TypeUtils; -import com.gemstone.gemfire.cache.query.types.ObjectType; -import com.gemstone.gemfire.cache.query.types.StructType; -import com.gemstone.gemfire.internal.cache.LocalRegion; -import com.gemstone.gemfire.internal.cache.RegionEntry; -import com.gemstone.gemfire.internal.cache.RegionEntryContext; -import com.gemstone.gemfire.internal.cache.VMThinRegionEntryHeap; -import com.gemstone.gemfire.internal.cache.persistence.query.CloseableIterator; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.pdx.internal.PdxString; +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.CacheException; +import org.apache.geode.cache.EntryDestroyedException; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.query.AmbiguousNameException; +import org.apache.geode.cache.query.FunctionDomainException; +import org.apache.geode.cache.query.IndexStatistics; +import org.apache.geode.cache.query.IndexType; +import org.apache.geode.cache.query.NameResolutionException; +import org.apache.geode.cache.query.QueryInvocationTargetException; +import org.apache.geode.cache.query.QueryService; +import org.apache.geode.cache.query.SelectResults; +import org.apache.geode.cache.query.TypeMismatchException; +import org.apache.geode.cache.query.internal.CompiledBindArgument; +import org.apache.geode.cache.query.internal.CompiledIteratorDef; +import org.apache.geode.cache.query.internal.CompiledLiteral; +import org.apache.geode.cache.query.internal.CompiledPath; +import org.apache.geode.cache.query.internal.CompiledSortCriterion; +import org.apache.geode.cache.query.internal.CompiledValue; +import org.apache.geode.cache.query.internal.CqEntry; +import org.apache.geode.cache.query.internal.ExecutionContext; +import org.apache.geode.cache.query.internal.IndexInfo; +import org.apache.geode.cache.query.internal.QRegion; +import org.apache.geode.cache.query.internal.QueryMonitor; +import org.apache.geode.cache.query.internal.QueryObserver; +import org.apache.geode.cache.query.internal.QueryObserverHolder; +import org.apache.geode.cache.query.internal.QueryUtils; +import org.apache.geode.cache.query.internal.RuntimeIterator; +import org.apache.geode.cache.query.internal.StructImpl; +import org.apache.geode.cache.query.internal.Support; +import org.apache.geode.cache.query.internal.index.IndexManager.TestHook; +import org.apache.geode.cache.query.internal.index.IndexStore.IndexStoreEntry; +import org.apache.geode.cache.query.internal.index.MemoryIndexStore.MemoryIndexStoreEntry; +import org.apache.geode.cache.query.internal.parse.OQLLexerTokenTypes; +import org.apache.geode.cache.query.internal.types.StructTypeImpl; +import org.apache.geode.cache.query.internal.types.TypeUtils; +import org.apache.geode.cache.query.types.ObjectType; +import org.apache.geode.cache.query.types.StructType; +import org.apache.geode.internal.cache.LocalRegion; +import org.apache.geode.internal.cache.RegionEntry; +import org.apache.geode.internal.cache.RegionEntryContext; +import org.apache.geode.internal.cache.VMThinRegionEntryHeap; +import org.apache.geode.internal.cache.persistence.query.CloseableIterator; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.pdx.internal.PdxString; //@todo Extend to support the keys or entries of a region. /** http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/DummyQRegion.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/DummyQRegion.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/DummyQRegion.java index aae26fd..79cf0cb 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/DummyQRegion.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/DummyQRegion.java @@ -20,7 +20,7 @@ * Created on March 15, 2005, 6:40 PM */ -package com.gemstone.gemfire.cache.query.internal.index; +package org.apache.geode.cache.query.internal.index; import java.util.ArrayList; import java.util.Collection; @@ -28,22 +28,22 @@ import java.util.Iterator; import java.util.List; import java.util.Set; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.query.SelectResults; -import com.gemstone.gemfire.cache.query.internal.QRegion; -import com.gemstone.gemfire.cache.query.internal.ResultsBag; -import com.gemstone.gemfire.cache.query.internal.ResultsSet; -import com.gemstone.gemfire.cache.query.internal.types.TypeUtils; -import com.gemstone.gemfire.cache.query.types.ObjectType; -import com.gemstone.gemfire.internal.cache.CachedDeserializable; -import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; -import com.gemstone.gemfire.internal.cache.LocalRegion; -import com.gemstone.gemfire.internal.cache.RegionEntry; -import com.gemstone.gemfire.internal.cache.RegionEntryContext; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.offheap.StoredObject; -import com.gemstone.gemfire.internal.offheap.annotations.Released; -import com.gemstone.gemfire.internal.offheap.annotations.Retained; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.query.SelectResults; +import org.apache.geode.cache.query.internal.QRegion; +import org.apache.geode.cache.query.internal.ResultsBag; +import org.apache.geode.cache.query.internal.ResultsSet; +import org.apache.geode.cache.query.internal.types.TypeUtils; +import org.apache.geode.cache.query.types.ObjectType; +import org.apache.geode.internal.cache.CachedDeserializable; +import org.apache.geode.internal.cache.GemFireCacheImpl; +import org.apache.geode.internal.cache.LocalRegion; +import org.apache.geode.internal.cache.RegionEntry; +import org.apache.geode.internal.cache.RegionEntryContext; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.offheap.StoredObject; +import org.apache.geode.internal.offheap.annotations.Released; +import org.apache.geode.internal.offheap.annotations.Retained; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/FunctionalIndexCreationHelper.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/FunctionalIndexCreationHelper.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/FunctionalIndexCreationHelper.java index 60f1954..9cb43c9 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/FunctionalIndexCreationHelper.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/FunctionalIndexCreationHelper.java @@ -19,7 +19,7 @@ * * Created on March 16, 2005, 6:20 PM */ -package com.gemstone.gemfire.cache.query.internal.index; +package org.apache.geode.cache.query.internal.index; import java.util.ArrayList; import java.util.Collection; @@ -27,34 +27,34 @@ import java.util.Collections; import java.util.List; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.query.AmbiguousNameException; -import com.gemstone.gemfire.cache.query.IndexInvalidException; -import com.gemstone.gemfire.cache.query.IndexType; -import com.gemstone.gemfire.cache.query.NameResolutionException; -import com.gemstone.gemfire.cache.query.TypeMismatchException; -import com.gemstone.gemfire.cache.query.internal.CompiledBindArgument; -import com.gemstone.gemfire.cache.query.internal.CompiledComparison; -import com.gemstone.gemfire.cache.query.internal.CompiledFunction; -import com.gemstone.gemfire.cache.query.internal.CompiledID; -import com.gemstone.gemfire.cache.query.internal.CompiledIndexOperation; -import com.gemstone.gemfire.cache.query.internal.CompiledIteratorDef; -import com.gemstone.gemfire.cache.query.internal.CompiledLiteral; -import com.gemstone.gemfire.cache.query.internal.CompiledNegation; -import com.gemstone.gemfire.cache.query.internal.CompiledOperation; -import com.gemstone.gemfire.cache.query.internal.CompiledPath; -import com.gemstone.gemfire.cache.query.internal.CompiledRegion; -import com.gemstone.gemfire.cache.query.internal.CompiledUndefined; -import com.gemstone.gemfire.cache.query.internal.CompiledValue; -import com.gemstone.gemfire.cache.query.internal.ExecutionContext; -import com.gemstone.gemfire.cache.query.internal.MapIndexable; -import com.gemstone.gemfire.cache.query.internal.QRegion; -import com.gemstone.gemfire.cache.query.internal.RuntimeIterator; -import com.gemstone.gemfire.cache.query.internal.parse.OQLLexerTokenTypes; -import com.gemstone.gemfire.cache.query.types.ObjectType; -import com.gemstone.gemfire.internal.cache.PartitionedRegion; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.query.AmbiguousNameException; +import org.apache.geode.cache.query.IndexInvalidException; +import org.apache.geode.cache.query.IndexType; +import org.apache.geode.cache.query.NameResolutionException; +import org.apache.geode.cache.query.TypeMismatchException; +import org.apache.geode.cache.query.internal.CompiledBindArgument; +import org.apache.geode.cache.query.internal.CompiledComparison; +import org.apache.geode.cache.query.internal.CompiledFunction; +import org.apache.geode.cache.query.internal.CompiledID; +import org.apache.geode.cache.query.internal.CompiledIndexOperation; +import org.apache.geode.cache.query.internal.CompiledIteratorDef; +import org.apache.geode.cache.query.internal.CompiledLiteral; +import org.apache.geode.cache.query.internal.CompiledNegation; +import org.apache.geode.cache.query.internal.CompiledOperation; +import org.apache.geode.cache.query.internal.CompiledPath; +import org.apache.geode.cache.query.internal.CompiledRegion; +import org.apache.geode.cache.query.internal.CompiledUndefined; +import org.apache.geode.cache.query.internal.CompiledValue; +import org.apache.geode.cache.query.internal.ExecutionContext; +import org.apache.geode.cache.query.internal.MapIndexable; +import org.apache.geode.cache.query.internal.QRegion; +import org.apache.geode.cache.query.internal.RuntimeIterator; +import org.apache.geode.cache.query.internal.parse.OQLLexerTokenTypes; +import org.apache.geode.cache.query.types.ObjectType; +import org.apache.geode.internal.cache.PartitionedRegion; +import org.apache.geode.internal.i18n.LocalizedStrings; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/HashIndex.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/HashIndex.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/HashIndex.java index d28b166..775daec 100755 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/HashIndex.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/HashIndex.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal.index; +package org.apache.geode.cache.query.internal.index; import it.unimi.dsi.fastutil.objects.Object2ObjectOpenHashMap; @@ -33,56 +33,56 @@ import java.util.concurrent.ConcurrentMap; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.cache.EntryDestroyedException; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.RegionAttributes; -import com.gemstone.gemfire.cache.query.AmbiguousNameException; -import com.gemstone.gemfire.cache.query.FunctionDomainException; -import com.gemstone.gemfire.cache.query.IndexStatistics; -import com.gemstone.gemfire.cache.query.IndexType; -import com.gemstone.gemfire.cache.query.NameResolutionException; -import com.gemstone.gemfire.cache.query.QueryException; -import com.gemstone.gemfire.cache.query.QueryInvocationTargetException; -import com.gemstone.gemfire.cache.query.QueryService; -import com.gemstone.gemfire.cache.query.SelectResults; -import com.gemstone.gemfire.cache.query.TypeMismatchException; -import com.gemstone.gemfire.cache.query.internal.AttributeDescriptor; -import com.gemstone.gemfire.cache.query.internal.CompiledComparison; -import com.gemstone.gemfire.cache.query.internal.CompiledIteratorDef; -import com.gemstone.gemfire.cache.query.internal.CompiledPath; -import com.gemstone.gemfire.cache.query.internal.CompiledSortCriterion; -import com.gemstone.gemfire.cache.query.internal.CompiledValue; -import com.gemstone.gemfire.cache.query.internal.CqEntry; -import com.gemstone.gemfire.cache.query.internal.DefaultQuery; -import com.gemstone.gemfire.cache.query.internal.ExecutionContext; -import com.gemstone.gemfire.cache.query.internal.IndexInfo; -import com.gemstone.gemfire.cache.query.internal.QRegion; -import com.gemstone.gemfire.cache.query.internal.QueryMonitor; -import com.gemstone.gemfire.cache.query.internal.QueryObserver; -import com.gemstone.gemfire.cache.query.internal.QueryObserverHolder; -import com.gemstone.gemfire.cache.query.internal.QueryUtils; -import com.gemstone.gemfire.cache.query.internal.RuntimeIterator; -import com.gemstone.gemfire.cache.query.internal.Support; -import com.gemstone.gemfire.cache.query.internal.index.HashIndex.IMQEvaluator.HashIndexComparator; -import com.gemstone.gemfire.cache.query.internal.index.IndexStore.IndexStoreEntry; -import com.gemstone.gemfire.cache.query.internal.parse.OQLLexerTokenTypes; -import com.gemstone.gemfire.cache.query.internal.types.StructTypeImpl; -import com.gemstone.gemfire.cache.query.internal.types.TypeUtils; -import com.gemstone.gemfire.cache.query.types.ObjectType; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.cache.CachedDeserializable; -import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; -import com.gemstone.gemfire.internal.cache.LocalRegion; -import com.gemstone.gemfire.internal.cache.RegionEntry; -import com.gemstone.gemfire.internal.cache.Token; -import com.gemstone.gemfire.internal.cache.persistence.query.CloseableIterator; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.offheap.StoredObject; -import com.gemstone.gemfire.internal.offheap.annotations.Released; -import com.gemstone.gemfire.internal.offheap.annotations.Retained; -import com.gemstone.gemfire.pdx.internal.PdxString; +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.EntryDestroyedException; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.RegionAttributes; +import org.apache.geode.cache.query.AmbiguousNameException; +import org.apache.geode.cache.query.FunctionDomainException; +import org.apache.geode.cache.query.IndexStatistics; +import org.apache.geode.cache.query.IndexType; +import org.apache.geode.cache.query.NameResolutionException; +import org.apache.geode.cache.query.QueryException; +import org.apache.geode.cache.query.QueryInvocationTargetException; +import org.apache.geode.cache.query.QueryService; +import org.apache.geode.cache.query.SelectResults; +import org.apache.geode.cache.query.TypeMismatchException; +import org.apache.geode.cache.query.internal.AttributeDescriptor; +import org.apache.geode.cache.query.internal.CompiledComparison; +import org.apache.geode.cache.query.internal.CompiledIteratorDef; +import org.apache.geode.cache.query.internal.CompiledPath; +import org.apache.geode.cache.query.internal.CompiledSortCriterion; +import org.apache.geode.cache.query.internal.CompiledValue; +import org.apache.geode.cache.query.internal.CqEntry; +import org.apache.geode.cache.query.internal.DefaultQuery; +import org.apache.geode.cache.query.internal.ExecutionContext; +import org.apache.geode.cache.query.internal.IndexInfo; +import org.apache.geode.cache.query.internal.QRegion; +import org.apache.geode.cache.query.internal.QueryMonitor; +import org.apache.geode.cache.query.internal.QueryObserver; +import org.apache.geode.cache.query.internal.QueryObserverHolder; +import org.apache.geode.cache.query.internal.QueryUtils; +import org.apache.geode.cache.query.internal.RuntimeIterator; +import org.apache.geode.cache.query.internal.Support; +import org.apache.geode.cache.query.internal.index.HashIndex.IMQEvaluator.HashIndexComparator; +import org.apache.geode.cache.query.internal.index.IndexStore.IndexStoreEntry; +import org.apache.geode.cache.query.internal.parse.OQLLexerTokenTypes; +import org.apache.geode.cache.query.internal.types.StructTypeImpl; +import org.apache.geode.cache.query.internal.types.TypeUtils; +import org.apache.geode.cache.query.types.ObjectType; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.cache.CachedDeserializable; +import org.apache.geode.internal.cache.GemFireCacheImpl; +import org.apache.geode.internal.cache.LocalRegion; +import org.apache.geode.internal.cache.RegionEntry; +import org.apache.geode.internal.cache.Token; +import org.apache.geode.internal.cache.persistence.query.CloseableIterator; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.offheap.StoredObject; +import org.apache.geode.internal.offheap.annotations.Released; +import org.apache.geode.internal.offheap.annotations.Retained; +import org.apache.geode.pdx.internal.PdxString; /** * A HashIndex is an index that can be used for equal and not equals queries It http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/HashIndexSet.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/HashIndexSet.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/HashIndexSet.java index 55cbac1..a5e9873 100755 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/HashIndexSet.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/HashIndexSet.java @@ -20,7 +20,7 @@ * They are based from add(), contains() and other methods from ObjectOpenHashSet * We have used the traversing mechanism and the HashCommon.mix() */ -package com.gemstone.gemfire.cache.query.internal.index; +package org.apache.geode.cache.query.internal.index; import static it.unimi.dsi.fastutil.HashCommon.arraySize; import it.unimi.dsi.fastutil.HashCommon; @@ -31,11 +31,11 @@ import java.util.Iterator; import java.util.NoSuchElementException; import java.util.Set; -import com.gemstone.gemfire.cache.query.TypeMismatchException; -import com.gemstone.gemfire.cache.query.internal.parse.OQLLexerTokenTypes; -import com.gemstone.gemfire.cache.query.internal.types.TypeUtils; -import com.gemstone.gemfire.internal.cache.CachePerfStats; -import com.gemstone.gemfire.pdx.internal.PdxString; +import org.apache.geode.cache.query.TypeMismatchException; +import org.apache.geode.cache.query.internal.parse.OQLLexerTokenTypes; +import org.apache.geode.cache.query.internal.types.TypeUtils; +import org.apache.geode.internal.cache.CachePerfStats; +import org.apache.geode.pdx.internal.PdxString; /** * An implementation of the <tt>Set</tt> interface for the HashIndex http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IMQException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IMQException.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IMQException.java index e716668..e82d7eb 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IMQException.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IMQException.java @@ -20,9 +20,9 @@ * Created on March 8, 2005, 6:11 PM */ -package com.gemstone.gemfire.cache.query.internal.index; +package org.apache.geode.cache.query.internal.index; -import com.gemstone.gemfire.cache.query.QueryException; +import org.apache.geode.cache.query.QueryException; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexConcurrentHashSet.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexConcurrentHashSet.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexConcurrentHashSet.java index 95a2613..8b209c2 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexConcurrentHashSet.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexConcurrentHashSet.java @@ -17,11 +17,11 @@ /** * */ -package com.gemstone.gemfire.cache.query.internal.index; +package org.apache.geode.cache.query.internal.index; import java.util.Collection; -import com.gemstone.gemfire.internal.concurrent.CompactConcurrentHashSet2; +import org.apache.geode.internal.concurrent.CompactConcurrentHashSet2; /** * This class overrides the size method to make it non-blocking for our query http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexCreationData.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexCreationData.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexCreationData.java index 87d945a..a6e2f17 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexCreationData.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexCreationData.java @@ -19,16 +19,16 @@ * * */ -package com.gemstone.gemfire.cache.query.internal.index; +package org.apache.geode.cache.query.internal.index; import java.io.DataInput; import java.io.DataOutput; import java.io.IOException; import java.util.List; -import com.gemstone.gemfire.cache.query.IndexType; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -import com.gemstone.gemfire.internal.Version; +import org.apache.geode.cache.query.IndexType; +import org.apache.geode.internal.DataSerializableFixedID; +import org.apache.geode.internal.Version; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexCreationHelper.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexCreationHelper.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexCreationHelper.java index 0ca43b5..c9e2951 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexCreationHelper.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexCreationHelper.java @@ -19,15 +19,15 @@ * * Created on March 20, 2005, 8:26 PM */ -package com.gemstone.gemfire.cache.query.internal.index; +package org.apache.geode.cache.query.internal.index; import java.util.List; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.query.*; -import com.gemstone.gemfire.cache.query.internal.CompiledValue; -import com.gemstone.gemfire.cache.query.internal.QCompiler; +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.query.*; +import org.apache.geode.cache.query.internal.CompiledValue; +import org.apache.geode.cache.query.internal.QCompiler; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexData.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexData.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexData.java index 85b39ab..c2bef60 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexData.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexData.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal.index; +package org.apache.geode.cache.query.internal.index; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexElemArray.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexElemArray.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexElemArray.java index 3cf4cbf..5b31312 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexElemArray.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexElemArray.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal.index; +package org.apache.geode.cache.query.internal.index; import java.util.Arrays; import java.util.Collection; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexManager.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexManager.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexManager.java index 8ef82f1..4dcd1c3 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexManager.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexManager.java @@ -19,20 +19,20 @@ * * Created on February 15, 2005, 11:49 AM */ -package com.gemstone.gemfire.cache.query.internal.index; - -import com.gemstone.gemfire.SystemFailure; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.query.*; -import com.gemstone.gemfire.cache.query.internal.*; -import com.gemstone.gemfire.cache.query.internal.index.AbstractIndex.InternalIndexStatistics; -import com.gemstone.gemfire.cache.query.internal.parse.OQLLexerTokenTypes; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.cache.*; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.LoggingThreadGroup; +package org.apache.geode.cache.query.internal.index; + +import org.apache.geode.SystemFailure; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.query.*; +import org.apache.geode.cache.query.internal.*; +import org.apache.geode.cache.query.internal.index.AbstractIndex.InternalIndexStatistics; +import org.apache.geode.cache.query.internal.parse.OQLLexerTokenTypes; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.cache.*; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.LoggingThreadGroup; import org.apache.logging.log4j.Logger; import java.util.*; @@ -948,7 +948,7 @@ public class IndexManager { * @param action action to be taken (IndexManager.ADD_ENTRY, * IndexManager.UPDATE_ENTRY, IndexManager.REMOVE_ENTRY) * @param opCode one of IndexProtocol.OTHER_OP, BEFORE_UPDATE_OP, AFTER_UPDATE_OP. - * @throws com.gemstone.gemfire.cache.query.IndexMaintenanceException + * @throws org.apache.geode.cache.query.IndexMaintenanceException */ public void updateIndexes(RegionEntry entry, int action, int opCode, boolean isDiskRecoveryInProgress) throws QueryException { @@ -1415,7 +1415,7 @@ public class IndexManager { public void run() { // async writers main loop // logger.debug("DiskRegion writer started (writer=" + this + ")"); - com.gemstone.gemfire.CancelCriterion stopper = ((LocalRegion)region).getCancelCriterion(); + org.apache.geode.CancelCriterion stopper = ((LocalRegion)region).getCancelCriterion(); try { while (!this.shutdownRequested) { // Termination checks http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexProtocol.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexProtocol.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexProtocol.java index bcbdaac..bb96cfe 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexProtocol.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexProtocol.java @@ -14,23 +14,23 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal.index; +package org.apache.geode.cache.query.internal.index; -//import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.query.FunctionDomainException; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.cache.query.AmbiguousNameException; -import com.gemstone.gemfire.cache.query.Index; -import com.gemstone.gemfire.cache.query.NameResolutionException; -import com.gemstone.gemfire.cache.query.QueryException; -import com.gemstone.gemfire.cache.query.QueryInvocationTargetException; -import com.gemstone.gemfire.cache.query.SelectResults; -import com.gemstone.gemfire.cache.query.TypeMismatchException; -import com.gemstone.gemfire.cache.query.internal.CompiledValue; -import com.gemstone.gemfire.cache.query.internal.ExecutionContext; -import com.gemstone.gemfire.cache.query.internal.RuntimeIterator; -import com.gemstone.gemfire.cache.query.types.ObjectType; -import com.gemstone.gemfire.internal.cache.RegionEntry; +//import org.apache.geode.cache.Region; +import org.apache.geode.cache.query.FunctionDomainException; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.cache.query.AmbiguousNameException; +import org.apache.geode.cache.query.Index; +import org.apache.geode.cache.query.NameResolutionException; +import org.apache.geode.cache.query.QueryException; +import org.apache.geode.cache.query.QueryInvocationTargetException; +import org.apache.geode.cache.query.SelectResults; +import org.apache.geode.cache.query.TypeMismatchException; +import org.apache.geode.cache.query.internal.CompiledValue; +import org.apache.geode.cache.query.internal.ExecutionContext; +import org.apache.geode.cache.query.internal.RuntimeIterator; +import org.apache.geode.cache.query.types.ObjectType; +import org.apache.geode.internal.cache.RegionEntry; import java.util.*; public interface IndexProtocol extends Index { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexStats.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexStats.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexStats.java index 84d9b61..3351e3c 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexStats.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexStats.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal.index; +package org.apache.geode.cache.query.internal.index; -import com.gemstone.gemfire.*; -//import com.gemstone.gemfire.cache.query.*; -import com.gemstone.gemfire.internal.statistics.StatisticsTypeFactoryImpl; -import com.gemstone.gemfire.internal.cache.CachePerfStats; +import org.apache.geode.*; +//import org.apache.geode.cache.query.*; +import org.apache.geode.internal.statistics.StatisticsTypeFactoryImpl; +import org.apache.geode.internal.cache.CachePerfStats; /** * IndexStats tracks statistics about query index use. @@ -193,7 +193,7 @@ public class IndexStats { /** * Closes these stats so that they can not longer be used. The * stats are closed when the {@linkplain - * com.gemstone.gemfire.internal.cache.GemFireCacheImpl#close cache} + * org.apache.geode.internal.cache.GemFireCacheImpl#close cache} * is closed. * * @since GemFire 3.5 http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexStore.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexStore.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexStore.java index 795939a..c26ec48 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexStore.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexStore.java @@ -14,12 +14,12 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal.index; +package org.apache.geode.cache.query.internal.index; import java.util.Collection; -import com.gemstone.gemfire.internal.cache.RegionEntry; -import com.gemstone.gemfire.internal.cache.persistence.query.CloseableIterator; +import org.apache.geode.internal.cache.RegionEntry; +import org.apache.geode.internal.cache.persistence.query.CloseableIterator; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexUtils.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexUtils.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexUtils.java index ee1fb6b..c56488a 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexUtils.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexUtils.java @@ -19,19 +19,19 @@ * * Created on March 4, 2005, 5:39 PM */ -package com.gemstone.gemfire.cache.query.internal.index; +package org.apache.geode.cache.query.internal.index; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.query.AmbiguousNameException; -import com.gemstone.gemfire.cache.query.IndexType; -import com.gemstone.gemfire.cache.query.NameResolutionException; -import com.gemstone.gemfire.cache.query.TypeMismatchException; -import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; -import com.gemstone.gemfire.internal.cache.LocalRegion; -import com.gemstone.gemfire.internal.cache.PartitionedRegion; -import com.gemstone.gemfire.cache.query.internal.*; -import com.gemstone.gemfire.cache.query.internal.index.IndexManager.TestHook; +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.query.AmbiguousNameException; +import org.apache.geode.cache.query.IndexType; +import org.apache.geode.cache.query.NameResolutionException; +import org.apache.geode.cache.query.TypeMismatchException; +import org.apache.geode.internal.cache.GemFireCacheImpl; +import org.apache.geode.internal.cache.LocalRegion; +import org.apache.geode.internal.cache.PartitionedRegion; +import org.apache.geode.cache.query.internal.*; +import org.apache.geode.cache.query.internal.index.IndexManager.TestHook; /** */ http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexedExpressionEvaluator.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexedExpressionEvaluator.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexedExpressionEvaluator.java index a8e9ee4..8e70979 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexedExpressionEvaluator.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/IndexedExpressionEvaluator.java @@ -19,13 +19,13 @@ * * Created on February 11, 2005, 4:25 PM */ -package com.gemstone.gemfire.cache.query.internal.index; +package org.apache.geode.cache.query.internal.index; import java.util.List; -import com.gemstone.gemfire.cache.query.internal.ExecutionContext; -import com.gemstone.gemfire.cache.query.types.ObjectType; -import com.gemstone.gemfire.internal.cache.RegionEntry; +import org.apache.geode.cache.query.internal.ExecutionContext; +import org.apache.geode.cache.query.types.ObjectType; +import org.apache.geode.internal.cache.RegionEntry; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/MapIndexStore.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/MapIndexStore.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/MapIndexStore.java index 92b0632..fb27c0e 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/MapIndexStore.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/MapIndexStore.java @@ -14,24 +14,24 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal.index; +package org.apache.geode.cache.query.internal.index; import java.util.Collection; import java.util.Iterator; -import com.gemstone.gemfire.cache.EntryDestroyedException; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.query.TypeMismatchException; -import com.gemstone.gemfire.cache.query.internal.parse.OQLLexerTokenTypes; -import com.gemstone.gemfire.cache.query.internal.types.TypeUtils; -import com.gemstone.gemfire.internal.cache.CachedDeserializable; -import com.gemstone.gemfire.internal.cache.LocalRegion; -import com.gemstone.gemfire.internal.cache.RegionEntry; -import com.gemstone.gemfire.internal.cache.RegionEntryContext; -import com.gemstone.gemfire.internal.cache.Token; -import com.gemstone.gemfire.internal.cache.LocalRegion.NonTXEntry; -import com.gemstone.gemfire.internal.cache.persistence.query.CloseableIterator; -import com.gemstone.gemfire.internal.cache.persistence.query.IndexMap; +import org.apache.geode.cache.EntryDestroyedException; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.query.TypeMismatchException; +import org.apache.geode.cache.query.internal.parse.OQLLexerTokenTypes; +import org.apache.geode.cache.query.internal.types.TypeUtils; +import org.apache.geode.internal.cache.CachedDeserializable; +import org.apache.geode.internal.cache.LocalRegion; +import org.apache.geode.internal.cache.RegionEntry; +import org.apache.geode.internal.cache.RegionEntryContext; +import org.apache.geode.internal.cache.Token; +import org.apache.geode.internal.cache.LocalRegion.NonTXEntry; +import org.apache.geode.internal.cache.persistence.query.CloseableIterator; +import org.apache.geode.internal.cache.persistence.query.IndexMap; /** * Implementation of IndexStorage that is backed by an IndexMap http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/MapRangeIndex.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/MapRangeIndex.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/MapRangeIndex.java index 13620f5..57a4d39 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/MapRangeIndex.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/MapRangeIndex.java @@ -14,15 +14,15 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal.index; +package org.apache.geode.cache.query.internal.index; import java.util.Collection; import java.util.Iterator; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.RegionAttributes; -import com.gemstone.gemfire.cache.query.IndexStatistics; -import com.gemstone.gemfire.internal.cache.BucketRegion; -import com.gemstone.gemfire.internal.cache.RegionEntry; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.RegionAttributes; +import org.apache.geode.cache.query.IndexStatistics; +import org.apache.geode.internal.cache.BucketRegion; +import org.apache.geode.internal.cache.RegionEntry; public class MapRangeIndex extends AbstractMapIndex { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/MemoryIndexStore.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/MemoryIndexStore.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/MemoryIndexStore.java index 59e7d21..2a58e2c 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/MemoryIndexStore.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/MemoryIndexStore.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal.index; +package org.apache.geode.cache.query.internal.index; import java.util.AbstractMap.SimpleImmutableEntry; import java.util.Collection; @@ -28,24 +28,24 @@ import java.util.concurrent.ConcurrentNavigableMap; import java.util.concurrent.ConcurrentSkipListMap; import java.util.concurrent.atomic.AtomicInteger; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.cache.EntryDestroyedException; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.RegionAttributes; -import com.gemstone.gemfire.cache.query.IndexMaintenanceException; -import com.gemstone.gemfire.cache.query.QueryService; -import com.gemstone.gemfire.cache.query.TypeMismatchException; -import com.gemstone.gemfire.cache.query.internal.CompiledComparison; -import com.gemstone.gemfire.cache.query.internal.DefaultQuery; -import com.gemstone.gemfire.cache.query.internal.index.AbstractIndex.InternalIndexStatistics; -import com.gemstone.gemfire.cache.query.internal.parse.OQLLexerTokenTypes; -import com.gemstone.gemfire.cache.query.internal.types.TypeUtils; -import com.gemstone.gemfire.internal.cache.CachedDeserializable; -import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; -import com.gemstone.gemfire.internal.cache.LocalRegion; -import com.gemstone.gemfire.internal.cache.RegionEntry; -import com.gemstone.gemfire.internal.cache.Token; -import com.gemstone.gemfire.internal.cache.persistence.query.CloseableIterator; +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.EntryDestroyedException; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.RegionAttributes; +import org.apache.geode.cache.query.IndexMaintenanceException; +import org.apache.geode.cache.query.QueryService; +import org.apache.geode.cache.query.TypeMismatchException; +import org.apache.geode.cache.query.internal.CompiledComparison; +import org.apache.geode.cache.query.internal.DefaultQuery; +import org.apache.geode.cache.query.internal.index.AbstractIndex.InternalIndexStatistics; +import org.apache.geode.cache.query.internal.parse.OQLLexerTokenTypes; +import org.apache.geode.cache.query.internal.types.TypeUtils; +import org.apache.geode.internal.cache.CachedDeserializable; +import org.apache.geode.internal.cache.GemFireCacheImpl; +import org.apache.geode.internal.cache.LocalRegion; +import org.apache.geode.internal.cache.RegionEntry; +import org.apache.geode.internal.cache.Token; +import org.apache.geode.internal.cache.persistence.query.CloseableIterator; /** * The in-memory index storage http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/PartitionedIndex.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/PartitionedIndex.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/PartitionedIndex.java index da25ee3..e2de661 100755 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/PartitionedIndex.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/PartitionedIndex.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal.index; +package org.apache.geode.cache.query.internal.index; import java.util.ArrayList; import java.util.Collection; @@ -25,26 +25,26 @@ import java.util.List; import java.util.Map; import java.util.Set; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.query.Index; -import com.gemstone.gemfire.cache.query.IndexExistsException; -import com.gemstone.gemfire.cache.query.IndexNameConflictException; -import com.gemstone.gemfire.cache.query.IndexStatistics; -import com.gemstone.gemfire.cache.query.IndexType; -import com.gemstone.gemfire.cache.query.QueryException; -import com.gemstone.gemfire.cache.query.QueryInvocationTargetException; -import com.gemstone.gemfire.cache.query.SelectResults; -import com.gemstone.gemfire.cache.query.TypeMismatchException; -import com.gemstone.gemfire.cache.query.internal.CompiledValue; -import com.gemstone.gemfire.cache.query.internal.ExecutionContext; -import com.gemstone.gemfire.cache.query.internal.RuntimeIterator; -import com.gemstone.gemfire.cache.query.types.ObjectType; -import com.gemstone.gemfire.internal.cache.BucketRegion; -import com.gemstone.gemfire.internal.cache.PartitionedRegion; -import com.gemstone.gemfire.internal.cache.PartitionedRegionDataStore; -import com.gemstone.gemfire.internal.cache.RegionEntry; -import com.gemstone.gemfire.internal.cache.execute.BucketMovedException; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.query.Index; +import org.apache.geode.cache.query.IndexExistsException; +import org.apache.geode.cache.query.IndexNameConflictException; +import org.apache.geode.cache.query.IndexStatistics; +import org.apache.geode.cache.query.IndexType; +import org.apache.geode.cache.query.QueryException; +import org.apache.geode.cache.query.QueryInvocationTargetException; +import org.apache.geode.cache.query.SelectResults; +import org.apache.geode.cache.query.TypeMismatchException; +import org.apache.geode.cache.query.internal.CompiledValue; +import org.apache.geode.cache.query.internal.ExecutionContext; +import org.apache.geode.cache.query.internal.RuntimeIterator; +import org.apache.geode.cache.query.types.ObjectType; +import org.apache.geode.internal.cache.BucketRegion; +import org.apache.geode.internal.cache.PartitionedRegion; +import org.apache.geode.internal.cache.PartitionedRegionDataStore; +import org.apache.geode.internal.cache.RegionEntry; +import org.apache.geode.internal.cache.execute.BucketMovedException; +import org.apache.geode.internal.i18n.LocalizedStrings; /** * This class implements a Partitioned index over a group of partitioned region
