http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/LinkedResultSet.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/LinkedResultSet.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/LinkedResultSet.java index f7b6311..3877bd0 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/LinkedResultSet.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/LinkedResultSet.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; @@ -30,15 +30,15 @@ import java.util.List; import java.util.Set; import java.util.SortedSet; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.query.SelectResults; -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.i18n.LocalizedStrings; +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.query.SelectResults; +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.i18n.LocalizedStrings; public class LinkedResultSet extends java.util.LinkedHashSet implements Ordered, SelectResults, DataSerializableFixedID {
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/LinkedStructSet.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/LinkedStructSet.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/LinkedStructSet.java index 3cfa738..5c3f964 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/LinkedStructSet.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/LinkedStructSet.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; @@ -28,17 +28,17 @@ import java.util.List; import java.util.Set; import java.util.SortedSet; -import com.gemstone.gemfire.DataSerializer; -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.types.CollectionType; -import com.gemstone.gemfire.cache.query.types.ObjectType; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.DataSerializer; +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.types.CollectionType; +import org.apache.geode.cache.query.types.ObjectType; +import org.apache.geode.internal.DataSerializableFixedID; +import org.apache.geode.internal.Version; +import org.apache.geode.internal.i18n.LocalizedStrings; public class LinkedStructSet extends LinkedHashSet<Struct> implements SelectResults<Struct>, Ordered, DataSerializableFixedID { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/MapIndexable.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/MapIndexable.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/MapIndexable.java index 4cc3fa0..b6eafd4 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/MapIndexable.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/MapIndexable.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.List; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/MethodDispatch.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/MethodDispatch.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/MethodDispatch.java index 16a3e42..084a360 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/MethodDispatch.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/MethodDispatch.java @@ -15,15 +15,15 @@ * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal; +package org.apache.geode.cache.query.internal; import java.util.*; import java.lang.reflect.*; -import com.gemstone.gemfire.cache.query.*; -import com.gemstone.gemfire.cache.query.internal.types.TypeUtils; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.cache.query.*; +import org.apache.geode.cache.query.internal.types.TypeUtils; +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/NWayMergeResults.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/NWayMergeResults.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/NWayMergeResults.java index 6be806a..03e9651 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/NWayMergeResults.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/NWayMergeResults.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; @@ -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.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.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.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.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; /** * The n - way merge results returns a sorted results on the cumulative sorted http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/Negatable.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/Negatable.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/Negatable.java index 8642f5e..bf20faf 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/Negatable.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/Negatable.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; /** * Marker interface to mark CompiledValue classes that know how to negate themselves. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/NullToken.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/NullToken.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/NullToken.java index 4d21d29..4e1aed4 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/NullToken.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/NullToken.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.io.DataInput; import java.io.DataOutput; import java.io.IOException; -import com.gemstone.gemfire.cache.query.QueryService; -import com.gemstone.gemfire.cache.query.internal.index.IndexManager; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -import com.gemstone.gemfire.internal.Version; +import org.apache.geode.cache.query.QueryService; +import org.apache.geode.cache.query.internal.index.IndexManager; +import org.apache.geode.internal.DataSerializableFixedID; +import org.apache.geode.internal.Version; /** * A Token representing null. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/ObjectIntHashMap.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/ObjectIntHashMap.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/ObjectIntHashMap.java index 113eb8d..d111670 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/ObjectIntHashMap.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/ObjectIntHashMap.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.IOException; 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/OrderByComparator.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/OrderByComparator.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/OrderByComparator.java index a99a515..9203b2a 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/OrderByComparator.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/OrderByComparator.java @@ -14,20 +14,20 @@ * 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.Comparator; import java.util.Iterator; 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.QueryService; -import com.gemstone.gemfire.cache.query.TypeMismatchException; -import com.gemstone.gemfire.cache.query.types.ObjectType; -import com.gemstone.gemfire.internal.cache.VMCachedDeserializable; -import com.gemstone.gemfire.pdx.internal.PdxString; +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.cache.query.types.ObjectType; +import org.apache.geode.internal.cache.VMCachedDeserializable; +import org.apache.geode.pdx.internal.PdxString; /** * A generic comparator class which compares two Object/StructImpl according to http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/OrderByComparatorUnmapped.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/OrderByComparatorUnmapped.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/OrderByComparatorUnmapped.java index 6eb8c46..6843d9c 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/OrderByComparatorUnmapped.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/OrderByComparatorUnmapped.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 it.unimi.dsi.fastutil.objects.Object2ObjectOpenCustomHashMap; @@ -23,11 +23,11 @@ import java.util.Iterator; import java.util.List; import java.util.Map; -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.types.ObjectType; +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.types.ObjectType; @Deprecated public class OrderByComparatorUnmapped extends OrderByComparator { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/Ordered.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/Ordered.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/Ordered.java index b55de6a..30d8e1a 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/Ordered.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/Ordered.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.Comparator; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/OrganizedOperands.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/OrganizedOperands.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/OrganizedOperands.java index 3b55cc3..2b44471 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/OrganizedOperands.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/OrganizedOperands.java @@ -19,7 +19,7 @@ * * */ -package com.gemstone.gemfire.cache.query.internal; +package org.apache.geode.cache.query.internal; /** * Helper class object which gets created during 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/PRQueryTraceInfo.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/PRQueryTraceInfo.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/PRQueryTraceInfo.java index 6cbe397..344c3ba 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/PRQueryTraceInfo.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/PRQueryTraceInfo.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; @@ -22,12 +22,12 @@ import java.io.IOException; import java.util.Collection; import java.util.Iterator; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.DataSerializer; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.DataSerializableFixedID; +import org.apache.geode.internal.Version; +import org.apache.geode.internal.i18n.LocalizedStrings; public class PRQueryTraceInfo implements DataSerializableFixedID { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/PathUtils.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/PathUtils.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/PathUtils.java index 70c6f7c..3d8db8d 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/PathUtils.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/PathUtils.java @@ -14,21 +14,21 @@ * 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.lang.reflect.*; import java.util.*; -import com.gemstone.gemfire.cache.query.AmbiguousNameException; -import com.gemstone.gemfire.cache.query.NameResolutionException; -import com.gemstone.gemfire.cache.query.QueryInvocationTargetException; -import com.gemstone.gemfire.cache.query.NameNotFoundException; -import com.gemstone.gemfire.cache.query.QueryService; -import com.gemstone.gemfire.cache.query.Struct; -import com.gemstone.gemfire.cache.query.TypeMismatchException; -import com.gemstone.gemfire.cache.query.types.*; -import com.gemstone.gemfire.cache.query.internal.parse.OQLLexerTokenTypes; -import com.gemstone.gemfire.cache.query.internal.types.*; +import org.apache.geode.cache.query.AmbiguousNameException; +import org.apache.geode.cache.query.NameResolutionException; +import org.apache.geode.cache.query.QueryInvocationTargetException; +import org.apache.geode.cache.query.NameNotFoundException; +import org.apache.geode.cache.query.QueryService; +import org.apache.geode.cache.query.Struct; +import org.apache.geode.cache.query.TypeMismatchException; +import org.apache.geode.cache.query.types.*; +import org.apache.geode.cache.query.internal.parse.OQLLexerTokenTypes; +import org.apache.geode.cache.query.internal.types.*; /** http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/PlanInfo.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/PlanInfo.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/PlanInfo.java index f42416a..ed803a6 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/PlanInfo.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/PlanInfo.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; /** * Encapsulates evaluation info about compiled values http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/ProxyQueryService.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/ProxyQueryService.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/ProxyQueryService.java index 21274c1..fc19039 100755 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/ProxyQueryService.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/ProxyQueryService.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; @@ -24,29 +24,29 @@ import java.util.List; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.cache.CacheClosedException; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.client.internal.ProxyCache; -import com.gemstone.gemfire.cache.client.internal.UserAttributes; -import com.gemstone.gemfire.cache.query.CqAttributes; -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.Index; -import com.gemstone.gemfire.cache.query.IndexExistsException; -import com.gemstone.gemfire.cache.query.IndexInvalidException; -import com.gemstone.gemfire.cache.query.IndexNameConflictException; -import com.gemstone.gemfire.cache.query.IndexType; -import com.gemstone.gemfire.cache.query.MultiIndexCreationException; -import com.gemstone.gemfire.cache.query.Query; -import com.gemstone.gemfire.cache.query.QueryInvalidException; -import com.gemstone.gemfire.cache.query.QueryService; -import com.gemstone.gemfire.cache.query.RegionNotFoundException; -import com.gemstone.gemfire.cache.query.internal.cq.ClientCQ; -import com.gemstone.gemfire.cache.query.internal.cq.InternalCqQuery; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.cache.CacheClosedException; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.client.internal.ProxyCache; +import org.apache.geode.cache.client.internal.UserAttributes; +import org.apache.geode.cache.query.CqAttributes; +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.Index; +import org.apache.geode.cache.query.IndexExistsException; +import org.apache.geode.cache.query.IndexInvalidException; +import org.apache.geode.cache.query.IndexNameConflictException; +import org.apache.geode.cache.query.IndexType; +import org.apache.geode.cache.query.MultiIndexCreationException; +import org.apache.geode.cache.query.Query; +import org.apache.geode.cache.query.QueryInvalidException; +import org.apache.geode.cache.query.QueryService; +import org.apache.geode.cache.query.RegionNotFoundException; +import org.apache.geode.cache.query.internal.cq.ClientCQ; +import org.apache.geode.cache.query.internal.cq.InternalCqQuery; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; /** * A wrapper class over an actual QueryService instance. This is used when the http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/QCompiler.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/QCompiler.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/QCompiler.java index b43d082..7de8266 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/QCompiler.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/QCompiler.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.StringReader; import java.util.ArrayList; @@ -30,28 +30,28 @@ import org.apache.logging.log4j.Logger; import antlr.collections.AST; import antlr.debug.misc.ASTFrame; -import com.gemstone.gemfire.cache.query.FunctionDomainException; -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.GemFireAST; -import com.gemstone.gemfire.cache.query.internal.parse.OQLLexer; -import com.gemstone.gemfire.cache.query.internal.parse.OQLLexerTokenTypes; -import com.gemstone.gemfire.cache.query.internal.parse.OQLParser; -import com.gemstone.gemfire.cache.query.internal.types.CollectionTypeImpl; -import com.gemstone.gemfire.cache.query.internal.types.MapTypeImpl; -import com.gemstone.gemfire.cache.query.internal.types.ObjectTypeImpl; -import com.gemstone.gemfire.cache.query.internal.types.TypeUtils; -import com.gemstone.gemfire.cache.query.types.CollectionType; -import com.gemstone.gemfire.cache.query.types.MapType; -import com.gemstone.gemfire.cache.query.types.ObjectType; -import com.gemstone.gemfire.i18n.LogWriterI18n; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.InternalDataSerializer; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.cache.query.FunctionDomainException; +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.GemFireAST; +import org.apache.geode.cache.query.internal.parse.OQLLexer; +import org.apache.geode.cache.query.internal.parse.OQLLexerTokenTypes; +import org.apache.geode.cache.query.internal.parse.OQLParser; +import org.apache.geode.cache.query.internal.types.CollectionTypeImpl; +import org.apache.geode.cache.query.internal.types.MapTypeImpl; +import org.apache.geode.cache.query.internal.types.ObjectTypeImpl; +import org.apache.geode.cache.query.internal.types.TypeUtils; +import org.apache.geode.cache.query.types.CollectionType; +import org.apache.geode.cache.query.types.MapType; +import org.apache.geode.cache.query.types.ObjectType; +import org.apache.geode.i18n.LogWriterI18n; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.InternalDataSerializer; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; /** * Class Description @@ -82,7 +82,7 @@ public class QCompiler implements OQLLexerTokenTypes { OQLParser parser = new OQLParser (lexer); // by default use Unsupported AST class, overridden for supported // operators in the grammer proper - parser.setASTNodeClass ("com.gemstone.gemfire.cache.query.internal.parse.ASTUnsupported"); + parser.setASTNodeClass ("org.apache.geode.cache.query.internal.parse.ASTUnsupported"); parser.queryProgram (); GemFireAST n = (GemFireAST)parser.getAST (); n.compile(this); @@ -100,7 +100,7 @@ public class QCompiler implements OQLLexerTokenTypes { OQLParser parser = new OQLParser (lexer); // by default use Unsupported AST class, overridden for supported // operators in the grammer proper - parser.setASTNodeClass ("com.gemstone.gemfire.cache.query.internal.parse.ASTUnsupported"); + parser.setASTNodeClass ("org.apache.geode.cache.query.internal.parse.ASTUnsupported"); parser.loneFromClause (); GemFireAST n = (GemFireAST)parser.getAST (); n.compile(this); @@ -119,7 +119,7 @@ public class QCompiler implements OQLLexerTokenTypes { OQLParser parser = new OQLParser (lexer); // by default use Unsupported AST class, overridden for supported // operators in the grammer proper - parser.setASTNodeClass ("com.gemstone.gemfire.cache.query.internal.parse.ASTUnsupported"); + parser.setASTNodeClass ("org.apache.geode.cache.query.internal.parse.ASTUnsupported"); parser.loneProjectionAttributes (); GemFireAST n = (GemFireAST)parser.getAST (); // don't compile TOK_STAR @@ -185,7 +185,7 @@ public class QCompiler implements OQLLexerTokenTypes { OQLParser parser = new OQLParser (lexer); // by default use Unsupported AST class, overridden for supported // operators in the grammer proper - parser.setASTNodeClass ("com.gemstone.gemfire.cache.query.internal.parse.ASTUnsupported"); + parser.setASTNodeClass ("org.apache.geode.cache.query.internal.parse.ASTUnsupported"); parser.loneImports(); GemFireAST n = (GemFireAST)parser.getAST (); n.compile(this); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/QRegion.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/QRegion.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/QRegion.java index 052200f..e1be5f3 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/QRegion.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/QRegion.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 java.io.*; -import com.gemstone.gemfire.cache.*; -import com.gemstone.gemfire.cache.query.*; +import org.apache.geode.cache.*; +import org.apache.geode.cache.query.*; import java.util.concurrent.locks.Lock; -import com.gemstone.gemfire.cache.query.types.*; -import com.gemstone.gemfire.cache.query.internal.types.*; -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.query.types.*; +import org.apache.geode.cache.query.internal.types.*; +import org.apache.geode.internal.cache.LocalDataSet; +import org.apache.geode.internal.cache.PartitionedRegion; +import org.apache.geode.internal.i18n.LocalizedStrings; /** * @since GemFire 4.0 http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/QScope.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/QScope.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/QScope.java index 789d8c3..b0e590a 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/QScope.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/QScope.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.*; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryExecutionCanceledException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryExecutionCanceledException.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryExecutionCanceledException.java index e863004..d475727 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryExecutionCanceledException.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryExecutionCanceledException.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal; +package org.apache.geode.cache.query.internal; -import com.gemstone.gemfire.cache.CacheRuntimeException; -import com.gemstone.gemfire.cache.control.ResourceManager; +import org.apache.geode.cache.CacheRuntimeException; +import org.apache.geode.cache.control.ResourceManager; /** * Internal exception thrown when a query has been canceled and QueryMonitor.isQueryExecutionCanceled() is called * Due to various threads using the method, access to the query object may not be available for certain threads http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryExecutionContext.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryExecutionContext.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryExecutionContext.java index 25ec088..5fde70c 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryExecutionContext.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryExecutionContext.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 it.unimi.dsi.fastutil.ints.IntOpenHashSet; @@ -24,10 +24,10 @@ import java.util.List; import java.util.Map; import java.util.Stack; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.cache.query.Query; -import com.gemstone.gemfire.cache.query.SelectResults; -import com.gemstone.gemfire.pdx.internal.PdxString; +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.query.Query; +import org.apache.geode.cache.query.SelectResults; +import org.apache.geode.pdx.internal.PdxString; /** * This ExecutionContext will be used ONLY for querying because this http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryExecutor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryExecutor.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryExecutor.java index 6084d23..c18205e 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryExecutor.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryExecutor.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; +package org.apache.geode.cache.query.internal; import java.util.Set; -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; /** * An interface allowing different Region implementations to support http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryMonitor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryMonitor.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryMonitor.java index d4ca1a9..fb96621 100755 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryMonitor.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryMonitor.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.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentLinkedQueue; @@ -24,13 +24,13 @@ import java.util.concurrent.atomic.AtomicBoolean; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.cache.query.Query; -import com.gemstone.gemfire.cache.query.QueryExecutionLowMemoryException; -import com.gemstone.gemfire.cache.query.QueryExecutionTimeoutException; -import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; -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.cache.query.Query; +import org.apache.geode.cache.query.QueryExecutionLowMemoryException; +import org.apache.geode.cache.query.QueryExecutionTimeoutException; +import org.apache.geode.internal.cache.GemFireCacheImpl; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; /** * QueryMonitor class, monitors the query execution time. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryObserver.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryObserver.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryObserver.java index f2658e2..a79dd14 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryObserver.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryObserver.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; +package org.apache.geode.cache.query.internal; import java.util.*; -import com.gemstone.gemfire.cache.query.*; +import org.apache.geode.cache.query.*; /** * This interface is used by testing/debugging code to be notified of query http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryObserverAdapter.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryObserverAdapter.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryObserverAdapter.java index 574b3b8..4b25359 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryObserverAdapter.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryObserverAdapter.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.*; -import com.gemstone.gemfire.cache.query.*; +import org.apache.geode.cache.query.*; /** * This class provides 'do-nothing' implementations of all of the methods of @@ -308,7 +308,7 @@ public class QueryObserverAdapter implements QueryObserver { } /** - * @see com.gemstone.gemfire.cache.query.internal.QueryObserver#beforeIndexLookup(com.gemstone.gemfire.cache.query.Index, + * @see org.apache.geode.cache.query.internal.QueryObserver#beforeIndexLookup(org.apache.geode.cache.query.Index, * int, java.lang.Object, int, java.lang.Object, java.util.Set) */ public void beforeIndexLookup(Index index, int lowerBoundOperator, http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryObserverHolder.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryObserverHolder.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryObserverHolder.java index b1c4675..685bfc9 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryObserverHolder.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryObserverHolder.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; /** * This class is intended to hold a single 'observer' which will receive http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryUtils.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryUtils.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryUtils.java index 8279c99..a29b599 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryUtils.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryUtils.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.Collections; @@ -28,32 +28,32 @@ import java.util.Set; import org.apache.logging.log4j.Logger; -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.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.AbstractIndex; -import com.gemstone.gemfire.cache.query.internal.index.IndexData; -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.IndexUtils; -import com.gemstone.gemfire.cache.query.internal.index.PartitionedIndex; -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.CollectionType; -import com.gemstone.gemfire.cache.query.types.ObjectType; -import com.gemstone.gemfire.cache.query.types.StructType; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.cache.BucketRegion; -import com.gemstone.gemfire.internal.cache.CachePerfStats; -import com.gemstone.gemfire.internal.cache.PartitionedRegion; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; +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.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.AbstractIndex; +import org.apache.geode.cache.query.internal.index.IndexData; +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.IndexUtils; +import org.apache.geode.cache.query.internal.index.PartitionedIndex; +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.CollectionType; +import org.apache.geode.cache.query.types.ObjectType; +import org.apache.geode.cache.query.types.StructType; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.cache.BucketRegion; +import org.apache.geode.internal.cache.CachePerfStats; +import org.apache.geode.internal.cache.PartitionedRegion; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; public class QueryUtils { private static final Logger logger = LogService.getLogger(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/RangeJunction.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/RangeJunction.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/RangeJunction.java index 6397f74..0f1eae6 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/RangeJunction.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/RangeJunction.java @@ -17,7 +17,7 @@ /* * Created on Jan 27, 2008 */ -package com.gemstone.gemfire.cache.query.internal; +package org.apache.geode.cache.query.internal; import java.util.ArrayList; import java.util.Collections; @@ -26,21 +26,21 @@ import java.util.Iterator; import java.util.List; import java.util.Set; -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.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.internal.i18n.LocalizedStrings; -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 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.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.internal.i18n.LocalizedStrings; +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; /** * This structure contains all the filter evaluatable CompiledComparision http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/ResultsBag.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/ResultsBag.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/ResultsBag.java index c0d4dc4..971f544 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/ResultsBag.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/ResultsBag.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; @@ -22,13 +22,13 @@ import java.io.IOException; import java.util.Collection; import java.util.Iterator; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.query.SelectResults; -import com.gemstone.gemfire.cache.query.internal.ObjectIntHashMap.Entry; -import com.gemstone.gemfire.cache.query.types.ObjectType; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.cache.CachePerfStats; +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.query.SelectResults; +import org.apache.geode.cache.query.internal.ObjectIntHashMap.Entry; +import org.apache.geode.cache.query.types.ObjectType; +import org.apache.geode.internal.DataSerializableFixedID; +import org.apache.geode.internal.Version; +import org.apache.geode.internal.cache.CachePerfStats; public class ResultsBag extends Bag implements DataSerializableFixedID { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/ResultsCollectionCopyOnReadWrapper.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/ResultsCollectionCopyOnReadWrapper.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/ResultsCollectionCopyOnReadWrapper.java index f9ba2f7..8147771 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/ResultsCollectionCopyOnReadWrapper.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/ResultsCollectionCopyOnReadWrapper.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; @@ -23,12 +23,12 @@ import java.util.Iterator; import java.util.List; import java.util.Set; -import com.gemstone.gemfire.CopyHelper; -import com.gemstone.gemfire.cache.query.SelectResults; -import com.gemstone.gemfire.cache.query.Struct; -import com.gemstone.gemfire.cache.query.internal.types.StructTypeImpl; -import com.gemstone.gemfire.cache.query.types.CollectionType; -import com.gemstone.gemfire.cache.query.types.ObjectType; +import org.apache.geode.CopyHelper; +import org.apache.geode.cache.query.SelectResults; +import org.apache.geode.cache.query.Struct; +import org.apache.geode.cache.query.internal.types.StructTypeImpl; +import org.apache.geode.cache.query.types.CollectionType; +import org.apache.geode.cache.query.types.ObjectType; /** * Class that wraps any SelectResults and performs copy on read when iterating through the results http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/ResultsCollectionPdxDeserializerWrapper.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/ResultsCollectionPdxDeserializerWrapper.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/ResultsCollectionPdxDeserializerWrapper.java index 5a57d98..91945f5 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/ResultsCollectionPdxDeserializerWrapper.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/ResultsCollectionPdxDeserializerWrapper.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; @@ -23,14 +23,14 @@ import java.util.Iterator; import java.util.List; import java.util.Set; -import com.gemstone.gemfire.CopyHelper; -import com.gemstone.gemfire.cache.query.SelectResults; -import com.gemstone.gemfire.cache.query.Struct; -import com.gemstone.gemfire.cache.query.internal.types.StructTypeImpl; -import com.gemstone.gemfire.cache.query.types.CollectionType; -import com.gemstone.gemfire.cache.query.types.ObjectType; -import com.gemstone.gemfire.pdx.PdxInstance; -import com.gemstone.gemfire.pdx.internal.PdxString; +import org.apache.geode.CopyHelper; +import org.apache.geode.cache.query.SelectResults; +import org.apache.geode.cache.query.Struct; +import org.apache.geode.cache.query.internal.types.StructTypeImpl; +import org.apache.geode.cache.query.types.CollectionType; +import org.apache.geode.cache.query.types.ObjectType; +import org.apache.geode.pdx.PdxInstance; +import org.apache.geode.pdx.internal.PdxString; public class ResultsCollectionPdxDeserializerWrapper implements SelectResults { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/ResultsCollectionWrapper.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/ResultsCollectionWrapper.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/ResultsCollectionWrapper.java index 6f35770..6bd5f8a 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/ResultsCollectionWrapper.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/ResultsCollectionWrapper.java @@ -14,21 +14,21 @@ * 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 java.io.*; import java.lang.reflect.Array; import java.lang.reflect.Modifier; -import com.gemstone.gemfire.cache.query.*; -import com.gemstone.gemfire.cache.query.types.*; -import com.gemstone.gemfire.cache.query.internal.types.*; -import com.gemstone.gemfire.internal.cache.EntriesSet; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.*; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -import com.gemstone.gemfire.internal.InternalDataSerializer; -import com.gemstone.gemfire.internal.Version; +import org.apache.geode.cache.query.*; +import org.apache.geode.cache.query.types.*; +import org.apache.geode.cache.query.internal.types.*; +import org.apache.geode.internal.cache.EntriesSet; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.*; +import org.apache.geode.internal.DataSerializableFixedID; +import org.apache.geode.internal.InternalDataSerializer; +import org.apache.geode.internal.Version; /** * Implementation of SelectResults that wraps an existing 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/ResultsSet.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/ResultsSet.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/ResultsSet.java index 2d513bf..e30013d 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/ResultsSet.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/ResultsSet.java @@ -15,22 +15,22 @@ * 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 java.util.*; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -import com.gemstone.gemfire.internal.InternalDataSerializer; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.query.*; -import com.gemstone.gemfire.cache.query.types.*; -import com.gemstone.gemfire.cache.query.internal.types.*; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.DataSerializableFixedID; +import org.apache.geode.internal.InternalDataSerializer; +import org.apache.geode.internal.Version; +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.query.*; +import org.apache.geode.cache.query.types.*; +import org.apache.geode.cache.query.internal.types.*; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.i18n.LocalizedStrings; // @todo probably should assert element type when elements added /** http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/RuntimeIterator.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/RuntimeIterator.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/RuntimeIterator.java index 1eb8691..0e2bb9b 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/RuntimeIterator.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/RuntimeIterator.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; +package org.apache.geode.cache.query.internal; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.i18n.LocalizedStrings; import java.util.*; import java.lang.reflect.Method; -import com.gemstone.gemfire.cache.query.*; -import com.gemstone.gemfire.cache.query.internal.index.IndexCreationHelper; -import com.gemstone.gemfire.cache.query.internal.types.TypeUtils; -import com.gemstone.gemfire.cache.query.types.*; +import org.apache.geode.cache.query.*; +import org.apache.geode.cache.query.internal.index.IndexCreationHelper; +import org.apache.geode.cache.query.internal.types.TypeUtils; +import org.apache.geode.cache.query.types.*; /** * Value representing a current iteration element. This is the representation http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/SelectResultsComparator.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/SelectResultsComparator.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/SelectResultsComparator.java index c63e1b5..8321a62 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/SelectResultsComparator.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/SelectResultsComparator.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.Comparator; -import com.gemstone.gemfire.cache.query.SelectResults; +import org.apache.geode.cache.query.SelectResults; /** * Comparator used by the sorted set for storing the results obtained from http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/SortedResultSet.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/SortedResultSet.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/SortedResultSet.java index f30e865..0d1fb65 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/SortedResultSet.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/SortedResultSet.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 java.io.*; -import com.gemstone.gemfire.*; -import com.gemstone.gemfire.cache.query.*; -import com.gemstone.gemfire.cache.query.types.*; -import com.gemstone.gemfire.cache.query.internal.types.*; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -import com.gemstone.gemfire.internal.Version; +import org.apache.geode.*; +import org.apache.geode.cache.query.*; +import org.apache.geode.cache.query.types.*; +import org.apache.geode.cache.query.internal.types.*; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.DataSerializableFixedID; +import org.apache.geode.internal.Version; /** * Implementation of SelectResults that extends TreeSet This is the sorted http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/SortedResultsBag.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/SortedResultsBag.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/SortedResultsBag.java index 4f6e225..15f777b 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/SortedResultsBag.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/SortedResultsBag.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.Comparator; import java.util.Iterator; @@ -23,10 +23,10 @@ import java.util.Map; import java.util.SortedMap; import java.util.TreeMap; -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.internal.cache.CachePerfStats; +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.internal.cache.CachePerfStats; /** * This results set is used to sort the data allowing duplicates. If the data http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/SortedStructBag.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/SortedStructBag.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/SortedStructBag.java index f318240..78c9749 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/SortedStructBag.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/SortedStructBag.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.Collection; @@ -23,14 +23,14 @@ import java.util.HashSet; import java.util.Iterator; import java.util.Set; -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.types.CollectionType; -import com.gemstone.gemfire.cache.query.types.ObjectType; -import com.gemstone.gemfire.cache.query.types.StructType; -import com.gemstone.gemfire.internal.cache.CachePerfStats; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +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.types.CollectionType; +import org.apache.geode.cache.query.types.ObjectType; +import org.apache.geode.cache.query.types.StructType; +import org.apache.geode.internal.cache.CachePerfStats; +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/SortedStructSet.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/SortedStructSet.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/SortedStructSet.java index b165e0e..48c78c8 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/SortedStructSet.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/SortedStructSet.java @@ -14,17 +14,17 @@ * 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 java.io.*; -import com.gemstone.gemfire.*; -import com.gemstone.gemfire.cache.query.*; -import com.gemstone.gemfire.cache.query.types.*; -import com.gemstone.gemfire.cache.query.internal.types.*; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -import com.gemstone.gemfire.internal.Version; +import org.apache.geode.*; +import org.apache.geode.cache.query.*; +import org.apache.geode.cache.query.types.*; +import org.apache.geode.cache.query.internal.types.*; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.DataSerializableFixedID; +import org.apache.geode.internal.Version; /** * A TreeSet constrained to contain Structs of all the same type. To conserve on http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/StructBag.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/StructBag.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/StructBag.java index 03439a7..7e95f82 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/StructBag.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/StructBag.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 it.unimi.dsi.fastutil.Hash; @@ -26,14 +26,14 @@ import java.util.Collection; import java.util.Iterator; import java.util.Set; -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.types.CollectionType; -import com.gemstone.gemfire.cache.query.types.ObjectType; -import com.gemstone.gemfire.cache.query.types.StructType; -import com.gemstone.gemfire.internal.cache.CachePerfStats; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +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.types.CollectionType; +import org.apache.geode.cache.query.types.ObjectType; +import org.apache.geode.cache.query.types.StructType; +import org.apache.geode.internal.cache.CachePerfStats; +import org.apache.geode.internal.i18n.LocalizedStrings; /** * A Bag constrained to contain Structs of all the same type. To conserve on http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/StructFields.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/StructFields.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/StructFields.java index 5aae91f..bc53d1d 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/StructFields.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/StructFields.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.Iterator; -import com.gemstone.gemfire.cache.query.types.CollectionType; +import org.apache.geode.cache.query.types.CollectionType; /** * This interface is to be implemented by all SelectResults implementation which http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/StructImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/StructImpl.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/StructImpl.java index 673a84e..1f6bf07 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/StructImpl.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/StructImpl.java @@ -15,19 +15,19 @@ * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal; +package org.apache.geode.cache.query.internal; import java.util.*; import java.io.*; -import com.gemstone.gemfire.cache.query.*; -import com.gemstone.gemfire.cache.query.types.*; -import com.gemstone.gemfire.cache.query.internal.types.StructTypeImpl; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.pdx.PdxInstance; -import com.gemstone.gemfire.pdx.internal.PdxString; +import org.apache.geode.cache.query.*; +import org.apache.geode.cache.query.types.*; +import org.apache.geode.cache.query.internal.types.StructTypeImpl; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.DataSerializer; +import org.apache.geode.internal.DataSerializableFixedID; +import org.apache.geode.internal.Version; +import org.apache.geode.pdx.PdxInstance; +import org.apache.geode.pdx.internal.PdxString; /** * Implementation of Struct http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/StructSet.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/StructSet.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/StructSet.java index af2dbe7..5a10bb4 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/StructSet.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/StructSet.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 it.unimi.dsi.fastutil.objects.AbstractObjectIterator; import it.unimi.dsi.fastutil.objects.ObjectIterator; @@ -25,13 +25,13 @@ import java.io.DataOutput; import java.io.IOException; import java.util.*; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.query.*; -import com.gemstone.gemfire.cache.query.types.*; -import com.gemstone.gemfire.cache.query.internal.types.*; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.DataSerializableFixedID; +import org.apache.geode.internal.Version; +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.query.*; +import org.apache.geode.cache.query.types.*; +import org.apache.geode.cache.query.internal.types.*; +import org.apache.geode.internal.i18n.LocalizedStrings; /** * A Set constrained to contain Structs of all the same type. To conserve on http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/Support.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/Support.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/Support.java index 9c12b13..3c55dcc 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/Support.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/Support.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package com.gemstone.gemfire.cache.query.internal; +package org.apache.geode.cache.query.internal; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.InternalGemFireError; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.InternalGemFireError; @@ -88,7 +88,7 @@ public class Support throw new InternalGemFireError(LocalizedStrings.Support_ERROR_ASSERTION_FAILED_0.toLocalizedString(message)); } - // com.gemstone.persistence.jdo.GsRuntime.notifyCDebugger(null); + // org.apache.persistence.jdo.GsRuntime.notifyCDebugger(null); } http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/Undefined.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/Undefined.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/Undefined.java index e65c796..2e21f96 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/Undefined.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/Undefined.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.io.*; -import com.gemstone.gemfire.cache.query.QueryService; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -import com.gemstone.gemfire.internal.Version; +import org.apache.geode.cache.query.QueryService; +import org.apache.geode.internal.DataSerializableFixedID; +import org.apache.geode.internal.Version; /** * An UNDEFINED value is the result of accessing an attribute of a null-valued @@ -41,7 +41,7 @@ public final class Undefined implements DataSerializableFixedID, Comparable, Ser Support.assertState(QueryService.UNDEFINED == null, "UNDEFINED constant already instantiated"); - // com.gemstone.persistence.CanonicalizationHelper + // org.apache.persistence.CanonicalizationHelper // .putCanonicalObj("com/gemstone/persistence/query/QueryService.UNDEFINED", // this); } http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/AbstractAggregator.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/AbstractAggregator.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/AbstractAggregator.java index 0d56a3a..dc998a5 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/AbstractAggregator.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/AbstractAggregator.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; /** * Abstract Aggregator class providing support for downcasting the result http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/Avg.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/Avg.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/Avg.java index 7a0f00a..5607f46 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/Avg.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/Avg.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 non distinct average 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/AvgBucketNode.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/AvgBucketNode.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/AvgBucketNode.java index dae038e..a3240aa 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/AvgBucketNode.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/AvgBucketNode.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; /** * The aggregator for compuing average which is used on the bucket node for http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/AvgDistinct.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/AvgDistinct.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/AvgDistinct.java index 4548731..db22e2d 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/AvgDistinct.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/AvgDistinct.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 average 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/AvgDistinctPRQueryNode.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/AvgDistinctPRQueryNode.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/AvgDistinctPRQueryNode.java index 20d368d..59d7760 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/AvgDistinctPRQueryNode.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/AvgDistinctPRQueryNode.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 final average of distinct values for the partitioned region http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/AvgPRQueryNode.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/AvgPRQueryNode.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/AvgPRQueryNode.java index f892971..f7dbc94 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/AvgPRQueryNode.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/AvgPRQueryNode.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 final non distinct average for a partitioned region based query. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/Count.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/Count.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/Count.java index 8992150..523c5aa 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/Count.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/Count.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 count of the non distinct rows for replicated & PR based http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/CountDistinct.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/CountDistinct.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/CountDistinct.java index c878a24..5068f85 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/CountDistinct.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/CountDistinct.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; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/CountDistinctPRQueryNode.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/CountDistinctPRQueryNode.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/CountDistinctPRQueryNode.java index b2f88a7..2f3fc27 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/CountDistinctPRQueryNode.java +++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/aggregate/CountDistinctPRQueryNode.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;
