http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/AbstractGroupOrRangeJunction.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/AbstractGroupOrRangeJunction.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/AbstractGroupOrRangeJunction.java index cbe7e24..be8bb6b 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/AbstractGroupOrRangeJunction.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/AbstractGroupOrRangeJunction.java @@ -18,15 +18,15 @@ * Abstract Super class of the Group or Range Junction. The common functionality * of Group or Range Junction is present in this class. */ -package com.gemstone.gemfire.cache.query.internal; +package org.apache.geode.cache.query.internal; -import com.gemstone.gemfire.cache.query.*; -import com.gemstone.gemfire.cache.query.internal.parse.OQLLexerTokenTypes; -import com.gemstone.gemfire.cache.query.internal.types.StructTypeImpl; -import com.gemstone.gemfire.cache.query.types.ObjectType; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.cache.query.*; +import org.apache.geode.cache.query.internal.parse.OQLLexerTokenTypes; +import org.apache.geode.cache.query.internal.types.StructTypeImpl; +import org.apache.geode.cache.query.types.ObjectType; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.i18n.LocalizedStrings; import java.util.*;
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/AllGroupJunction.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/AllGroupJunction.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/AllGroupJunction.java index 7b64af7..eae4796 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/AllGroupJunction.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/AllGroupJunction.java @@ -17,18 +17,18 @@ /* * Created on Oct 25, 2005 */ -package com.gemstone.gemfire.cache.query.internal; +package org.apache.geode.cache.query.internal; import java.util.*; -import com.gemstone.gemfire.cache.query.FunctionDomainException; -import com.gemstone.gemfire.cache.query.NameResolutionException; -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.parse.OQLLexerTokenTypes; -import com.gemstone.gemfire.cache.query.internal.types.StructTypeImpl; -import com.gemstone.gemfire.cache.query.types.ObjectType; -import com.gemstone.gemfire.cache.query.types.StructType; +import org.apache.geode.cache.query.FunctionDomainException; +import org.apache.geode.cache.query.NameResolutionException; +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.parse.OQLLexerTokenTypes; +import org.apache.geode.cache.query.internal.types.StructTypeImpl; +import org.apache.geode.cache.query.types.ObjectType; +import org.apache.geode.cache.query.types.StructType; /** * An object of this class gets created during the organization of operands in a http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/AttributeDescriptor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/AttributeDescriptor.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/AttributeDescriptor.java index 7016075..80b01b9 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/AttributeDescriptor.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/AttributeDescriptor.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal; +package org.apache.geode.cache.query.internal; import java.lang.reflect.AccessibleObject; import java.lang.reflect.Field; @@ -30,17 +30,17 @@ import java.util.Set; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentMap; -import com.gemstone.gemfire.cache.EntryDestroyedException; -import com.gemstone.gemfire.cache.query.NameNotFoundException; -import com.gemstone.gemfire.cache.query.QueryInvocationTargetException; -import com.gemstone.gemfire.cache.query.QueryService; -import com.gemstone.gemfire.cache.query.types.ObjectType; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.pdx.PdxInstance; -import com.gemstone.gemfire.pdx.PdxSerializationException; -import com.gemstone.gemfire.pdx.internal.FieldNotFoundInPdxVersion; -import com.gemstone.gemfire.pdx.internal.PdxInstanceImpl; -import com.gemstone.gemfire.pdx.JSONFormatter; +import org.apache.geode.cache.EntryDestroyedException; +import org.apache.geode.cache.query.NameNotFoundException; +import org.apache.geode.cache.query.QueryInvocationTargetException; +import org.apache.geode.cache.query.QueryService; +import org.apache.geode.cache.query.types.ObjectType; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.pdx.PdxInstance; +import org.apache.geode.pdx.PdxSerializationException; +import org.apache.geode.pdx.internal.FieldNotFoundInPdxVersion; +import org.apache.geode.pdx.internal.PdxInstanceImpl; +import org.apache.geode.pdx.JSONFormatter; /** * Utility for managing an attribute @@ -91,7 +91,7 @@ public class AttributeDescriptor { Support.Assert(target != null); Support.Assert(target != QueryService.UNDEFINED); Member m; - if (target.getClass().getName().startsWith("com.gemstone.gemfire.internal.cache.Token$")) { + if (target.getClass().getName().startsWith("org.apache.geode.internal.cache.Token$")) { return QueryService.UNDEFINED; } else { m = getReadMember(resolutionClass); @@ -99,7 +99,7 @@ public class AttributeDescriptor { try { if (m instanceof Method) { try { - if (target.getClass().getName().startsWith("com.gemstone.gemfire.internal.cache.Token$")) { + if (target.getClass().getName().startsWith("org.apache.geode.internal.cache.Token$")) { return QueryService.UNDEFINED; } else { return ((Method)m).invoke(target, (Object[])null); @@ -123,7 +123,7 @@ public class AttributeDescriptor { } } else { try { - if (target.getClass().getName().startsWith("com.gemstone.gemfire.internal.cache.Token$")) { + if (target.getClass().getName().startsWith("org.apache.geode.internal.cache.Token$")) { return QueryService.UNDEFINED; } else { return ((Field)m).get(target); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/Bag.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/Bag.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/Bag.java index 15ca6bb..f4baa03 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/Bag.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/Bag.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal; +package org.apache.geode.cache.query.internal; import java.io.DataInput; import java.io.DataOutput; @@ -29,18 +29,18 @@ import java.util.List; import java.util.NoSuchElementException; import java.util.Set; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.query.CqResults; -import com.gemstone.gemfire.cache.query.SelectResults; -import com.gemstone.gemfire.cache.query.internal.ObjectIntHashMap.Entry; -import com.gemstone.gemfire.cache.query.internal.types.CollectionTypeImpl; -import com.gemstone.gemfire.cache.query.types.CollectionType; -import com.gemstone.gemfire.cache.query.types.ObjectType; -import com.gemstone.gemfire.cache.query.types.StructType; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.cache.CachePerfStats; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.query.CqResults; +import org.apache.geode.cache.query.SelectResults; +import org.apache.geode.cache.query.internal.ObjectIntHashMap.Entry; +import org.apache.geode.cache.query.internal.types.CollectionTypeImpl; +import org.apache.geode.cache.query.types.CollectionType; +import org.apache.geode.cache.query.types.ObjectType; +import org.apache.geode.cache.query.types.StructType; +import org.apache.geode.internal.DataSerializableFixedID; +import org.apache.geode.internal.Version; +import org.apache.geode.internal.cache.CachePerfStats; +import org.apache.geode.internal.i18n.LocalizedStrings; // @todo probably should assert element type when elements added // @todo support generics when no longer support Java 1.4 http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledAggregateFunction.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledAggregateFunction.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledAggregateFunction.java index 87f29fa..f49ef52 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledAggregateFunction.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledAggregateFunction.java @@ -14,30 +14,30 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal; - -import com.gemstone.gemfire.cache.query.AmbiguousNameException; -import com.gemstone.gemfire.cache.query.FunctionDomainException; -import com.gemstone.gemfire.cache.query.NameResolutionException; -import com.gemstone.gemfire.cache.query.QueryInvocationTargetException; -import com.gemstone.gemfire.cache.query.TypeMismatchException; -import com.gemstone.gemfire.cache.query.internal.aggregate.AvgBucketNode; -import com.gemstone.gemfire.cache.query.internal.aggregate.AvgDistinct; -import com.gemstone.gemfire.cache.query.internal.aggregate.AvgDistinctPRQueryNode; -import com.gemstone.gemfire.cache.query.internal.aggregate.AvgPRQueryNode; -import com.gemstone.gemfire.cache.query.internal.aggregate.Count; -import com.gemstone.gemfire.cache.query.internal.aggregate.CountDistinct; -import com.gemstone.gemfire.cache.query.internal.aggregate.CountDistinctPRQueryNode; -import com.gemstone.gemfire.cache.query.internal.aggregate.SumDistinctPRQueryNode; -import com.gemstone.gemfire.cache.query.internal.aggregate.CountPRQueryNode; -import com.gemstone.gemfire.cache.query.internal.aggregate.DistinctAggregator; -import com.gemstone.gemfire.cache.query.internal.aggregate.MaxMin; -import com.gemstone.gemfire.cache.query.internal.aggregate.Avg; -import com.gemstone.gemfire.cache.query.internal.aggregate.Sum; -import com.gemstone.gemfire.cache.query.internal.aggregate.SumDistinct; -import com.gemstone.gemfire.cache.query.internal.parse.OQLLexerTokenTypes; -import com.gemstone.gemfire.cache.query.internal.types.ObjectTypeImpl; -import com.gemstone.gemfire.cache.query.types.ObjectType; +package org.apache.geode.cache.query.internal; + +import org.apache.geode.cache.query.AmbiguousNameException; +import org.apache.geode.cache.query.FunctionDomainException; +import org.apache.geode.cache.query.NameResolutionException; +import org.apache.geode.cache.query.QueryInvocationTargetException; +import org.apache.geode.cache.query.TypeMismatchException; +import org.apache.geode.cache.query.internal.aggregate.AvgBucketNode; +import org.apache.geode.cache.query.internal.aggregate.AvgDistinct; +import org.apache.geode.cache.query.internal.aggregate.AvgDistinctPRQueryNode; +import org.apache.geode.cache.query.internal.aggregate.AvgPRQueryNode; +import org.apache.geode.cache.query.internal.aggregate.Count; +import org.apache.geode.cache.query.internal.aggregate.CountDistinct; +import org.apache.geode.cache.query.internal.aggregate.CountDistinctPRQueryNode; +import org.apache.geode.cache.query.internal.aggregate.SumDistinctPRQueryNode; +import org.apache.geode.cache.query.internal.aggregate.CountPRQueryNode; +import org.apache.geode.cache.query.internal.aggregate.DistinctAggregator; +import org.apache.geode.cache.query.internal.aggregate.MaxMin; +import org.apache.geode.cache.query.internal.aggregate.Avg; +import org.apache.geode.cache.query.internal.aggregate.Sum; +import org.apache.geode.cache.query.internal.aggregate.SumDistinct; +import org.apache.geode.cache.query.internal.parse.OQLLexerTokenTypes; +import org.apache.geode.cache.query.internal.types.ObjectTypeImpl; +import org.apache.geode.cache.query.types.ObjectType; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledBindArgument.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledBindArgument.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledBindArgument.java index 3308cea..37d39a5 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledBindArgument.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledBindArgument.java @@ -15,17 +15,17 @@ * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal; +package org.apache.geode.cache.query.internal; import java.util.*; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.internal.cache.PartitionedRegion; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.pdx.internal.PdxString; -import com.gemstone.gemfire.cache.query.AmbiguousNameException; -import com.gemstone.gemfire.cache.query.NameResolutionException; -import com.gemstone.gemfire.cache.query.TypeMismatchException; +import org.apache.geode.cache.Region; +import org.apache.geode.internal.cache.PartitionedRegion; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.pdx.internal.PdxString; +import org.apache.geode.cache.query.AmbiguousNameException; +import org.apache.geode.cache.query.NameResolutionException; +import org.apache.geode.cache.query.TypeMismatchException; /** * Class Description http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledComparison.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledComparison.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledComparison.java index 5c764e3..d8324d6 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledComparison.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledComparison.java @@ -14,33 +14,33 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal; +package org.apache.geode.cache.query.internal; import java.util.ArrayList; import java.util.List; import java.util.Set; -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.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.Struct; -import com.gemstone.gemfire.cache.query.TypeMismatchException; -import com.gemstone.gemfire.cache.query.internal.index.IndexData; -import com.gemstone.gemfire.cache.query.internal.index.IndexProtocol; -import com.gemstone.gemfire.cache.query.internal.index.IndexUtils; -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.offheap.annotations.Retained; -import com.gemstone.gemfire.pdx.PdxInstance; -import com.gemstone.gemfire.pdx.internal.PdxString; +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.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.Struct; +import org.apache.geode.cache.query.TypeMismatchException; +import org.apache.geode.cache.query.internal.index.IndexData; +import org.apache.geode.cache.query.internal.index.IndexProtocol; +import org.apache.geode.cache.query.internal.index.IndexUtils; +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.offheap.annotations.Retained; +import org.apache.geode.pdx.PdxInstance; +import org.apache.geode.pdx.internal.PdxString; /** * Comparison value: <, >, <=, >=, <>, = http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledConstruction.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledConstruction.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledConstruction.java index f2bdab7..3ec8df1 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledConstruction.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledConstruction.java @@ -15,11 +15,11 @@ * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal; +package org.apache.geode.cache.query.internal; import java.util.*; -import com.gemstone.gemfire.cache.query.*; -import com.gemstone.gemfire.internal.Assert; +import org.apache.geode.cache.query.*; +import org.apache.geode.internal.Assert; /** http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledFunction.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledFunction.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledFunction.java index 1d76d86..dec4a26 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledFunction.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledFunction.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal; +package org.apache.geode.cache.query.internal; import java.util.*; -import com.gemstone.gemfire.cache.query.*; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.pdx.internal.PdxString; +import org.apache.geode.cache.query.*; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.pdx.internal.PdxString; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledGroupBySelect.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledGroupBySelect.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledGroupBySelect.java index 59e228f..d287350 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledGroupBySelect.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledGroupBySelect.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; +package org.apache.geode.cache.query.internal; import java.util.Arrays; import java.util.BitSet; @@ -25,22 +25,22 @@ import java.util.List; import java.util.Map; import java.util.Set; -import com.gemstone.gemfire.cache.query.Aggregator; -import com.gemstone.gemfire.cache.query.AmbiguousNameException; -import com.gemstone.gemfire.cache.query.FunctionDomainException; -import com.gemstone.gemfire.cache.query.NameResolutionException; -import com.gemstone.gemfire.cache.query.QueryInvalidException; -import com.gemstone.gemfire.cache.query.QueryInvocationTargetException; -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.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.internal.utils.PDXUtils; -import com.gemstone.gemfire.cache.query.types.ObjectType; -import com.gemstone.gemfire.cache.query.types.StructType; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.cache.query.Aggregator; +import org.apache.geode.cache.query.AmbiguousNameException; +import org.apache.geode.cache.query.FunctionDomainException; +import org.apache.geode.cache.query.NameResolutionException; +import org.apache.geode.cache.query.QueryInvalidException; +import org.apache.geode.cache.query.QueryInvocationTargetException; +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.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.internal.utils.PDXUtils; +import org.apache.geode.cache.query.types.ObjectType; +import org.apache.geode.cache.query.types.StructType; +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/CompiledID.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledID.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledID.java index 2f12c20..57b3df0 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledID.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledID.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; +package org.apache.geode.cache.query.internal; import java.util.*; -import com.gemstone.gemfire.cache.query.*; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.internal.cache.PartitionedRegion; +import org.apache.geode.cache.query.*; +import org.apache.geode.cache.Region; +import org.apache.geode.internal.cache.PartitionedRegion; /** http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledIn.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledIn.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledIn.java index 42824df..e7c731e 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledIn.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledIn.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal; +package org.apache.geode.cache.query.internal; import java.lang.reflect.Array; import java.util.ArrayList; @@ -29,28 +29,28 @@ import java.util.Set; import org.apache.logging.log4j.Logger; -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.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.RegionNotFoundException; -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.index.IndexData; -import com.gemstone.gemfire.cache.query.internal.index.IndexProtocol; -import com.gemstone.gemfire.cache.query.internal.index.IndexUtils; -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.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.pdx.internal.PdxString; +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.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.RegionNotFoundException; +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.index.IndexData; +import org.apache.geode.cache.query.internal.index.IndexProtocol; +import org.apache.geode.cache.query.internal.index.IndexUtils; +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.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.pdx.internal.PdxString; /** * Class Description http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledIndexOperation.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledIndexOperation.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledIndexOperation.java index fca7e83..b789060 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledIndexOperation.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledIndexOperation.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; +package org.apache.geode.cache.query.internal; import java.util.*; -import com.gemstone.gemfire.cache.query.*; -import com.gemstone.gemfire.cache.*; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.cache.query.*; +import org.apache.geode.cache.*; +import org.apache.geode.internal.i18n.LocalizedStrings; import java.lang.reflect.Array; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledIteratorDef.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledIteratorDef.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledIteratorDef.java index 9f2d06d..b0b3efb 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledIteratorDef.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledIteratorDef.java @@ -14,19 +14,19 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal; +package org.apache.geode.cache.query.internal; import java.util.*; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.cache.*; -import com.gemstone.gemfire.cache.query.*; -import com.gemstone.gemfire.cache.query.internal.parse.*; -import com.gemstone.gemfire.cache.query.types.*; -import com.gemstone.gemfire.cache.query.internal.types.TypeUtils; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.cache.*; +import org.apache.geode.cache.query.*; +import org.apache.geode.cache.query.internal.parse.*; +import org.apache.geode.cache.query.types.*; +import org.apache.geode.cache.query.internal.types.TypeUtils; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; /** */ http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledJunction.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledJunction.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledJunction.java index e238ca2..2612ba5 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledJunction.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledJunction.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; +package org.apache.geode.cache.query.internal; import java.util.ArrayList; import java.util.Arrays; @@ -27,23 +27,23 @@ import java.util.List; import java.util.Map; import java.util.Set; -import com.gemstone.gemfire.InternalGemFireError; -import com.gemstone.gemfire.cache.EntryDestroyedException; -import com.gemstone.gemfire.cache.query.AmbiguousNameException; -import com.gemstone.gemfire.cache.query.FunctionDomainException; -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.index.IndexManager; -import com.gemstone.gemfire.cache.query.internal.index.IndexProtocol; -import com.gemstone.gemfire.cache.query.internal.parse.OQLLexerTokenTypes; -import com.gemstone.gemfire.cache.query.internal.types.StructTypeImpl; -import com.gemstone.gemfire.cache.query.types.ObjectType; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.InternalGemFireError; +import org.apache.geode.cache.EntryDestroyedException; +import org.apache.geode.cache.query.AmbiguousNameException; +import org.apache.geode.cache.query.FunctionDomainException; +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.index.IndexManager; +import org.apache.geode.cache.query.internal.index.IndexProtocol; +import org.apache.geode.cache.query.internal.parse.OQLLexerTokenTypes; +import org.apache.geode.cache.query.internal.types.StructTypeImpl; +import org.apache.geode.cache.query.types.ObjectType; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.i18n.LocalizedStrings; /** * Conjunctions and Disjunctions (LITERAL_and LITERAL_or) As a part of feature http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledLike.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledLike.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledLike.java index 241170f..25087d9 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledLike.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledLike.java @@ -14,25 +14,25 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal; +package org.apache.geode.cache.query.internal; import java.util.regex.Pattern; -import com.gemstone.gemfire.cache.query.AmbiguousNameException; -import com.gemstone.gemfire.cache.query.FunctionDomainException; -import com.gemstone.gemfire.cache.query.NameResolutionException; -import com.gemstone.gemfire.cache.query.QueryInvalidException; -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.index.IndexManager; -import com.gemstone.gemfire.cache.query.internal.index.IndexProtocol; -import com.gemstone.gemfire.cache.query.internal.index.PrimaryKeyIndex; -import com.gemstone.gemfire.cache.query.internal.parse.OQLLexerTokenTypes; -import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.pdx.internal.PdxString; +import org.apache.geode.cache.query.AmbiguousNameException; +import org.apache.geode.cache.query.FunctionDomainException; +import org.apache.geode.cache.query.NameResolutionException; +import org.apache.geode.cache.query.QueryInvalidException; +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.index.IndexManager; +import org.apache.geode.cache.query.internal.index.IndexProtocol; +import org.apache.geode.cache.query.internal.index.PrimaryKeyIndex; +import org.apache.geode.cache.query.internal.parse.OQLLexerTokenTypes; +import org.apache.geode.internal.cache.GemFireCacheImpl; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.pdx.internal.PdxString; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledLiteral.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledLiteral.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledLiteral.java index f29d9d1..0705f53 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledLiteral.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledLiteral.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal; +package org.apache.geode.cache.query.internal; //import java.util.*; -import com.gemstone.gemfire.cache.query.*; -import com.gemstone.gemfire.pdx.internal.PdxString; -//import com.gemstone.gemfire.internal.Assert; +import org.apache.geode.cache.query.*; +import org.apache.geode.pdx.internal.PdxString; +//import org.apache.geode.internal.Assert; /** * Class Description http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledNegation.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledNegation.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledNegation.java index 6d7e9b9..2a69f26 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledNegation.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledNegation.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal; +package org.apache.geode.cache.query.internal; import java.util.*; -import com.gemstone.gemfire.cache.query.*; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.cache.query.*; +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/CompiledOperation.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledOperation.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledOperation.java index 99126ea..12fa01d 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledOperation.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledOperation.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal; +package org.apache.geode.cache.query.internal; import java.util.ArrayList; import java.util.Arrays; @@ -25,21 +25,21 @@ import java.util.Set; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentMap; -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.NameResolutionException; -import com.gemstone.gemfire.cache.query.QueryInvocationTargetException; -import com.gemstone.gemfire.cache.query.QueryService; -import com.gemstone.gemfire.cache.query.TypeMismatchException; -import com.gemstone.gemfire.internal.InternalDataSerializer; -import com.gemstone.gemfire.internal.cache.PartitionedRegion; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.pdx.PdxInstance; -import com.gemstone.gemfire.pdx.PdxSerializationException; -import com.gemstone.gemfire.pdx.internal.PdxInstanceImpl; -import com.gemstone.gemfire.pdx.internal.PdxString; +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.NameResolutionException; +import org.apache.geode.cache.query.QueryInvocationTargetException; +import org.apache.geode.cache.query.QueryService; +import org.apache.geode.cache.query.TypeMismatchException; +import org.apache.geode.internal.InternalDataSerializer; +import org.apache.geode.internal.cache.PartitionedRegion; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.pdx.PdxInstance; +import org.apache.geode.pdx.PdxSerializationException; +import org.apache.geode.pdx.internal.PdxInstanceImpl; +import org.apache.geode.pdx.internal.PdxString; /** * Class Description @@ -263,7 +263,7 @@ public class CompiledOperation extends AbstractCompiledValue { try { methodDispatch = new MethodDispatch(resolutionType, this.methodName, argTypes); } catch(NameResolutionException nre) { - if (!com.gemstone.gemfire.cache.query.Struct.class.isAssignableFrom(resolutionType) && + if (!org.apache.geode.cache.query.Struct.class.isAssignableFrom(resolutionType) && (DefaultQueryService.QUERY_HETEROGENEOUS_OBJECTS || DefaultQueryService.TEST_QUERY_HETEROGENEOUS_OBJECTS)) { return QueryService.UNDEFINED; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledPath.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledPath.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledPath.java index eb29d7c..7266094 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledPath.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledPath.java @@ -15,14 +15,14 @@ * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal; +package org.apache.geode.cache.query.internal; import java.util.*; -import com.gemstone.gemfire.cache.query.*; -import com.gemstone.gemfire.cache.EntryDestroyedException; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.internal.cache.PartitionedRegion; +import org.apache.geode.cache.query.*; +import org.apache.geode.cache.EntryDestroyedException; +import org.apache.geode.cache.Region; +import org.apache.geode.internal.cache.PartitionedRegion; /** http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledRegion.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledRegion.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledRegion.java index aa51b5e..2299282 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledRegion.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledRegion.java @@ -14,16 +14,16 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal; +package org.apache.geode.cache.query.internal; import java.util.*; -import com.gemstone.gemfire.cache.*; -import com.gemstone.gemfire.cache.query.*; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.internal.cache.BucketRegion; -import com.gemstone.gemfire.internal.cache.LocalDataSet; -import com.gemstone.gemfire.internal.cache.PartitionedRegion; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.cache.*; +import org.apache.geode.cache.query.*; +import org.apache.geode.cache.Region; +import org.apache.geode.internal.cache.BucketRegion; +import org.apache.geode.internal.cache.LocalDataSet; +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/CompiledSelect.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledSelect.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledSelect.java index f01a6cb..9c80930 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledSelect.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledSelect.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; +package org.apache.geode.cache.query.internal; import java.util.ArrayList; import java.util.Collection; @@ -22,34 +22,34 @@ import java.util.Iterator; import java.util.List; import java.util.Set; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.cache.CacheClosedException; -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.Index; -import com.gemstone.gemfire.cache.query.NameNotFoundException; -import com.gemstone.gemfire.cache.query.NameResolutionException; -import com.gemstone.gemfire.cache.query.Query; -import com.gemstone.gemfire.cache.query.QueryInvalidException; -import com.gemstone.gemfire.cache.query.QueryInvocationTargetException; -import com.gemstone.gemfire.cache.query.QueryService; -import com.gemstone.gemfire.cache.query.RegionNotFoundException; -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.index.AbstractIndex; -import com.gemstone.gemfire.cache.query.internal.index.PartitionedIndex; -import com.gemstone.gemfire.cache.query.internal.types.ObjectTypeImpl; -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.CollectionType; -import com.gemstone.gemfire.cache.query.types.ObjectType; -import com.gemstone.gemfire.cache.query.types.StructType; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.pdx.PdxInstance; -import com.gemstone.gemfire.pdx.internal.PdxString; +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.CacheClosedException; +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.Index; +import org.apache.geode.cache.query.NameNotFoundException; +import org.apache.geode.cache.query.NameResolutionException; +import org.apache.geode.cache.query.Query; +import org.apache.geode.cache.query.QueryInvalidException; +import org.apache.geode.cache.query.QueryInvocationTargetException; +import org.apache.geode.cache.query.QueryService; +import org.apache.geode.cache.query.RegionNotFoundException; +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.index.AbstractIndex; +import org.apache.geode.cache.query.internal.index.PartitionedIndex; +import org.apache.geode.cache.query.internal.types.ObjectTypeImpl; +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.CollectionType; +import org.apache.geode.cache.query.types.ObjectType; +import org.apache.geode.cache.query.types.StructType; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.pdx.PdxInstance; +import org.apache.geode.pdx.internal.PdxString; /** * Class Description http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledSortCriterion.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledSortCriterion.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledSortCriterion.java index 473e65b..f6b23c0 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledSortCriterion.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledSortCriterion.java @@ -15,24 +15,24 @@ * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal; +package org.apache.geode.cache.query.internal; import java.util.*; -import com.gemstone.gemfire.GemFireCacheException; -import com.gemstone.gemfire.GemFireException; -import com.gemstone.gemfire.cache.CacheException; -import com.gemstone.gemfire.cache.query.AmbiguousNameException; -import com.gemstone.gemfire.cache.query.FunctionDomainException; -import com.gemstone.gemfire.cache.query.IndexInvalidException; -import com.gemstone.gemfire.cache.query.NameResolutionException; -import com.gemstone.gemfire.cache.query.QueryException; -import com.gemstone.gemfire.cache.query.QueryInvalidException; -import com.gemstone.gemfire.cache.query.QueryInvocationTargetException; -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.i18n.LocalizedStrings; +import org.apache.geode.GemFireCacheException; +import org.apache.geode.GemFireException; +import org.apache.geode.cache.CacheException; +import org.apache.geode.cache.query.AmbiguousNameException; +import org.apache.geode.cache.query.FunctionDomainException; +import org.apache.geode.cache.query.IndexInvalidException; +import org.apache.geode.cache.query.NameResolutionException; +import org.apache.geode.cache.query.QueryException; +import org.apache.geode.cache.query.QueryInvalidException; +import org.apache.geode.cache.query.QueryInvocationTargetException; +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.i18n.LocalizedStrings; /** * This class represents a compiled form of sort criterian present in order by http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledUnaryMinus.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledUnaryMinus.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledUnaryMinus.java index 8d27418..f920848 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledUnaryMinus.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledUnaryMinus.java @@ -14,16 +14,16 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal; +package org.apache.geode.cache.query.internal; import java.util.*; -import com.gemstone.gemfire.cache.query.AmbiguousNameException; -import com.gemstone.gemfire.cache.query.FunctionDomainException; -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.TypeMismatchException; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.cache.query.AmbiguousNameException; +import org.apache.geode.cache.query.FunctionDomainException; +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.TypeMismatchException; +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/CompiledUndefined.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledUndefined.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledUndefined.java index 98f301c..7b7242a 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledUndefined.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledUndefined.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; +package org.apache.geode.cache.query.internal; import java.util.*; -import com.gemstone.gemfire.cache.query.*; -import com.gemstone.gemfire.cache.query.internal.IndexInfo; -import com.gemstone.gemfire.cache.query.internal.index.IndexData; -import com.gemstone.gemfire.cache.query.internal.index.IndexProtocol; -import com.gemstone.gemfire.cache.query.internal.index.IndexUtils; -import com.gemstone.gemfire.cache.query.internal.types.StructTypeImpl; -import com.gemstone.gemfire.cache.query.types.ObjectType; -import com.gemstone.gemfire.cache.query.types.StructType; +import org.apache.geode.cache.query.*; +import org.apache.geode.cache.query.internal.IndexInfo; +import org.apache.geode.cache.query.internal.index.IndexData; +import org.apache.geode.cache.query.internal.index.IndexProtocol; +import org.apache.geode.cache.query.internal.index.IndexUtils; +import org.apache.geode.cache.query.internal.types.StructTypeImpl; +import org.apache.geode.cache.query.types.ObjectType; +import org.apache.geode.cache.query.types.StructType; /** * Predefined function for identity of the UNDEFINED literal http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledValue.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledValue.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledValue.java index b31a4f6..5fe341b 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledValue.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompiledValue.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; +package org.apache.geode.cache.query.internal; -import com.gemstone.gemfire.cache.query.*; -import com.gemstone.gemfire.cache.query.internal.parse.OQLLexerTokenTypes; -import com.gemstone.gemfire.cache.query.types.ObjectType; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; +import org.apache.geode.cache.query.*; +import org.apache.geode.cache.query.internal.parse.OQLLexerTokenTypes; +import org.apache.geode.cache.query.types.ObjectType; +import org.apache.geode.distributed.internal.DistributionConfig; import java.util.List; 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/CompositeGroupJunction.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompositeGroupJunction.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompositeGroupJunction.java index d2f9469..9877d78 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompositeGroupJunction.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CompositeGroupJunction.java @@ -18,7 +18,7 @@ * Created on Nov 18, 2005 * */ -package com.gemstone.gemfire.cache.query.internal; +package org.apache.geode.cache.query.internal; import java.util.ArrayList; import java.util.Collections; @@ -27,16 +27,16 @@ import java.util.LinkedList; import java.util.List; import java.util.SortedSet; import java.util.TreeSet; -import com.gemstone.gemfire.cache.query.FunctionDomainException; -import com.gemstone.gemfire.cache.query.NameResolutionException; -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.parse.OQLLexerTokenTypes; -import com.gemstone.gemfire.cache.query.internal.types.StructTypeImpl; -import com.gemstone.gemfire.cache.query.internal.SelectResultsComparator; -import com.gemstone.gemfire.cache.query.types.ObjectType; -import com.gemstone.gemfire.cache.query.types.StructType; +import org.apache.geode.cache.query.FunctionDomainException; +import org.apache.geode.cache.query.NameResolutionException; +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.parse.OQLLexerTokenTypes; +import org.apache.geode.cache.query.internal.types.StructTypeImpl; +import org.apache.geode.cache.query.internal.SelectResultsComparator; +import org.apache.geode.cache.query.types.ObjectType; +import org.apache.geode.cache.query.types.StructType; /** * An object of this class gets created during the organization of operands in a http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/CqEntry.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CqEntry.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CqEntry.java index bba284b..48f04de 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CqEntry.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CqEntry.java @@ -15,14 +15,14 @@ * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal; +package org.apache.geode.cache.query.internal; import java.io.DataInput; import java.io.DataOutput; import java.io.IOException; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -import com.gemstone.gemfire.internal.Version; +import org.apache.geode.DataSerializer; +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/CqQueryVsdStats.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CqQueryVsdStats.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CqQueryVsdStats.java index e65af17..c94091a 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CqQueryVsdStats.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CqQueryVsdStats.java @@ -14,19 +14,19 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal; +package org.apache.geode.cache.query.internal; -import com.gemstone.gemfire.StatisticDescriptor; -import com.gemstone.gemfire.Statistics; -import com.gemstone.gemfire.StatisticsFactory; -import com.gemstone.gemfire.StatisticsType; -import com.gemstone.gemfire.StatisticsTypeFactory; -import com.gemstone.gemfire.cache.query.CqEvent; -import com.gemstone.gemfire.internal.statistics.StatisticsTypeFactoryImpl; -import com.gemstone.gemfire.internal.cache.tier.MessageType; +import org.apache.geode.StatisticDescriptor; +import org.apache.geode.Statistics; +import org.apache.geode.StatisticsFactory; +import org.apache.geode.StatisticsType; +import org.apache.geode.StatisticsTypeFactory; +import org.apache.geode.cache.query.CqEvent; +import org.apache.geode.internal.statistics.StatisticsTypeFactoryImpl; +import org.apache.geode.internal.cache.tier.MessageType; /** - * This class tracks GemFire statistics related to a {@link com.gemstone.gemfire.cache.query.CqQuery}. + * This class tracks GemFire statistics related to a {@link org.apache.geode.cache.query.CqQuery}. * * @since GemFire 5.5 */ http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/CqStateImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CqStateImpl.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CqStateImpl.java index 17c7099..25d858f 100755 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CqStateImpl.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CqStateImpl.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal; +package org.apache.geode.cache.query.internal; -import com.gemstone.gemfire.cache.query.CqState; +import org.apache.geode.cache.query.CqState; /** * Offers methods to get CQ state. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/CumulativeNonDistinctResults.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CumulativeNonDistinctResults.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CumulativeNonDistinctResults.java index c7be13e..7401bfa 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/CumulativeNonDistinctResults.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/CumulativeNonDistinctResults.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; +package org.apache.geode.cache.query.internal; import java.io.DataInput; import java.io.DataOutput; @@ -27,21 +27,21 @@ import java.util.Iterator; import java.util.List; import java.util.Set; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.CacheException; -import com.gemstone.gemfire.cache.query.QueryException; -import com.gemstone.gemfire.cache.query.SelectResults; -import com.gemstone.gemfire.cache.query.Struct; -import com.gemstone.gemfire.cache.query.internal.types.CollectionTypeImpl; -import com.gemstone.gemfire.cache.query.internal.types.StructTypeImpl; -import com.gemstone.gemfire.cache.query.internal.utils.LimitIterator; -import com.gemstone.gemfire.cache.query.internal.utils.PDXUtils; -import com.gemstone.gemfire.cache.query.types.CollectionType; -import com.gemstone.gemfire.cache.query.types.ObjectType; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -import com.gemstone.gemfire.internal.HeapDataOutputStream; -import com.gemstone.gemfire.internal.HeapDataOutputStream.LongUpdater; -import com.gemstone.gemfire.internal.Version; +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.CacheException; +import org.apache.geode.cache.query.QueryException; +import org.apache.geode.cache.query.SelectResults; +import org.apache.geode.cache.query.Struct; +import org.apache.geode.cache.query.internal.types.CollectionTypeImpl; +import org.apache.geode.cache.query.internal.types.StructTypeImpl; +import org.apache.geode.cache.query.internal.utils.LimitIterator; +import org.apache.geode.cache.query.internal.utils.PDXUtils; +import org.apache.geode.cache.query.types.CollectionType; +import org.apache.geode.cache.query.types.ObjectType; +import org.apache.geode.internal.DataSerializableFixedID; +import org.apache.geode.internal.HeapDataOutputStream; +import org.apache.geode.internal.HeapDataOutputStream.LongUpdater; +import org.apache.geode.internal.Version; /** * This is used as a wrapper over all the results of PR which are of non http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/DefaultQuery.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/DefaultQuery.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/DefaultQuery.java index 665c5a4..58df390 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/DefaultQuery.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/DefaultQuery.java @@ -15,31 +15,31 @@ * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal; - -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.cache.CacheClosedException; -import com.gemstone.gemfire.cache.CacheRuntimeException; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.client.internal.ProxyCache; -import com.gemstone.gemfire.cache.client.internal.ServerProxy; -import com.gemstone.gemfire.cache.client.internal.UserAttributes; -import com.gemstone.gemfire.cache.execute.Function; -import com.gemstone.gemfire.cache.execute.RegionFunctionContext; -import com.gemstone.gemfire.cache.partition.PartitionRegionHelper; -import com.gemstone.gemfire.cache.query.*; -import com.gemstone.gemfire.cache.query.internal.cq.InternalCqQuery; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.internal.NanoTimer; -import com.gemstone.gemfire.internal.cache.*; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +package org.apache.geode.cache.query.internal; + +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.CacheClosedException; +import org.apache.geode.cache.CacheRuntimeException; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.client.internal.ProxyCache; +import org.apache.geode.cache.client.internal.ServerProxy; +import org.apache.geode.cache.client.internal.UserAttributes; +import org.apache.geode.cache.execute.Function; +import org.apache.geode.cache.execute.RegionFunctionContext; +import org.apache.geode.cache.partition.PartitionRegionHelper; +import org.apache.geode.cache.query.*; +import org.apache.geode.cache.query.internal.cq.InternalCqQuery; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.internal.NanoTimer; +import org.apache.geode.internal.cache.*; +import org.apache.geode.internal.i18n.LocalizedStrings; import java.util.*; import java.util.concurrent.atomic.AtomicLong; /** - * Thread-safe implementation of com.gemstone.persistence.query.Query + * Thread-safe implementation of org.apache.persistence.query.Query * */ http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/DefaultQueryService.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/DefaultQueryService.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/DefaultQueryService.java index cbfc051..7a43a79 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/DefaultQueryService.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/DefaultQueryService.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; - -import com.gemstone.gemfire.cache.CacheException; -import com.gemstone.gemfire.cache.LowMemoryException; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.RegionAttributes; -import com.gemstone.gemfire.cache.client.internal.InternalPool; -import com.gemstone.gemfire.cache.client.internal.ProxyCache; -import com.gemstone.gemfire.cache.client.internal.ServerProxy; -import com.gemstone.gemfire.cache.client.internal.UserAttributes; -import com.gemstone.gemfire.cache.query.*; -import com.gemstone.gemfire.cache.query.internal.cq.ClientCQ; -import com.gemstone.gemfire.cache.query.internal.cq.CqService; -import com.gemstone.gemfire.cache.query.internal.cq.InternalCqQuery; -import com.gemstone.gemfire.cache.query.internal.index.*; -import com.gemstone.gemfire.cache.query.internal.parse.OQLLexerTokenTypes; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.internal.cache.ForceReattemptException; -import com.gemstone.gemfire.internal.cache.InternalCache; -import com.gemstone.gemfire.internal.cache.LocalRegion; -import com.gemstone.gemfire.internal.cache.PartitionedRegion; -import com.gemstone.gemfire.internal.cache.control.MemoryThresholds; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; +package org.apache.geode.cache.query.internal; + +import org.apache.geode.cache.CacheException; +import org.apache.geode.cache.LowMemoryException; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.RegionAttributes; +import org.apache.geode.cache.client.internal.InternalPool; +import org.apache.geode.cache.client.internal.ProxyCache; +import org.apache.geode.cache.client.internal.ServerProxy; +import org.apache.geode.cache.client.internal.UserAttributes; +import org.apache.geode.cache.query.*; +import org.apache.geode.cache.query.internal.cq.ClientCQ; +import org.apache.geode.cache.query.internal.cq.CqService; +import org.apache.geode.cache.query.internal.cq.InternalCqQuery; +import org.apache.geode.cache.query.internal.index.*; +import org.apache.geode.cache.query.internal.parse.OQLLexerTokenTypes; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.internal.cache.ForceReattemptException; +import org.apache.geode.internal.cache.InternalCache; +import org.apache.geode.internal.cache.LocalRegion; +import org.apache.geode.internal.cache.PartitionedRegion; +import org.apache.geode.internal.cache.control.MemoryThresholds; +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; import java.util.*; @@ -82,7 +82,7 @@ public class DefaultQueryService implements QueryService { * * @return The new <code>Query</code> object. * @throws IllegalArgumentException if the query syntax is invalid. - * @see com.gemstone.gemfire.cache.query.Query + * @see org.apache.geode.cache.query.Query */ public Query newQuery(String queryString) { if (QueryMonitor.isLowMemory()) { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/DerivedInfo.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/DerivedInfo.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/DerivedInfo.java index a934524..f7c9453 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/DerivedInfo.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/DerivedInfo.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal; +package org.apache.geode.cache.query.internal; import java.util.ArrayList; import java.util.HashMap; @@ -26,19 +26,19 @@ import java.util.List; import java.util.Map; import java.util.Set; -import com.gemstone.gemfire.cache.query.FunctionDomainException; -import com.gemstone.gemfire.cache.query.Index; -import com.gemstone.gemfire.cache.query.NameResolutionException; -import com.gemstone.gemfire.cache.query.QueryInvocationTargetException; -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.index.AbstractIndex; -import com.gemstone.gemfire.cache.query.internal.index.IndexProtocol; -import com.gemstone.gemfire.cache.query.internal.index.PartitionedIndex; -import com.gemstone.gemfire.cache.query.internal.parse.OQLLexerTokenTypes; -import com.gemstone.gemfire.cache.query.types.CollectionType; -import com.gemstone.gemfire.cache.query.types.ObjectType; +import org.apache.geode.cache.query.FunctionDomainException; +import org.apache.geode.cache.query.Index; +import org.apache.geode.cache.query.NameResolutionException; +import org.apache.geode.cache.query.QueryInvocationTargetException; +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.index.AbstractIndex; +import org.apache.geode.cache.query.internal.index.IndexProtocol; +import org.apache.geode.cache.query.internal.index.PartitionedIndex; +import org.apache.geode.cache.query.internal.parse.OQLLexerTokenTypes; +import org.apache.geode.cache.query.types.CollectionType; +import org.apache.geode.cache.query.types.ObjectType; public class DerivedInfo { public Map<String, SelectResults> derivedResults; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/ExecutionContext.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/ExecutionContext.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/ExecutionContext.java index 391c028..32679a5 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/ExecutionContext.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/ExecutionContext.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; +package org.apache.geode.cache.query.internal; import java.util.*; -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.index.IndexManager; -import com.gemstone.gemfire.cache.query.internal.parse.OQLLexerTokenTypes; -import com.gemstone.gemfire.cache.query.internal.types.*; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.cache.query.internal.index.IndexUtils; -import com.gemstone.gemfire.internal.cache.PartitionedRegion; -import com.gemstone.gemfire.internal.cache.BucketRegion; -import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; -import com.gemstone.gemfire.internal.cache.CachePerfStats; -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.Region; +import org.apache.geode.cache.query.*; +import org.apache.geode.cache.query.internal.index.IndexManager; +import org.apache.geode.cache.query.internal.parse.OQLLexerTokenTypes; +import org.apache.geode.cache.query.internal.types.*; +import org.apache.geode.internal.Assert; +import org.apache.geode.cache.query.internal.index.IndexUtils; +import org.apache.geode.internal.cache.PartitionedRegion; +import org.apache.geode.internal.cache.BucketRegion; +import org.apache.geode.internal.cache.GemFireCacheImpl; +import org.apache.geode.internal.cache.CachePerfStats; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.pdx.internal.PdxString; /** * This is used to carry the state of a query or index update operation. A state @@ -94,7 +94,7 @@ public class ExecutionContext { * current iteration element. Used to implement the "this" var in the query * shortcut methods * - * @see com.gemstone.gemfire.cache.Region#query + * @see org.apache.geode.cache.Region#query */ public ExecutionContext(Object[] bindArguments, Cache cache) { this.bindArguments = bindArguments; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/Filter.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/Filter.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/Filter.java index d6d5000..7e90e0c 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/Filter.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/Filter.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; +package org.apache.geode.cache.query.internal; import java.util.List; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.cache.query.*; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.cache.query.*; /** * Class Description http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/Functions.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/Functions.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/Functions.java index 45f0902..8e7d55a 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/Functions.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/Functions.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal; +package org.apache.geode.cache.query.internal; import java.util.*; -import com.gemstone.gemfire.cache.query.*; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.pdx.internal.PdxString; +import org.apache.geode.cache.query.*; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.pdx.internal.PdxString; import java.text.*; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/GroupJunction.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/GroupJunction.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/GroupJunction.java index 353d48e..09b4846 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/GroupJunction.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/GroupJunction.java @@ -17,14 +17,14 @@ /* * Created on Oct 25, 2005 */ -package com.gemstone.gemfire.cache.query.internal; +package org.apache.geode.cache.query.internal; import java.util.ArrayList; import java.util.List; -import com.gemstone.gemfire.cache.query.FunctionDomainException; -import com.gemstone.gemfire.cache.query.NameResolutionException; -import com.gemstone.gemfire.cache.query.QueryInvocationTargetException; -import com.gemstone.gemfire.cache.query.TypeMismatchException; +import org.apache.geode.cache.query.FunctionDomainException; +import org.apache.geode.cache.query.NameResolutionException; +import org.apache.geode.cache.query.QueryInvocationTargetException; +import org.apache.geode.cache.query.TypeMismatchException; /** * This structure contains the filter evaluable and iter evaluable http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/HashingStrategy.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/HashingStrategy.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/HashingStrategy.java index 18514a1..021c31e 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/HashingStrategy.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/HashingStrategy.java @@ -17,7 +17,7 @@ /** * */ -package com.gemstone.gemfire.cache.query.internal; +package org.apache.geode.cache.query.internal; import java.io.Serializable; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/IndexInfo.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/IndexInfo.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/IndexInfo.java index 35be578..9681657 100755 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/IndexInfo.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/IndexInfo.java @@ -14,16 +14,16 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal; +package org.apache.geode.cache.query.internal; -import com.gemstone.gemfire.cache.query.FunctionDomainException; -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.TypeMismatchException; -import com.gemstone.gemfire.cache.query.internal.index.AbstractIndex; -import com.gemstone.gemfire.cache.query.internal.index.IndexProtocol; -import com.gemstone.gemfire.cache.query.internal.parse.OQLLexerTokenTypes; +import org.apache.geode.cache.query.FunctionDomainException; +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.TypeMismatchException; +import org.apache.geode.cache.query.internal.index.AbstractIndex; +import org.apache.geode.cache.query.internal.index.IndexProtocol; +import org.apache.geode.cache.query.internal.parse.OQLLexerTokenTypes; public class IndexInfo { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/IndexTrackingQueryObserver.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/IndexTrackingQueryObserver.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/IndexTrackingQueryObserver.java index e92e7ca..1650269 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/IndexTrackingQueryObserver.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/IndexTrackingQueryObserver.java @@ -18,7 +18,7 @@ // IndexTrackingQueryObserver.java // gemfire // -package com.gemstone.gemfire.cache.query.internal; +package org.apache.geode.cache.query.internal; import it.unimi.dsi.fastutil.objects.Object2ObjectOpenHashMap; @@ -29,10 +29,10 @@ import java.util.Map; import java.util.Map.Entry; import java.util.Set; -import com.gemstone.gemfire.cache.query.Index; -import com.gemstone.gemfire.cache.query.internal.index.CompactMapRangeIndex; -import com.gemstone.gemfire.cache.query.internal.index.MapRangeIndex; -import com.gemstone.gemfire.internal.cache.PartitionedRegionQueryEvaluator.TestHook; +import org.apache.geode.cache.query.Index; +import org.apache.geode.cache.query.internal.index.CompactMapRangeIndex; +import org.apache.geode.cache.query.internal.index.MapRangeIndex; +import org.apache.geode.internal.cache.PartitionedRegionQueryEvaluator.TestHook; /** * Verbose Index information http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/Indexable.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/Indexable.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/Indexable.java index 8405b86..6ee76bd 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/Indexable.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/Indexable.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; +package org.apache.geode.cache.query.internal; -import com.gemstone.gemfire.cache.query.AmbiguousNameException; -import com.gemstone.gemfire.cache.query.NameResolutionException; -import com.gemstone.gemfire.cache.query.TypeMismatchException; +import org.apache.geode.cache.query.AmbiguousNameException; +import org.apache.geode.cache.query.NameResolutionException; +import org.apache.geode.cache.query.TypeMismatchException; /** * Interface implemented by CompiledComparision and CompiledUndefibed to
