Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 7C182200B5A for ; Thu, 4 Aug 2016 18:57:36 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 7AB23160AAE; Thu, 4 Aug 2016 16:57:36 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 75A2E160A6A for ; Thu, 4 Aug 2016 18:57:35 +0200 (CEST) Received: (qmail 11594 invoked by uid 500); 4 Aug 2016 16:57:34 -0000 Mailing-List: contact commits-help@geode.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@geode.incubator.apache.org Delivered-To: mailing list commits@geode.incubator.apache.org Received: (qmail 11585 invoked by uid 99); 4 Aug 2016 16:57:34 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 04 Aug 2016 16:57:34 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org) with ESMTP id 45840C0AEF for ; Thu, 4 Aug 2016 16:57:34 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -4.646 X-Spam-Level: X-Spam-Status: No, score=-4.646 tagged_above=-999 required=6.31 tests=[KAM_ASCII_DIVIDERS=0.8, KAM_LAZY_DOMAIN_SECURITY=1, RCVD_IN_DNSWL_HI=-5, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RP_MATCHES_RCVD=-1.426] autolearn=disabled Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id Sm_T6izVZcud for ; Thu, 4 Aug 2016 16:57:31 +0000 (UTC) Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with SMTP id 5451D5FD8D for ; Thu, 4 Aug 2016 16:57:31 +0000 (UTC) Received: (qmail 11464 invoked by uid 99); 4 Aug 2016 16:57:30 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 04 Aug 2016 16:57:30 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 7D011E78B2; Thu, 4 Aug 2016 16:57:30 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: klund@apache.org To: commits@geode.incubator.apache.org Date: Thu, 04 Aug 2016 16:57:37 -0000 Message-Id: <7551abb05b644f5ab56028b0e1827845@git.apache.org> In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [08/10] incubator-geode git commit: GEODE-1713: cleanup imports archived-at: Thu, 04 Aug 2016 16:57:36 -0000 GEODE-1713: cleanup imports Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/3ac987fe Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/3ac987fe Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/3ac987fe Branch: refs/heads/develop Commit: 3ac987fe8be0888db00c7bbb12125467564c56f1 Parents: f93b748 Author: gmeilen Authored: Thu Jul 28 10:46:30 2016 -0700 Committer: Kirk Lund Committed: Thu Aug 4 09:44:30 2016 -0700 ---------------------------------------------------------------------- .../tier/sockets/command/BaseCQCommand.java | 34 -------------------- .../cache/tier/sockets/command/ExecuteCQ.java | 28 ++++++++-------- .../cache/tier/sockets/command/ExecuteCQ61.java | 2 -- .../cache/tier/sockets/command/GetCQStats.java | 2 -- .../tier/sockets/command/GetDurableCQs.java | 1 - .../cache/tier/sockets/command/MonitorCQ.java | 1 - .../cache/tier/sockets/command/StopCQ.java | 1 - 7 files changed, 15 insertions(+), 54 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/3ac987fe/geode-cq/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/BaseCQCommand.java ---------------------------------------------------------------------- diff --git a/geode-cq/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/BaseCQCommand.java b/geode-cq/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/BaseCQCommand.java index a77ebe5..01dbdb7 100644 --- a/geode-cq/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/BaseCQCommand.java +++ b/geode-cq/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/BaseCQCommand.java @@ -16,41 +16,7 @@ */ package com.gemstone.gemfire.internal.cache.tier.sockets.command; -import java.io.IOException; -import java.util.Collection; -import java.util.Iterator; -import java.util.List; -import java.util.Set; - -import com.gemstone.gemfire.cache.RegionDestroyedException; -import com.gemstone.gemfire.cache.operations.QueryOperationContext; -import com.gemstone.gemfire.cache.query.Query; -import com.gemstone.gemfire.cache.query.QueryException; -import com.gemstone.gemfire.cache.query.QueryInvalidException; -import com.gemstone.gemfire.cache.query.SelectResults; -import com.gemstone.gemfire.cache.query.Struct; -import com.gemstone.gemfire.cache.query.internal.CqEntry; -import com.gemstone.gemfire.cache.query.internal.DefaultQuery; -import com.gemstone.gemfire.cache.query.internal.cq.InternalCqQuery; -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.distributed.DistributedSystemDisconnectedException; -import com.gemstone.gemfire.distributed.internal.DistributionStats; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.cache.CachedDeserializable; -import com.gemstone.gemfire.internal.cache.tier.CachedRegionHelper; -import com.gemstone.gemfire.internal.cache.tier.MessageType; -import com.gemstone.gemfire.internal.cache.tier.sockets.BaseCommand; import com.gemstone.gemfire.internal.cache.tier.sockets.BaseCommandQuery; -import com.gemstone.gemfire.internal.cache.tier.sockets.CacheServerStats; -import com.gemstone.gemfire.internal.cache.tier.sockets.ChunkedMessage; -import com.gemstone.gemfire.internal.cache.tier.sockets.Message; -import com.gemstone.gemfire.internal.cache.tier.sockets.ObjectPartList; -import com.gemstone.gemfire.internal.cache.tier.sockets.ServerConnection; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; -import com.gemstone.gemfire.internal.security.AuthorizeRequestPP; public abstract class BaseCQCommand extends BaseCommandQuery { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/3ac987fe/geode-cq/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteCQ.java ---------------------------------------------------------------------- diff --git a/geode-cq/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteCQ.java b/geode-cq/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteCQ.java index 378cfc4..335e660 100644 --- a/geode-cq/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteCQ.java +++ b/geode-cq/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteCQ.java @@ -16,31 +16,33 @@ */ package com.gemstone.gemfire.internal.cache.tier.sockets.command; -import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; -import com.gemstone.gemfire.internal.cache.tier.CachedRegionHelper; -import com.gemstone.gemfire.internal.cache.tier.Command; -import com.gemstone.gemfire.internal.cache.tier.MessageType; -import com.gemstone.gemfire.internal.cache.tier.sockets.*; +import java.io.IOException; +import java.util.Set; + +import org.apache.logging.log4j.Logger; + import com.gemstone.gemfire.cache.operations.ExecuteCQOperationContext; import com.gemstone.gemfire.cache.query.CqException; import com.gemstone.gemfire.cache.query.Query; -import com.gemstone.gemfire.distributed.internal.DistributionStats; import com.gemstone.gemfire.cache.query.internal.DefaultQuery; import com.gemstone.gemfire.cache.query.internal.DefaultQueryService; 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.cq.ServerCQ; +import com.gemstone.gemfire.distributed.internal.DistributionStats; +import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; +import com.gemstone.gemfire.internal.cache.tier.CachedRegionHelper; +import com.gemstone.gemfire.internal.cache.tier.Command; +import com.gemstone.gemfire.internal.cache.tier.MessageType; +import com.gemstone.gemfire.internal.cache.tier.sockets.AcceptorImpl; +import com.gemstone.gemfire.internal.cache.tier.sockets.CacheServerStats; import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; +import com.gemstone.gemfire.internal.cache.tier.sockets.Message; +import com.gemstone.gemfire.internal.cache.tier.sockets.Part; +import com.gemstone.gemfire.internal.cache.tier.sockets.ServerConnection; import com.gemstone.gemfire.internal.i18n.LocalizedStrings; import com.gemstone.gemfire.internal.logging.LogService; import com.gemstone.gemfire.internal.security.AuthorizeRequest; -import java.io.IOException; -import java.util.Set; - -import org.apache.logging.log4j.Logger; - - public class ExecuteCQ extends BaseCQCommand { protected static final Logger logger = LogService.getLogger(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/3ac987fe/geode-cq/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteCQ61.java ---------------------------------------------------------------------- diff --git a/geode-cq/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteCQ61.java b/geode-cq/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteCQ61.java index 97d8341..5d088e7 100755 --- a/geode-cq/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteCQ61.java +++ b/geode-cq/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteCQ61.java @@ -48,11 +48,9 @@ import com.gemstone.gemfire.internal.i18n.LocalizedStrings; import com.gemstone.gemfire.internal.logging.LogService; import com.gemstone.gemfire.internal.security.AuthorizeRequest; - /** * @since GemFire 6.1 */ - public class ExecuteCQ61 extends BaseCQCommand { protected static final Logger logger = LogService.getLogger(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/3ac987fe/geode-cq/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetCQStats.java ---------------------------------------------------------------------- diff --git a/geode-cq/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetCQStats.java b/geode-cq/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetCQStats.java index 6e18d04..4d98cb8 100644 --- a/geode-cq/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetCQStats.java +++ b/geode-cq/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetCQStats.java @@ -16,7 +16,6 @@ */ package com.gemstone.gemfire.internal.cache.tier.sockets.command; - import java.io.IOException; import com.gemstone.gemfire.cache.query.internal.cq.CqService; @@ -28,7 +27,6 @@ import com.gemstone.gemfire.internal.cache.tier.sockets.CacheServerStats; import com.gemstone.gemfire.internal.cache.tier.sockets.Message; import com.gemstone.gemfire.internal.cache.tier.sockets.ServerConnection; - public class GetCQStats extends BaseCQCommand { private final static GetCQStats singleton = new GetCQStats(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/3ac987fe/geode-cq/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetDurableCQs.java ---------------------------------------------------------------------- diff --git a/geode-cq/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetDurableCQs.java b/geode-cq/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetDurableCQs.java index 8773a08..9e1b1d7 100755 --- a/geode-cq/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetDurableCQs.java +++ b/geode-cq/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetDurableCQs.java @@ -36,7 +36,6 @@ import com.gemstone.gemfire.internal.cache.tier.sockets.Message; import com.gemstone.gemfire.internal.cache.tier.sockets.ServerConnection; import com.gemstone.gemfire.internal.security.AuthorizeRequest; - public class GetDurableCQs extends BaseCQCommand { private final static GetDurableCQs singleton = new GetDurableCQs(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/3ac987fe/geode-cq/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/MonitorCQ.java ---------------------------------------------------------------------- diff --git a/geode-cq/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/MonitorCQ.java b/geode-cq/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/MonitorCQ.java index 0da9091..98d8e18 100644 --- a/geode-cq/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/MonitorCQ.java +++ b/geode-cq/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/MonitorCQ.java @@ -16,7 +16,6 @@ */ package com.gemstone.gemfire.internal.cache.tier.sockets.command; - import java.io.IOException; import com.gemstone.gemfire.cache.query.CqException; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/3ac987fe/geode-cq/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/StopCQ.java ---------------------------------------------------------------------- diff --git a/geode-cq/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/StopCQ.java b/geode-cq/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/StopCQ.java index 0d2c82c..0988944 100644 --- a/geode-cq/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/StopCQ.java +++ b/geode-cq/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/StopCQ.java @@ -35,7 +35,6 @@ import com.gemstone.gemfire.internal.cache.tier.sockets.ServerConnection; import com.gemstone.gemfire.internal.i18n.LocalizedStrings; import com.gemstone.gemfire.internal.security.AuthorizeRequest; - public class StopCQ extends BaseCQCommand { private final static StopCQ singleton = new StopCQ();