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 01814200CEC for ; Mon, 31 Jul 2017 09:52:31 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id F3BEE164979; Mon, 31 Jul 2017 07:52:30 +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 A61F916497E for ; Mon, 31 Jul 2017 09:52:28 +0200 (CEST) Received: (qmail 17493 invoked by uid 500); 31 Jul 2017 07:52:27 -0000 Mailing-List: contact commits-help@gobblin.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@gobblin.incubator.apache.org Delivered-To: mailing list commits@gobblin.incubator.apache.org Received: (qmail 16015 invoked by uid 99); 31 Jul 2017 07:52:23 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 31 Jul 2017 07:52:23 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 03ACBF333F; Mon, 31 Jul 2017 07:52:19 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: abti@apache.org To: commits@gobblin.apache.org Date: Mon, 31 Jul 2017 07:52:34 -0000 Message-Id: <5204f792516d4f8792a5854a10f415dd@git.apache.org> In-Reply-To: <50c2ce484ba041a294296078b24418ae@git.apache.org> References: <50c2ce484ba041a294296078b24418ae@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [16/77] [abbrv] incubator-gobblin git commit: Updated package names, imports and shell scripts archived-at: Mon, 31 Jul 2017 07:52:31 -0000 http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/converter/AvroR2JoinConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/converter/AvroR2JoinConverter.java b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/converter/AvroR2JoinConverter.java index 508d531..f8c314d 100644 --- a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/converter/AvroR2JoinConverter.java +++ b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/converter/AvroR2JoinConverter.java @@ -1,4 +1,4 @@ -package gobblin.converter; +package org.apache.gobblin.converter; import java.io.IOException; @@ -12,19 +12,19 @@ import com.typesafe.config.Config; import lombok.extern.slf4j.Slf4j; -import gobblin.async.AsyncRequestBuilder; -import gobblin.broker.gobblin_scopes.GobblinScopeTypes; -import gobblin.broker.iface.SharedResourcesBroker; -import gobblin.http.HttpClient; -import gobblin.http.HttpRequestResponseRecord; -import gobblin.http.ResponseHandler; -import gobblin.http.ResponseStatus; -import gobblin.r2.R2ClientFactory; -import gobblin.r2.R2Client; -import gobblin.r2.R2ResponseStatus; -import gobblin.r2.R2RestRequestBuilder; -import gobblin.r2.R2RestResponseHandler; -import gobblin.utils.HttpConstants; +import org.apache.gobblin.async.AsyncRequestBuilder; +import org.apache.gobblin.broker.gobblin_scopes.GobblinScopeTypes; +import org.apache.gobblin.broker.iface.SharedResourcesBroker; +import org.apache.gobblin.http.HttpClient; +import org.apache.gobblin.http.HttpRequestResponseRecord; +import org.apache.gobblin.http.ResponseHandler; +import org.apache.gobblin.http.ResponseStatus; +import org.apache.gobblin.r2.R2ClientFactory; +import org.apache.gobblin.r2.R2Client; +import org.apache.gobblin.r2.R2ResponseStatus; +import org.apache.gobblin.r2.R2RestRequestBuilder; +import org.apache.gobblin.r2.R2RestResponseHandler; +import org.apache.gobblin.utils.HttpConstants; @Slf4j http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/converter/HttpJoinConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/converter/HttpJoinConverter.java b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/converter/HttpJoinConverter.java index b750931..e3a5018 100644 --- a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/converter/HttpJoinConverter.java +++ b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/converter/HttpJoinConverter.java @@ -1,4 +1,4 @@ -package gobblin.converter; +package org.apache.gobblin.converter; import java.io.IOException; import java.util.Queue; @@ -12,20 +12,20 @@ import com.typesafe.config.ConfigFactory; import lombok.extern.slf4j.Slf4j; -import gobblin.async.AsyncRequest; -import gobblin.async.AsyncRequestBuilder; -import gobblin.async.BufferedRecord; -import gobblin.broker.gobblin_scopes.GobblinScopeTypes; -import gobblin.broker.iface.SharedResourcesBroker; -import gobblin.config.ConfigBuilder; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.http.HttpClient; -import gobblin.http.HttpOperation; -import gobblin.http.ResponseHandler; -import gobblin.http.ResponseStatus; -import gobblin.utils.HttpConstants; -import gobblin.writer.WriteCallback; +import org.apache.gobblin.async.AsyncRequest; +import org.apache.gobblin.async.AsyncRequestBuilder; +import org.apache.gobblin.async.BufferedRecord; +import org.apache.gobblin.broker.gobblin_scopes.GobblinScopeTypes; +import org.apache.gobblin.broker.iface.SharedResourcesBroker; +import org.apache.gobblin.config.ConfigBuilder; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.http.HttpClient; +import org.apache.gobblin.http.HttpOperation; +import org.apache.gobblin.http.ResponseHandler; +import org.apache.gobblin.http.ResponseStatus; +import org.apache.gobblin.utils.HttpConstants; +import org.apache.gobblin.writer.WriteCallback; /** * This converter converts an input record (DI) to an output record (DO) which http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ApacheHttpAsyncClient.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ApacheHttpAsyncClient.java b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ApacheHttpAsyncClient.java index 18080ca..956889b 100644 --- a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ApacheHttpAsyncClient.java +++ b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ApacheHttpAsyncClient.java @@ -1,4 +1,4 @@ -package gobblin.http; +package org.apache.gobblin.http; import java.io.IOException; import java.util.concurrent.CountDownLatch; @@ -26,10 +26,10 @@ import com.typesafe.config.ConfigFactory; import lombok.Getter; import lombok.extern.slf4j.Slf4j; -import gobblin.async.Callback; -import gobblin.broker.gobblin_scopes.GobblinScopeTypes; -import gobblin.broker.iface.SharedResourcesBroker; -import gobblin.utils.HttpUtils; +import org.apache.gobblin.async.Callback; +import org.apache.gobblin.broker.gobblin_scopes.GobblinScopeTypes; +import org.apache.gobblin.broker.iface.SharedResourcesBroker; +import org.apache.gobblin.utils.HttpUtils; /** * An asynchronous {@link HttpClient} which sends {@link HttpUriRequest} and registers a callback. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ApacheHttpClient.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ApacheHttpClient.java b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ApacheHttpClient.java index db458f5..4f98ded 100644 --- a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ApacheHttpClient.java +++ b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ApacheHttpClient.java @@ -1,4 +1,4 @@ -package gobblin.http; +package org.apache.gobblin.http; import java.io.IOException; import java.util.concurrent.TimeUnit; @@ -20,10 +20,10 @@ import com.typesafe.config.ConfigFactory; import lombok.extern.slf4j.Slf4j; -import gobblin.async.Callback; -import gobblin.broker.gobblin_scopes.GobblinScopeTypes; -import gobblin.broker.iface.SharedResourcesBroker; -import gobblin.utils.HttpUtils; +import org.apache.gobblin.async.Callback; +import org.apache.gobblin.broker.gobblin_scopes.GobblinScopeTypes; +import org.apache.gobblin.broker.iface.SharedResourcesBroker; +import org.apache.gobblin.utils.HttpUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ApacheHttpRequest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ApacheHttpRequest.java b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ApacheHttpRequest.java index 225d07d..92d29b7 100644 --- a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ApacheHttpRequest.java +++ b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ApacheHttpRequest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.http; +package org.apache.gobblin.http; import java.io.IOException; import java.util.Arrays; @@ -24,7 +24,7 @@ import org.apache.http.HttpEntityEnclosingRequest; import org.apache.http.client.methods.HttpUriRequest; import org.apache.http.util.EntityUtils; -import gobblin.async.AsyncRequest; +import org.apache.gobblin.async.AsyncRequest; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ApacheHttpRequestBuilder.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ApacheHttpRequestBuilder.java b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ApacheHttpRequestBuilder.java index 78e1c53..92b8b96 100644 --- a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ApacheHttpRequestBuilder.java +++ b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ApacheHttpRequestBuilder.java @@ -1,4 +1,4 @@ -package gobblin.http; +package org.apache.gobblin.http; import java.net.URI; import java.util.Map; @@ -15,9 +15,9 @@ import org.slf4j.LoggerFactory; import com.google.common.annotations.VisibleForTesting; -import gobblin.utils.HttpUtils; -import gobblin.async.AsyncRequestBuilder; -import gobblin.async.BufferedRecord; +import org.apache.gobblin.utils.HttpUtils; +import org.apache.gobblin.async.AsyncRequestBuilder; +import org.apache.gobblin.async.BufferedRecord; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ApacheHttpResponseHandler.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ApacheHttpResponseHandler.java b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ApacheHttpResponseHandler.java index ae23a91..c7d182e 100644 --- a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ApacheHttpResponseHandler.java +++ b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ApacheHttpResponseHandler.java @@ -1,4 +1,4 @@ -package gobblin.http; +package org.apache.gobblin.http; import java.io.IOException; import java.util.HashSet; @@ -10,8 +10,8 @@ import org.apache.http.client.methods.HttpUriRequest; import org.apache.http.util.EntityUtils; import lombok.extern.slf4j.Slf4j; -import gobblin.net.Request; -import gobblin.utils.HttpUtils; +import org.apache.gobblin.net.Request; +import org.apache.gobblin.utils.HttpUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ApacheHttpResponseStatus.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ApacheHttpResponseStatus.java b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ApacheHttpResponseStatus.java index 3eda3d0..e5569de 100644 --- a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ApacheHttpResponseStatus.java +++ b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ApacheHttpResponseStatus.java @@ -1,4 +1,4 @@ -package gobblin.http; +package org.apache.gobblin.http; import lombok.Getter; import lombok.Setter; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/HttpClient.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/HttpClient.java b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/HttpClient.java index ed6beb7..247158a 100644 --- a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/HttpClient.java +++ b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/HttpClient.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package gobblin.http; +package org.apache.gobblin.http; import java.io.Closeable; import java.io.IOException; -import gobblin.async.Callback; +import org.apache.gobblin.async.Callback; /** * An interface to send a request http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ResponseHandler.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ResponseHandler.java b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ResponseHandler.java index 02650f8..51861fc 100644 --- a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ResponseHandler.java +++ b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ResponseHandler.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.http; +package org.apache.gobblin.http; -import gobblin.net.Request; +import org.apache.gobblin.net.Request; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ResponseStatus.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ResponseStatus.java b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ResponseStatus.java index a20ffbf..530559e 100644 --- a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ResponseStatus.java +++ b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ResponseStatus.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.http; +package org.apache.gobblin.http; import lombok.Getter; import lombok.Setter; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/StatusType.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/StatusType.java b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/StatusType.java index aede660..bdd2ea8 100644 --- a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/StatusType.java +++ b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/StatusType.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.http; +package org.apache.gobblin.http; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ThrottledHttpClient.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ThrottledHttpClient.java b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ThrottledHttpClient.java index d6627b2..e53396c 100644 --- a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ThrottledHttpClient.java +++ b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/http/ThrottledHttpClient.java @@ -1,4 +1,4 @@ -package gobblin.http; +package org.apache.gobblin.http; import java.io.IOException; @@ -8,16 +8,16 @@ import com.codahale.metrics.Timer; import lombok.Getter; import lombok.extern.slf4j.Slf4j; -import gobblin.async.Callback; -import gobblin.broker.gobblin_scopes.GobblinScopeTypes; -import gobblin.broker.iface.NotConfiguredException; -import gobblin.broker.iface.SharedResourcesBroker; -import gobblin.metrics.MetricContext; -import gobblin.metrics.broker.MetricContextFactory; -import gobblin.metrics.broker.MetricContextKey; -import gobblin.util.http.HttpLimiterKey; -import gobblin.util.limiter.Limiter; -import gobblin.util.limiter.broker.SharedLimiterFactory; +import org.apache.gobblin.async.Callback; +import org.apache.gobblin.broker.gobblin_scopes.GobblinScopeTypes; +import org.apache.gobblin.broker.iface.NotConfiguredException; +import org.apache.gobblin.broker.iface.SharedResourcesBroker; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.broker.MetricContextFactory; +import org.apache.gobblin.metrics.broker.MetricContextKey; +import org.apache.gobblin.util.http.HttpLimiterKey; +import org.apache.gobblin.util.limiter.Limiter; +import org.apache.gobblin.util.limiter.broker.SharedLimiterFactory; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/D2ClientProxy.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/D2ClientProxy.java b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/D2ClientProxy.java index 76b5d82..5338173 100644 --- a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/D2ClientProxy.java +++ b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/D2ClientProxy.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.r2; +package org.apache.gobblin.r2; import java.net.URI; import java.util.ArrayList; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2Client.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2Client.java b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2Client.java index 467c8e0..4c26592 100644 --- a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2Client.java +++ b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2Client.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.r2; +package org.apache.gobblin.r2; import java.io.IOException; import java.util.concurrent.ExecutionException; @@ -30,10 +30,10 @@ import com.typesafe.config.Config; import lombok.extern.slf4j.Slf4j; -import gobblin.async.Callback; -import gobblin.broker.iface.SharedResourcesBroker; -import gobblin.http.ThrottledHttpClient; -import gobblin.utils.HttpUtils; +import org.apache.gobblin.async.Callback; +import org.apache.gobblin.broker.iface.SharedResourcesBroker; +import org.apache.gobblin.http.ThrottledHttpClient; +import org.apache.gobblin.utils.HttpUtils; @Slf4j http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2ClientFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2ClientFactory.java b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2ClientFactory.java index 1b02c71..44d9d0f 100644 --- a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2ClientFactory.java +++ b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2ClientFactory.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.r2; +package org.apache.gobblin.r2; import java.util.HashMap; import java.util.Map; @@ -32,7 +32,7 @@ import com.typesafe.config.ConfigValue; import javax.net.ssl.SSLContext; import javax.net.ssl.SSLParameters; -import gobblin.security.ssl.SSLContextFactory; +import org.apache.gobblin.security.ssl.SSLContextFactory; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2HttpClientProxy.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2HttpClientProxy.java b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2HttpClientProxy.java index 6facc89..06a3b0e 100644 --- a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2HttpClientProxy.java +++ b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2HttpClientProxy.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.r2; +package org.apache.gobblin.r2; import java.util.Map; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2Request.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2Request.java b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2Request.java index dd72afb..ebb1f28 100644 --- a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2Request.java +++ b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2Request.java @@ -15,14 +15,14 @@ * limitations under the License. */ -package gobblin.r2; +package org.apache.gobblin.r2; import java.nio.charset.Charset; import com.linkedin.data.ByteString; import com.linkedin.r2.message.rest.RestRequest; -import gobblin.async.AsyncRequest; +import org.apache.gobblin.async.AsyncRequest; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2ResponseStatus.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2ResponseStatus.java b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2ResponseStatus.java index eb7df49..76b7907 100644 --- a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2ResponseStatus.java +++ b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2ResponseStatus.java @@ -1,12 +1,12 @@ -package gobblin.r2; +package org.apache.gobblin.r2; import com.linkedin.data.ByteString; import lombok.Getter; import lombok.Setter; -import gobblin.http.ResponseStatus; -import gobblin.http.StatusType; +import org.apache.gobblin.http.ResponseStatus; +import org.apache.gobblin.http.StatusType; @Getter @Setter public class R2ResponseStatus extends ResponseStatus { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2RestRequestBuilder.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2RestRequestBuilder.java b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2RestRequestBuilder.java index e06dcf6..4c1e1ea 100644 --- a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2RestRequestBuilder.java +++ b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2RestRequestBuilder.java @@ -1,4 +1,4 @@ -package gobblin.r2; +package org.apache.gobblin.r2; import java.io.IOException; import java.net.URI; @@ -17,10 +17,10 @@ import com.linkedin.r2.message.rest.RestRequestBuilder; import com.linkedin.restli.common.ResourceMethod; import com.linkedin.restli.common.RestConstants; -import gobblin.http.HttpOperation; -import gobblin.utils.HttpUtils; -import gobblin.async.AsyncRequestBuilder; -import gobblin.async.BufferedRecord; +import org.apache.gobblin.http.HttpOperation; +import org.apache.gobblin.utils.HttpUtils; +import org.apache.gobblin.async.AsyncRequestBuilder; +import org.apache.gobblin.async.BufferedRecord; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2RestResponseHandler.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2RestResponseHandler.java b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2RestResponseHandler.java index 876f0c2..496670e 100644 --- a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2RestResponseHandler.java +++ b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2RestResponseHandler.java @@ -1,17 +1,17 @@ -package gobblin.r2; +package org.apache.gobblin.r2; import com.google.common.collect.Maps; import com.linkedin.r2.message.rest.RestRequest; import com.linkedin.r2.message.rest.RestResponse; -import gobblin.configuration.State; -import gobblin.http.ResponseHandler; -import gobblin.http.StatusType; -import gobblin.instrumented.Instrumented; -import gobblin.metrics.MetricContext; -import gobblin.metrics.event.EventSubmitter; -import gobblin.net.Request; -import gobblin.utils.HttpConstants; -import gobblin.utils.HttpUtils; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.http.ResponseHandler; +import org.apache.gobblin.http.StatusType; +import org.apache.gobblin.instrumented.Instrumented; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.event.EventSubmitter; +import org.apache.gobblin.net.Request; +import org.apache.gobblin.utils.HttpConstants; +import org.apache.gobblin.utils.HttpUtils; import java.util.HashSet; import java.util.Map; import java.util.Set; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/utils/HttpConstants.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/utils/HttpConstants.java b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/utils/HttpConstants.java index 82f5f41..2af506c 100644 --- a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/utils/HttpConstants.java +++ b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/utils/HttpConstants.java @@ -1,4 +1,4 @@ -package gobblin.utils; +package org.apache.gobblin.utils; public class HttpConstants { /** Configuration keys */ http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/utils/HttpUtils.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/utils/HttpUtils.java b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/utils/HttpUtils.java index f176154..03a2fba 100644 --- a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/utils/HttpUtils.java +++ b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/utils/HttpUtils.java @@ -1,4 +1,4 @@ -package gobblin.utils; +package org.apache.gobblin.utils; import java.net.MalformedURLException; import java.net.URI; @@ -23,10 +23,10 @@ import com.typesafe.config.Config; import lombok.extern.slf4j.Slf4j; -import gobblin.http.HttpOperation; -import gobblin.http.ResponseStatus; -import gobblin.http.StatusType; -import gobblin.util.AvroUtils; +import org.apache.gobblin.http.HttpOperation; +import org.apache.gobblin.http.ResponseStatus; +import org.apache.gobblin.http.StatusType; +import org.apache.gobblin.util.AvroUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/writer/AsyncHttpWriter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/writer/AsyncHttpWriter.java b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/writer/AsyncHttpWriter.java index 80c0eb4..3396de9 100644 --- a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/writer/AsyncHttpWriter.java +++ b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/writer/AsyncHttpWriter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import java.io.IOException; import java.util.Queue; @@ -25,13 +25,13 @@ import org.slf4j.LoggerFactory; import lombok.extern.slf4j.Slf4j; -import gobblin.async.AsyncRequest; -import gobblin.async.AsyncRequestBuilder; -import gobblin.async.BufferedRecord; -import gobblin.async.DispatchException; -import gobblin.http.HttpClient; -import gobblin.http.ResponseHandler; -import gobblin.http.ResponseStatus; +import org.apache.gobblin.async.AsyncRequest; +import org.apache.gobblin.async.AsyncRequestBuilder; +import org.apache.gobblin.async.BufferedRecord; +import org.apache.gobblin.async.DispatchException; +import org.apache.gobblin.http.HttpClient; +import org.apache.gobblin.http.ResponseHandler; +import org.apache.gobblin.http.ResponseStatus; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/writer/AsyncHttpWriterBuilder.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/writer/AsyncHttpWriterBuilder.java b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/writer/AsyncHttpWriterBuilder.java index 330c76f..9db93d1 100644 --- a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/writer/AsyncHttpWriterBuilder.java +++ b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/writer/AsyncHttpWriterBuilder.java @@ -15,24 +15,24 @@ * limitations under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import com.google.common.base.Preconditions; import com.google.common.collect.ImmutableMap; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.async.AsyncRequestBuilder; -import gobblin.broker.gobblin_scopes.GobblinScopeTypes; -import gobblin.broker.iface.SharedResourcesBroker; -import gobblin.config.ConfigBuilder; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.http.HttpClient; -import gobblin.http.ResponseHandler; -import gobblin.instrumented.Instrumented; -import gobblin.metrics.MetricContext; -import gobblin.util.ConfigUtils; -import gobblin.utils.HttpConstants; +import org.apache.gobblin.async.AsyncRequestBuilder; +import org.apache.gobblin.broker.gobblin_scopes.GobblinScopeTypes; +import org.apache.gobblin.broker.iface.SharedResourcesBroker; +import org.apache.gobblin.config.ConfigBuilder; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.http.HttpClient; +import org.apache.gobblin.http.ResponseHandler; +import org.apache.gobblin.instrumented.Instrumented; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.utils.HttpConstants; import java.io.IOException; import lombok.Getter; import lombok.extern.slf4j.Slf4j; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/writer/AvroHttpWriterBuilder.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/writer/AvroHttpWriterBuilder.java b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/writer/AvroHttpWriterBuilder.java index d28c194..43ff44f 100644 --- a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/writer/AvroHttpWriterBuilder.java +++ b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/writer/AvroHttpWriterBuilder.java @@ -1,4 +1,4 @@ -package gobblin.writer; +package org.apache.gobblin.writer; import java.util.Set; @@ -13,11 +13,11 @@ import com.typesafe.config.ConfigFactory; import lombok.extern.slf4j.Slf4j; -import gobblin.http.ApacheHttpClient; -import gobblin.http.ApacheHttpResponseHandler; -import gobblin.http.ApacheHttpRequestBuilder; -import gobblin.utils.HttpConstants; -import gobblin.utils.HttpUtils; +import org.apache.gobblin.http.ApacheHttpClient; +import org.apache.gobblin.http.ApacheHttpResponseHandler; +import org.apache.gobblin.http.ApacheHttpRequestBuilder; +import org.apache.gobblin.utils.HttpConstants; +import org.apache.gobblin.utils.HttpUtils; @Slf4j http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/writer/R2RestWriterBuilder.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/writer/R2RestWriterBuilder.java b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/writer/R2RestWriterBuilder.java index 63793ee..719ab54 100644 --- a/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/writer/R2RestWriterBuilder.java +++ b/gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/writer/R2RestWriterBuilder.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import com.google.common.collect.ImmutableMap; import com.linkedin.r2.message.rest.RestRequest; @@ -23,12 +23,12 @@ import com.linkedin.r2.message.rest.RestResponse; import com.linkedin.r2.transport.common.Client; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.r2.R2Client; -import gobblin.r2.R2ClientFactory; -import gobblin.r2.R2RestRequestBuilder; -import gobblin.r2.R2RestResponseHandler; -import gobblin.utils.HttpConstants; -import gobblin.utils.HttpUtils; +import org.apache.gobblin.r2.R2Client; +import org.apache.gobblin.r2.R2ClientFactory; +import org.apache.gobblin.r2.R2RestRequestBuilder; +import org.apache.gobblin.r2.R2RestResponseHandler; +import org.apache.gobblin.utils.HttpConstants; +import org.apache.gobblin.utils.HttpUtils; import java.util.Set; import lombok.extern.slf4j.Slf4j; import org.apache.avro.generic.GenericRecord; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/HttpTestUtils.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/HttpTestUtils.java b/gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/HttpTestUtils.java index 4c0dcf3..4a8a3ee 100644 --- a/gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/HttpTestUtils.java +++ b/gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/HttpTestUtils.java @@ -19,8 +19,8 @@ import com.linkedin.data.ByteString; import com.linkedin.r2.message.rest.RestRequest; import com.linkedin.r2.message.rest.RestRequestBuilder; -import gobblin.http.HttpOperation; -import gobblin.async.BufferedRecord; +import org.apache.gobblin.http.HttpOperation; +import org.apache.gobblin.async.BufferedRecord; public class HttpTestUtils { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/http/ApacheHttpRequestBuilderTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/http/ApacheHttpRequestBuilderTest.java b/gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/http/ApacheHttpRequestBuilderTest.java index 8d8307d..b8b24e8 100644 --- a/gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/http/ApacheHttpRequestBuilderTest.java +++ b/gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/http/ApacheHttpRequestBuilderTest.java @@ -1,4 +1,4 @@ -package gobblin.http; +package org.apache.gobblin.http; import java.io.IOException; import java.util.Queue; @@ -13,9 +13,9 @@ import org.mockito.ArgumentCaptor; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.HttpTestUtils; -import gobblin.async.AsyncRequest; -import gobblin.async.BufferedRecord; +import org.apache.gobblin.HttpTestUtils; +import org.apache.gobblin.async.AsyncRequest; +import org.apache.gobblin.async.BufferedRecord; import static org.mockito.Mockito.spy; import static org.mockito.Mockito.verify; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/r2/R2ClientFactoryTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/r2/R2ClientFactoryTest.java b/gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/r2/R2ClientFactoryTest.java index 66baa91..8b9d443 100644 --- a/gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/r2/R2ClientFactoryTest.java +++ b/gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/r2/R2ClientFactoryTest.java @@ -1,4 +1,4 @@ -package gobblin.r2; +package org.apache.gobblin.r2; import java.util.HashMap; import java.util.Map; @@ -16,7 +16,7 @@ import com.typesafe.config.ConfigFactory; import junit.framework.Assert; -import gobblin.security.ssl.SSLContextFactory; +import org.apache.gobblin.security.ssl.SSLContextFactory; @Test http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/r2/R2RestRequestBuilderTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/r2/R2RestRequestBuilderTest.java b/gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/r2/R2RestRequestBuilderTest.java index ffb9846..59c1ddc 100644 --- a/gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/r2/R2RestRequestBuilderTest.java +++ b/gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/r2/R2RestRequestBuilderTest.java @@ -1,4 +1,4 @@ -package gobblin.r2; +package org.apache.gobblin.r2; import java.io.IOException; import java.net.URI; @@ -16,10 +16,10 @@ import com.linkedin.r2.message.rest.RestRequest; import com.linkedin.r2.message.rest.RestRequestBuilder; import com.linkedin.restli.common.RestConstants; -import gobblin.HttpTestUtils; -import gobblin.async.AsyncRequest; -import gobblin.async.BufferedRecord; -import gobblin.r2.R2RestRequestBuilder; +import org.apache.gobblin.HttpTestUtils; +import org.apache.gobblin.async.AsyncRequest; +import org.apache.gobblin.async.BufferedRecord; +import org.apache.gobblin.r2.R2RestRequestBuilder; import static org.mockito.Mockito.spy; import static org.mockito.Mockito.verify; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/util/HttpUtilsTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/util/HttpUtilsTest.java b/gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/util/HttpUtilsTest.java index 39a8d21..3d33da8 100644 --- a/gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/util/HttpUtilsTest.java +++ b/gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/util/HttpUtilsTest.java @@ -1,4 +1,4 @@ -package gobblin.util; +package org.apache.gobblin.util; import java.util.HashMap; import java.util.HashSet; @@ -11,10 +11,10 @@ import com.typesafe.config.ConfigFactory; import junit.framework.Assert; -import gobblin.http.ResponseStatus; -import gobblin.http.StatusType; -import gobblin.utils.HttpConstants; -import gobblin.utils.HttpUtils; +import org.apache.gobblin.http.ResponseStatus; +import org.apache.gobblin.http.StatusType; +import org.apache.gobblin.utils.HttpConstants; +import org.apache.gobblin.utils.HttpUtils; @Test http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/writer/AsyncHttpWriterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/writer/AsyncHttpWriterTest.java b/gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/writer/AsyncHttpWriterTest.java index a4a4fd5..65c95a0 100644 --- a/gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/writer/AsyncHttpWriterTest.java +++ b/gobblin-modules/gobblin-http/src/test/java/org/apache/gobblin/writer/AsyncHttpWriterTest.java @@ -1,4 +1,4 @@ -package gobblin.writer; +package org.apache.gobblin.writer; import java.io.IOException; import java.util.ArrayList; @@ -17,24 +17,24 @@ import com.typesafe.config.ConfigFactory; import junit.framework.Assert; import lombok.extern.slf4j.Slf4j; -import gobblin.async.AsyncRequest; -import gobblin.async.AsyncRequestBuilder; -import gobblin.async.BufferedRecord; -import gobblin.async.Callback; -import gobblin.broker.BrokerConstants; -import gobblin.broker.SharedResourcesBrokerFactory; -import gobblin.broker.SharedResourcesBrokerImpl; -import gobblin.broker.SimpleScopeType; -import gobblin.broker.iface.SharedResourcesBroker; -import gobblin.configuration.WorkUnitState; -import gobblin.http.HttpClient; -import gobblin.http.ResponseHandler; -import gobblin.http.ResponseStatus; -import gobblin.http.StatusType; -import gobblin.http.ThrottledHttpClient; -import gobblin.net.Request; -import gobblin.util.limiter.RateBasedLimiter; -import gobblin.util.limiter.broker.SharedLimiterFactory; +import org.apache.gobblin.async.AsyncRequest; +import org.apache.gobblin.async.AsyncRequestBuilder; +import org.apache.gobblin.async.BufferedRecord; +import org.apache.gobblin.async.Callback; +import org.apache.gobblin.broker.BrokerConstants; +import org.apache.gobblin.broker.SharedResourcesBrokerFactory; +import org.apache.gobblin.broker.SharedResourcesBrokerImpl; +import org.apache.gobblin.broker.SimpleScopeType; +import org.apache.gobblin.broker.iface.SharedResourcesBroker; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.http.HttpClient; +import org.apache.gobblin.http.ResponseHandler; +import org.apache.gobblin.http.ResponseStatus; +import org.apache.gobblin.http.StatusType; +import org.apache.gobblin.http.ThrottledHttpClient; +import org.apache.gobblin.net.Request; +import org.apache.gobblin.util.limiter.RateBasedLimiter; +import org.apache.gobblin.util.limiter.broker.SharedLimiterFactory; @Test http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/client/Kafka08ConsumerClient.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/client/Kafka08ConsumerClient.java b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/client/Kafka08ConsumerClient.java index 5011bdb..08e8ca2 100644 --- a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/client/Kafka08ConsumerClient.java +++ b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/client/Kafka08ConsumerClient.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.kafka.client; +package org.apache.gobblin.kafka.client; import java.io.IOException; import java.nio.ByteBuffer; @@ -49,11 +49,11 @@ import com.google.common.collect.Maps; import com.google.common.net.HostAndPort; import com.typesafe.config.Config; -import gobblin.source.extractor.extract.kafka.KafkaOffsetRetrievalFailureException; -import gobblin.source.extractor.extract.kafka.KafkaPartition; -import gobblin.source.extractor.extract.kafka.KafkaTopic; -import gobblin.util.ConfigUtils; -import gobblin.util.DatasetFilterUtils; +import org.apache.gobblin.source.extractor.extract.kafka.KafkaOffsetRetrievalFailureException; +import org.apache.gobblin.source.extractor.extract.kafka.KafkaPartition; +import org.apache.gobblin.source.extractor.extract.kafka.KafkaTopic; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.util.DatasetFilterUtils; /** * A {@link GobblinKafkaConsumerClient} that uses kafka 08 scala consumer client. All the code has been moved from the http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroDeserializer.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroDeserializer.java b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroDeserializer.java index 71a2e3b..78cd932 100644 --- a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroDeserializer.java +++ b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroDeserializer.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.kafka.serialize; +package org.apache.gobblin.kafka.serialize; import java.io.IOException; import java.util.Map; @@ -34,9 +34,9 @@ import com.google.common.base.Preconditions; import lombok.extern.slf4j.Slf4j; -import gobblin.kafka.schemareg.KafkaSchemaRegistry; -import gobblin.kafka.schemareg.KafkaSchemaRegistryFactory; -import gobblin.kafka.schemareg.SchemaRegistryException; +import org.apache.gobblin.kafka.schemareg.KafkaSchemaRegistry; +import org.apache.gobblin.kafka.schemareg.KafkaSchemaRegistryFactory; +import org.apache.gobblin.kafka.schemareg.SchemaRegistryException; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroSerializer.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroSerializer.java b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroSerializer.java index 4dc0add..6bf812a 100644 --- a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroSerializer.java +++ b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroSerializer.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.kafka.serialize; +package org.apache.gobblin.kafka.serialize; import java.io.IOException; @@ -23,7 +23,7 @@ import org.apache.avro.generic.GenericRecord; import org.apache.kafka.common.errors.SerializationException; import org.apache.kafka.common.serialization.Serializer; -import gobblin.kafka.schemareg.SchemaRegistryException; +import org.apache.gobblin.kafka.schemareg.SchemaRegistryException; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/tool/KafkaCheckpoint.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/tool/KafkaCheckpoint.java b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/tool/KafkaCheckpoint.java index 3a54faa..527135d 100644 --- a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/tool/KafkaCheckpoint.java +++ b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/tool/KafkaCheckpoint.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.kafka.tool; +package org.apache.gobblin.kafka.tool; import java.io.File; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/tool/SimpleKafkaConsumer.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/tool/SimpleKafkaConsumer.java b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/tool/SimpleKafkaConsumer.java index 7447184..fb83990 100644 --- a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/tool/SimpleKafkaConsumer.java +++ b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/tool/SimpleKafkaConsumer.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.kafka.tool; +package org.apache.gobblin.kafka.tool; import java.io.File; import java.io.FileInputStream; @@ -41,10 +41,10 @@ import kafka.javaapi.consumer.ConsumerConnector; import kafka.message.MessageAndMetadata; import lombok.extern.slf4j.Slf4j; -import gobblin.kafka.schemareg.KafkaSchemaRegistry; -import gobblin.kafka.schemareg.KafkaSchemaRegistryFactory; -import gobblin.kafka.serialize.LiAvroDeserializer; -import gobblin.kafka.serialize.MD5Digest; +import org.apache.gobblin.kafka.schemareg.KafkaSchemaRegistry; +import org.apache.gobblin.kafka.schemareg.KafkaSchemaRegistryFactory; +import org.apache.gobblin.kafka.serialize.LiAvroDeserializer; +import org.apache.gobblin.kafka.serialize.MD5Digest; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/writer/Kafka08DataWriter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/writer/Kafka08DataWriter.java b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/writer/Kafka08DataWriter.java index c8a2b9e..8df03c3 100644 --- a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/writer/Kafka08DataWriter.java +++ b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/writer/Kafka08DataWriter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.kafka.writer; +package org.apache.gobblin.kafka.writer; import java.io.IOException; import java.util.Properties; @@ -33,11 +33,11 @@ import com.typesafe.config.ConfigFactory; import lombok.extern.slf4j.Slf4j; -import gobblin.writer.AsyncDataWriter; -import gobblin.writer.WriteCallback; -import gobblin.writer.WriteResponse; -import gobblin.writer.WriteResponseFuture; -import gobblin.writer.WriteResponseMapper; +import org.apache.gobblin.writer.AsyncDataWriter; +import org.apache.gobblin.writer.WriteCallback; +import org.apache.gobblin.writer.WriteResponse; +import org.apache.gobblin.writer.WriteResponseFuture; +import org.apache.gobblin.writer.WriteResponseMapper; /** @@ -106,8 +106,8 @@ public class Kafka08DataWriter implements AsyncDataWriter { log.debug("Close called"); this.producer.close(); } - - + + @Override public Future write(final D record, final WriteCallback callback) { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/writer/KafkaDataWriterBuilder.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/writer/KafkaDataWriterBuilder.java b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/writer/KafkaDataWriterBuilder.java index a396a06..2d8aafc 100644 --- a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/writer/KafkaDataWriterBuilder.java +++ b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/writer/KafkaDataWriterBuilder.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.kafka.writer; +package org.apache.gobblin.kafka.writer; import java.io.IOException; import java.util.Properties; @@ -25,12 +25,12 @@ import org.apache.avro.generic.GenericRecord; import com.typesafe.config.Config; -import gobblin.configuration.State; -import gobblin.util.ConfigUtils; -import gobblin.writer.AsyncDataWriter; -import gobblin.writer.DataWriter; -import gobblin.writer.DataWriterBuilder; -import gobblin.writer.PartitionAwareDataWriterBuilder; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.writer.AsyncDataWriter; +import org.apache.gobblin.writer.DataWriter; +import org.apache.gobblin.writer.DataWriterBuilder; +import org.apache.gobblin.writer.PartitionAwareDataWriterBuilder; /** * Builder that hands back a {@link Kafka08DataWriter} http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/KafkaReportingFormats.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/KafkaReportingFormats.java b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/KafkaReportingFormats.java index 74cd702..0fcac22 100644 --- a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/KafkaReportingFormats.java +++ b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/KafkaReportingFormats.java @@ -15,16 +15,16 @@ * limitations under the License. */ -package gobblin.metrics; +package org.apache.gobblin.metrics; import java.util.Properties; -import gobblin.configuration.ConfigurationKeys; -import gobblin.metrics.kafka.KafkaAvroEventReporter; -import gobblin.metrics.kafka.KafkaAvroReporter; -import gobblin.metrics.kafka.KafkaAvroSchemaRegistry; -import gobblin.metrics.kafka.KafkaEventReporter; -import gobblin.metrics.kafka.KafkaReporter; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.metrics.kafka.KafkaAvroEventReporter; +import org.apache.gobblin.metrics.kafka.KafkaAvroReporter; +import org.apache.gobblin.metrics.kafka.KafkaAvroSchemaRegistry; +import org.apache.gobblin.metrics.kafka.KafkaEventReporter; +import org.apache.gobblin.metrics.kafka.KafkaReporter; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroEventReporter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroEventReporter.java b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroEventReporter.java index f38a27a..c01cbc9 100644 --- a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroEventReporter.java +++ b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroEventReporter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.kafka; +package org.apache.gobblin.metrics.kafka; import java.io.IOException; @@ -23,12 +23,12 @@ import org.apache.avro.Schema; import com.google.common.base.Optional; -import gobblin.metrics.GobblinTrackingEvent; -import gobblin.metrics.MetricContext; -import gobblin.metrics.reporter.util.AvroBinarySerializer; -import gobblin.metrics.reporter.util.AvroSerializer; -import gobblin.metrics.reporter.util.SchemaRegistryVersionWriter; -import gobblin.metrics.reporter.util.SchemaVersionWriter; +import org.apache.gobblin.metrics.GobblinTrackingEvent; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.reporter.util.AvroBinarySerializer; +import org.apache.gobblin.metrics.reporter.util.AvroSerializer; +import org.apache.gobblin.metrics.reporter.util.SchemaRegistryVersionWriter; +import org.apache.gobblin.metrics.reporter.util.SchemaVersionWriter; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroReporter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroReporter.java b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroReporter.java index ea2f01f..7a04358 100644 --- a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroReporter.java +++ b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroReporter.java @@ -15,15 +15,15 @@ * limitations under the License. */ -package gobblin.metrics.kafka; - -import gobblin.configuration.ConfigurationKeys; -import gobblin.metrics.MetricReport; -import gobblin.metrics.reporter.util.AvroBinarySerializer; -import gobblin.metrics.reporter.util.AvroSerializer; -import gobblin.metrics.reporter.util.SchemaRegistryVersionWriter; -import gobblin.metrics.reporter.util.SchemaVersionWriter; -import gobblin.util.ConfigUtils; +package org.apache.gobblin.metrics.kafka; + +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.metrics.MetricReport; +import org.apache.gobblin.metrics.reporter.util.AvroBinarySerializer; +import org.apache.gobblin.metrics.reporter.util.AvroSerializer; +import org.apache.gobblin.metrics.reporter.util.SchemaRegistryVersionWriter; +import org.apache.gobblin.metrics.reporter.util.SchemaVersionWriter; +import org.apache.gobblin.util.ConfigUtils; import java.io.IOException; import java.util.Properties; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaEventReporter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaEventReporter.java b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaEventReporter.java index cfb4d14..bb4f9f0 100644 --- a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaEventReporter.java +++ b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaEventReporter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.kafka; +package org.apache.gobblin.metrics.kafka; import java.io.IOException; import java.util.List; @@ -24,13 +24,13 @@ import java.util.Queue; import com.google.common.base.Optional; import com.google.common.collect.Lists; -import gobblin.metrics.GobblinTrackingEvent; -import gobblin.metrics.MetricContext; -import gobblin.metrics.reporter.EventReporter; -import gobblin.metrics.reporter.util.AvroJsonSerializer; -import gobblin.metrics.reporter.util.AvroSerializer; -import gobblin.metrics.reporter.util.FixedSchemaVersionWriter; -import gobblin.metrics.reporter.util.SchemaVersionWriter; +import org.apache.gobblin.metrics.GobblinTrackingEvent; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.reporter.EventReporter; +import org.apache.gobblin.metrics.reporter.util.AvroJsonSerializer; +import org.apache.gobblin.metrics.reporter.util.AvroSerializer; +import org.apache.gobblin.metrics.reporter.util.FixedSchemaVersionWriter; +import org.apache.gobblin.metrics.reporter.util.SchemaVersionWriter; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaPusher.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaPusher.java b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaPusher.java index 506f591..29162ac 100644 --- a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaPusher.java +++ b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaPusher.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.kafka; +package org.apache.gobblin.metrics.kafka; import java.io.Closeable; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaReporter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaReporter.java b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaReporter.java index bc4d740..add315b 100644 --- a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaReporter.java +++ b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaReporter.java @@ -15,17 +15,17 @@ * limitations under the License. */ -package gobblin.metrics.kafka; - -import gobblin.configuration.ConfigurationKeys; -import gobblin.metrics.MetricReport; -import gobblin.metrics.reporter.MetricReportReporter; -import gobblin.metrics.reporter.util.AvroJsonSerializer; -import gobblin.metrics.reporter.util.AvroSerializer; -import gobblin.metrics.reporter.util.FixedSchemaVersionWriter; -import gobblin.metrics.reporter.util.SchemaVersionWriter; -import gobblin.util.ClassAliasResolver; -import gobblin.util.ConfigUtils; +package org.apache.gobblin.metrics.kafka; + +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.metrics.MetricReport; +import org.apache.gobblin.metrics.reporter.MetricReportReporter; +import org.apache.gobblin.metrics.reporter.util.AvroJsonSerializer; +import org.apache.gobblin.metrics.reporter.util.AvroSerializer; +import org.apache.gobblin.metrics.reporter.util.FixedSchemaVersionWriter; +import org.apache.gobblin.metrics.reporter.util.SchemaVersionWriter; +import org.apache.gobblin.util.ClassAliasResolver; +import org.apache.gobblin.util.ConfigUtils; import java.io.IOException; import java.util.Properties; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaReporterFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaReporterFactory.java b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaReporterFactory.java index a452a4e..328a47b 100644 --- a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaReporterFactory.java +++ b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaReporterFactory.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.kafka; +package org.apache.gobblin.metrics.kafka; import java.io.IOException; import java.util.Properties; @@ -27,11 +27,11 @@ import com.google.common.base.Preconditions; import lombok.extern.slf4j.Slf4j; -import gobblin.configuration.ConfigurationKeys; -import gobblin.metrics.CustomCodahaleReporterFactory; -import gobblin.metrics.KafkaReportingFormats; -import gobblin.metrics.MetricContext; -import gobblin.metrics.RootMetricContext; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.metrics.CustomCodahaleReporterFactory; +import org.apache.gobblin.metrics.KafkaReportingFormats; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.RootMetricContext; @Slf4j http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/ProducerCloseable.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/ProducerCloseable.java b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/ProducerCloseable.java index d5b278a..b28d6a7 100644 --- a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/ProducerCloseable.java +++ b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/ProducerCloseable.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.kafka; +package org.apache.gobblin.metrics.kafka; import java.io.Closeable; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/service/SimpleKafkaSpecExecutorInstance.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/service/SimpleKafkaSpecExecutorInstance.java b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/service/SimpleKafkaSpecExecutorInstance.java index 0e0e523..a60d8e2 100644 --- a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/service/SimpleKafkaSpecExecutorInstance.java +++ b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/service/SimpleKafkaSpecExecutorInstance.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.service; +package org.apache.gobblin.service; import com.google.common.util.concurrent.AbstractIdleService; import java.io.Serializable; @@ -34,11 +34,11 @@ import com.google.common.base.Splitter; import com.google.common.collect.Maps; import com.typesafe.config.Config; -import gobblin.configuration.ConfigurationKeys; -import gobblin.runtime.api.Spec; -import gobblin.runtime.api.SpecExecutorInstance; -import gobblin.util.CompletedFuture; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.runtime.api.Spec; +import org.apache.gobblin.runtime.api.SpecExecutorInstance; +import org.apache.gobblin.util.CompletedFuture; +import org.apache.gobblin.util.ConfigUtils; public class SimpleKafkaSpecExecutorInstance extends AbstractIdleService implements SpecExecutorInstance { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/service/SimpleKafkaSpecExecutorInstanceConsumer.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/service/SimpleKafkaSpecExecutorInstanceConsumer.java b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/service/SimpleKafkaSpecExecutorInstanceConsumer.java index a3eb851..90960e7 100644 --- a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/service/SimpleKafkaSpecExecutorInstanceConsumer.java +++ b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/service/SimpleKafkaSpecExecutorInstanceConsumer.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.service; +package org.apache.gobblin.service; import java.io.ByteArrayInputStream; import java.io.Closeable; @@ -43,21 +43,21 @@ import com.google.common.base.Optional; import com.google.common.collect.Lists; import com.typesafe.config.Config; -import gobblin.kafka.client.ByteArrayBasedKafkaRecord; -import gobblin.kafka.client.DecodeableKafkaRecord; -import gobblin.kafka.client.GobblinKafkaConsumerClient; -import gobblin.kafka.client.Kafka08ConsumerClient; -import gobblin.kafka.client.KafkaConsumerRecord; -import gobblin.metrics.reporter.util.FixedSchemaVersionWriter; -import gobblin.metrics.reporter.util.SchemaVersionWriter; -import gobblin.runtime.api.JobSpec; -import gobblin.runtime.api.Spec; -import gobblin.runtime.api.SpecExecutorInstanceConsumer; -import gobblin.runtime.job_spec.AvroJobSpec; -import gobblin.source.extractor.extract.kafka.KafkaOffsetRetrievalFailureException; -import gobblin.source.extractor.extract.kafka.KafkaPartition; -import gobblin.source.extractor.extract.kafka.KafkaTopic; -import gobblin.util.CompletedFuture; +import org.apache.gobblin.kafka.client.ByteArrayBasedKafkaRecord; +import org.apache.gobblin.kafka.client.DecodeableKafkaRecord; +import org.apache.gobblin.kafka.client.GobblinKafkaConsumerClient; +import org.apache.gobblin.kafka.client.Kafka08ConsumerClient; +import org.apache.gobblin.kafka.client.KafkaConsumerRecord; +import org.apache.gobblin.metrics.reporter.util.FixedSchemaVersionWriter; +import org.apache.gobblin.metrics.reporter.util.SchemaVersionWriter; +import org.apache.gobblin.runtime.api.JobSpec; +import org.apache.gobblin.runtime.api.Spec; +import org.apache.gobblin.runtime.api.SpecExecutorInstanceConsumer; +import org.apache.gobblin.runtime.job_spec.AvroJobSpec; +import org.apache.gobblin.source.extractor.extract.kafka.KafkaOffsetRetrievalFailureException; +import org.apache.gobblin.source.extractor.extract.kafka.KafkaPartition; +import org.apache.gobblin.source.extractor.extract.kafka.KafkaTopic; +import org.apache.gobblin.util.CompletedFuture; public class SimpleKafkaSpecExecutorInstanceConsumer extends SimpleKafkaSpecExecutorInstance implements SpecExecutorInstanceConsumer, Closeable { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/service/SimpleKafkaSpecExecutorInstanceProducer.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/service/SimpleKafkaSpecExecutorInstanceProducer.java b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/service/SimpleKafkaSpecExecutorInstanceProducer.java index 40851c3..cdafe06 100644 --- a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/service/SimpleKafkaSpecExecutorInstanceProducer.java +++ b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/service/SimpleKafkaSpecExecutorInstanceProducer.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.service; +package org.apache.gobblin.service; import java.io.Closeable; import java.io.IOException; @@ -33,16 +33,16 @@ import com.google.common.collect.ImmutableMap; import com.google.common.collect.Maps; import com.typesafe.config.Config; -import gobblin.kafka.writer.Kafka08DataWriter; -import gobblin.metrics.reporter.util.AvroBinarySerializer; -import gobblin.metrics.reporter.util.AvroSerializer; -import gobblin.metrics.reporter.util.FixedSchemaVersionWriter; -import gobblin.runtime.api.JobSpec; -import gobblin.runtime.api.Spec; -import gobblin.runtime.api.SpecExecutorInstanceProducer; -import gobblin.runtime.job_spec.AvroJobSpec; -import gobblin.util.ConfigUtils; -import gobblin.writer.WriteCallback; +import org.apache.gobblin.kafka.writer.Kafka08DataWriter; +import org.apache.gobblin.metrics.reporter.util.AvroBinarySerializer; +import org.apache.gobblin.metrics.reporter.util.AvroSerializer; +import org.apache.gobblin.metrics.reporter.util.FixedSchemaVersionWriter; +import org.apache.gobblin.runtime.api.JobSpec; +import org.apache.gobblin.runtime.api.Spec; +import org.apache.gobblin.runtime.api.SpecExecutorInstanceProducer; +import org.apache.gobblin.runtime.job_spec.AvroJobSpec; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.writer.WriteCallback; @NotThreadSafe http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/service/StreamingKafkaSpecExecutorInstanceConsumer.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/service/StreamingKafkaSpecExecutorInstanceConsumer.java b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/service/StreamingKafkaSpecExecutorInstanceConsumer.java index 50df00c..ac7fe03 100644 --- a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/service/StreamingKafkaSpecExecutorInstanceConsumer.java +++ b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/service/StreamingKafkaSpecExecutorInstanceConsumer.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.service; +package org.apache.gobblin.service; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.util.ConfigUtils; import java.io.Closeable; import java.io.IOException; import java.net.URI; @@ -37,14 +37,14 @@ import com.google.common.collect.ImmutableMap; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.runtime.api.JobSpec; -import gobblin.runtime.api.MutableJobCatalog; -import gobblin.runtime.api.Spec; -import gobblin.runtime.api.SpecExecutorInstanceConsumer; -import gobblin.runtime.job_monitor.AvroJobSpecKafkaJobMonitor; -import gobblin.runtime.job_monitor.KafkaJobMonitor; -import gobblin.runtime.std.DefaultJobCatalogListenerImpl; -import gobblin.util.CompletedFuture; +import org.apache.gobblin.runtime.api.JobSpec; +import org.apache.gobblin.runtime.api.MutableJobCatalog; +import org.apache.gobblin.runtime.api.Spec; +import org.apache.gobblin.runtime.api.SpecExecutorInstanceConsumer; +import org.apache.gobblin.runtime.job_monitor.AvroJobSpecKafkaJobMonitor; +import org.apache.gobblin.runtime.job_monitor.KafkaJobMonitor; +import org.apache.gobblin.runtime.std.DefaultJobCatalogListenerImpl; +import org.apache.gobblin.util.CompletedFuture; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaDeserializerExtractor.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaDeserializerExtractor.java b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaDeserializerExtractor.java index 950485b..74eafa8 100644 --- a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaDeserializerExtractor.java +++ b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaDeserializerExtractor.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor.extract.kafka; +package org.apache.gobblin.source.extractor.extract.kafka; import io.confluent.kafka.serializers.KafkaAvroDeserializer; import io.confluent.kafka.serializers.KafkaJsonDeserializer; @@ -39,13 +39,13 @@ import com.google.common.base.Enums; import com.google.common.base.Optional; import com.google.common.base.Preconditions; -import gobblin.annotation.Alias; -import gobblin.configuration.WorkUnitState; -import gobblin.kafka.client.ByteArrayBasedKafkaRecord; -import gobblin.metrics.kafka.KafkaSchemaRegistry; -import gobblin.metrics.kafka.SchemaRegistryException; -import gobblin.util.AvroUtils; -import gobblin.util.PropertiesUtils; +import org.apache.gobblin.annotation.Alias; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.kafka.client.ByteArrayBasedKafkaRecord; +import org.apache.gobblin.metrics.kafka.KafkaSchemaRegistry; +import org.apache.gobblin.metrics.kafka.SchemaRegistryException; +import org.apache.gobblin.util.AvroUtils; +import org.apache.gobblin.util.PropertiesUtils; /** @@ -80,18 +80,18 @@ public class KafkaDeserializerExtractor extends KafkaExtractor { private final Deserializer kafkaDeserializer; private final KafkaSchemaRegistry kafkaSchemaRegistry; private final Schema latestSchema; - + public KafkaDeserializerExtractor(WorkUnitState state) throws ReflectiveOperationException { this(state, getDeserializerType(state.getProperties())); } private KafkaDeserializerExtractor(WorkUnitState state, Optional deserializerType) throws ReflectiveOperationException { - this(state, deserializerType, + this(state, deserializerType, getDeserializer(getProps(state), deserializerType), getKafkaSchemaRegistry(getProps(state))); } - + @VisibleForTesting KafkaDeserializerExtractor(WorkUnitState state, Optional deserializerType, Deserializer kafkaDeserializer, KafkaSchemaRegistry kafkaSchemaRegistry) { @@ -105,7 +105,7 @@ public class KafkaDeserializerExtractor extends KafkaExtractor { @Override protected Object decodeRecord(ByteArrayBasedKafkaRecord messageAndOffset) throws IOException { Object deserialized = kafkaDeserializer.deserialize(this.topicName, messageAndOffset.getMessageBytes()); - + // For Confluent's Schema Registry the read schema is the latest registered schema to support schema evolution return (this.latestSchema == null) ? deserialized : AvroUtils.convertRecordSchema((GenericRecord) deserialized, this.latestSchema); @@ -119,13 +119,13 @@ public class KafkaDeserializerExtractor extends KafkaExtractor { throw new RuntimeException(e); } } - + private static Optional getDeserializerType(Properties props) { Preconditions.checkArgument(props.containsKey(KAFKA_DESERIALIZER_TYPE), "Missing required property " + KAFKA_DESERIALIZER_TYPE); return Enums.getIfPresent(Deserializers.class, props.getProperty(KAFKA_DESERIALIZER_TYPE).toUpperCase()); } - + /** * Constructs a {@link Deserializer}, using the value of {@link #KAFKA_DESERIALIZER_TYPE}. */ http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaDeserializerSource.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaDeserializerSource.java b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaDeserializerSource.java index d18ebcd..2abeb28 100644 --- a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaDeserializerSource.java +++ b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaDeserializerSource.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package gobblin.source.extractor.extract.kafka; +package org.apache.gobblin.source.extractor.extract.kafka; import java.io.IOException; -import gobblin.configuration.WorkUnitState; -import gobblin.source.extractor.Extractor; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.source.extractor.Extractor; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaGsonDeserializer.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaGsonDeserializer.java b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaGsonDeserializer.java index ca35494..e297d96 100644 --- a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaGsonDeserializer.java +++ b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaGsonDeserializer.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor.extract.kafka; +package org.apache.gobblin.source.extractor.extract.kafka; import java.nio.charset.Charset; import java.nio.charset.StandardCharsets; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaWrapper.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaWrapper.java b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaWrapper.java index f3dd45d..201dbef 100644 --- a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaWrapper.java +++ b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaWrapper.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor.extract.kafka; +package org.apache.gobblin.source.extractor.extract.kafka; import java.io.Closeable; import java.io.IOException; @@ -39,11 +39,11 @@ import com.google.common.net.HostAndPort; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.kafka.client.GobblinKafkaConsumerClient; -import gobblin.util.ConfigUtils; -import gobblin.util.DatasetFilterUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.kafka.client.GobblinKafkaConsumerClient; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.util.DatasetFilterUtils; import kafka.api.PartitionFetchInfo; import kafka.api.PartitionOffsetRequestInfo; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/test/java/StandaloneTestKafkaServer.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/test/java/StandaloneTestKafkaServer.java b/gobblin-modules/gobblin-kafka-08/src/test/java/StandaloneTestKafkaServer.java index 269cb1b..e12ddd4 100644 --- a/gobblin-modules/gobblin-kafka-08/src/test/java/StandaloneTestKafkaServer.java +++ b/gobblin-modules/gobblin-kafka-08/src/test/java/StandaloneTestKafkaServer.java @@ -17,7 +17,7 @@ import lombok.extern.slf4j.Slf4j; -import gobblin.kafka.KafkaTestBase; +import org.apache.gobblin.kafka.KafkaTestBase; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/kafka/FlakyKafkaProducer.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/kafka/FlakyKafkaProducer.java b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/kafka/FlakyKafkaProducer.java index e1a4082..013511b 100644 --- a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/kafka/FlakyKafkaProducer.java +++ b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/kafka/FlakyKafkaProducer.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.kafka; +package org.apache.gobblin.kafka; import java.util.Properties; import java.util.concurrent.Callable; @@ -34,7 +34,7 @@ import org.apache.kafka.clients.producer.RecordMetadata; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.test.ErrorManager; +import org.apache.gobblin.test.ErrorManager; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/kafka/KafkaTestBase.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/kafka/KafkaTestBase.java b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/kafka/KafkaTestBase.java index e306320..a89f29c 100644 --- a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/kafka/KafkaTestBase.java +++ b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/kafka/KafkaTestBase.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.kafka; +package org.apache.gobblin.kafka; import java.io.Closeable; import java.io.IOException; @@ -44,7 +44,7 @@ import kafka.utils.ZKStringSerializer$; import kafka.zk.EmbeddedZookeeper; import lombok.extern.slf4j.Slf4j; -import gobblin.test.TestUtils; +import org.apache.gobblin.test.TestUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/kafka/writer/Kafka08DataWriterIntegrationTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/kafka/writer/Kafka08DataWriterIntegrationTest.java b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/kafka/writer/Kafka08DataWriterIntegrationTest.java index a488c17..3db88eb 100644 --- a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/kafka/writer/Kafka08DataWriterIntegrationTest.java +++ b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/kafka/writer/Kafka08DataWriterIntegrationTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.kafka.writer; +package org.apache.gobblin.kafka.writer; import java.io.File; import java.io.FileReader; @@ -35,9 +35,9 @@ import org.testng.Assert; import kafka.consumer.ConsumerIterator; import lombok.extern.slf4j.Slf4j; -import gobblin.kafka.KafkaTestBase; -import gobblin.runtime.JobLauncher; -import gobblin.runtime.JobLauncherFactory; +import org.apache.gobblin.kafka.KafkaTestBase; +import org.apache.gobblin.runtime.JobLauncher; +import org.apache.gobblin.runtime.JobLauncherFactory; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/kafka/writer/Kafka08DataWriterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/kafka/writer/Kafka08DataWriterTest.java b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/kafka/writer/Kafka08DataWriterTest.java index 6c996e8..900e0be 100644 --- a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/kafka/writer/Kafka08DataWriterTest.java +++ b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/kafka/writer/Kafka08DataWriterTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.kafka.writer; +package org.apache.gobblin.kafka.writer; import java.io.IOException; import java.lang.management.ManagementFactory; @@ -30,15 +30,15 @@ import org.testng.annotations.Test; import lombok.extern.slf4j.Slf4j; -import gobblin.kafka.KafkaTestBase; -import gobblin.kafka.schemareg.ConfigDrivenMd5SchemaRegistry; -import gobblin.kafka.schemareg.KafkaSchemaRegistryConfigurationKeys; -import gobblin.kafka.schemareg.SchemaRegistryException; -import gobblin.kafka.serialize.LiAvroDeserializer; -import gobblin.kafka.serialize.LiAvroDeserializerBase; -import gobblin.test.TestUtils; -import gobblin.writer.WriteCallback; -import gobblin.writer.WriteResponse; +import org.apache.gobblin.kafka.KafkaTestBase; +import org.apache.gobblin.kafka.schemareg.ConfigDrivenMd5SchemaRegistry; +import org.apache.gobblin.kafka.schemareg.KafkaSchemaRegistryConfigurationKeys; +import org.apache.gobblin.kafka.schemareg.SchemaRegistryException; +import org.apache.gobblin.kafka.serialize.LiAvroDeserializer; +import org.apache.gobblin.kafka.serialize.LiAvroDeserializerBase; +import org.apache.gobblin.test.TestUtils; +import org.apache.gobblin.writer.WriteCallback; +import org.apache.gobblin.writer.WriteResponse; import static org.mockito.Mockito.*; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/kafka/writer/Kafka08DataWriterUnitTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/kafka/writer/Kafka08DataWriterUnitTest.java b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/kafka/writer/Kafka08DataWriterUnitTest.java index fdc5bcb..c31f178 100644 --- a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/kafka/writer/Kafka08DataWriterUnitTest.java +++ b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/kafka/writer/Kafka08DataWriterUnitTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.kafka.writer; +package org.apache.gobblin.kafka.writer; import java.util.Properties;