gobblin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a...@apache.org
Subject [16/77] [abbrv] incubator-gobblin git commit: Updated package names, imports and shell scripts
Date Mon, 31 Jul 2017 07:52:34 GMT
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<D> implements AsyncDataWriter<D> {
     log.debug("Close called");
     this.producer.close();
   }
-  
-  
+
+
 
   @Override
   public Future<WriteResponse> 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<Spec>, 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<Object, Object> {
   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<Deserializers> deserializerType)
       throws ReflectiveOperationException {
-    this(state, deserializerType, 
+    this(state, deserializerType,
         getDeserializer(getProps(state), deserializerType),
         getKafkaSchemaRegistry(getProps(state)));
   }
-  
+
   @VisibleForTesting
   KafkaDeserializerExtractor(WorkUnitState state, Optional<Deserializers> deserializerType,
       Deserializer<?> kafkaDeserializer, KafkaSchemaRegistry<?, ?> kafkaSchemaRegistry) {
@@ -105,7 +105,7 @@ public class KafkaDeserializerExtractor extends KafkaExtractor<Object, Object> {
   @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<Object, Object> {
       throw new RuntimeException(e);
     }
   }
-  
+
   private static Optional<Deserializers> 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;
 


Mime
View raw message