gobblin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a...@apache.org
Subject [28/77] [abbrv] incubator-gobblin git commit: Updated package names, imports and shell scripts
Date Mon, 31 Jul 2017 07:52:46 GMT
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/PartitionedDataWriter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/PartitionedDataWriter.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/PartitionedDataWriter.java
index f5cb017..d915730 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/PartitionedDataWriter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/PartitionedDataWriter.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 import java.io.IOException;
 import java.util.Map;
@@ -36,18 +36,18 @@ import com.google.common.io.Closer;
 
 import lombok.extern.slf4j.Slf4j;
 
-import gobblin.commit.SpeculativeAttemptAwareConstruct;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.instrumented.writer.InstrumentedDataWriterDecorator;
-import gobblin.instrumented.writer.InstrumentedPartitionedDataWriterDecorator;
-import gobblin.records.ControlMessageHandler;
-import gobblin.source.extractor.CheckpointableWatermark;
-import gobblin.stream.ControlMessage;
-import gobblin.stream.RecordEnvelope;
-import gobblin.util.AvroUtils;
-import gobblin.util.FinalState;
-import gobblin.writer.partitioner.WriterPartitioner;
+import org.apache.gobblin.commit.SpeculativeAttemptAwareConstruct;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.instrumented.writer.InstrumentedDataWriterDecorator;
+import org.apache.gobblin.instrumented.writer.InstrumentedPartitionedDataWriterDecorator;
+import org.apache.gobblin.records.ControlMessageHandler;
+import org.apache.gobblin.source.extractor.CheckpointableWatermark;
+import org.apache.gobblin.stream.ControlMessage;
+import org.apache.gobblin.stream.RecordEnvelope;
+import org.apache.gobblin.util.AvroUtils;
+import org.apache.gobblin.util.FinalState;
+import org.apache.gobblin.writer.partitioner.WriterPartitioner;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/Retriable.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/Retriable.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/Retriable.java
index 091e3e1..0a6a88d 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/Retriable.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/Retriable.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 import com.github.rholder.retry.RetryerBuilder;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/RetryWriter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/RetryWriter.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/RetryWriter.java
index 2fc24b9..2c04003 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/RetryWriter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/RetryWriter.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 import java.io.IOException;
 import java.util.concurrent.Callable;
@@ -35,14 +35,14 @@ import com.github.rholder.retry.WaitStrategies;
 import com.google.common.base.Optional;
 import com.google.common.base.Predicate;
 
-import gobblin.commit.SpeculativeAttemptAwareConstruct;
-import gobblin.configuration.State;
-import gobblin.instrumented.Instrumented;
-import gobblin.metrics.GobblinMetrics;
-import gobblin.records.ControlMessageHandler;
-import gobblin.stream.RecordEnvelope;
-import gobblin.util.FinalState;
-import gobblin.writer.exception.NonTransientException;
+import org.apache.gobblin.commit.SpeculativeAttemptAwareConstruct;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.instrumented.Instrumented;
+import org.apache.gobblin.metrics.GobblinMetrics;
+import org.apache.gobblin.records.ControlMessageHandler;
+import org.apache.gobblin.stream.RecordEnvelope;
+import org.apache.gobblin.util.FinalState;
+import org.apache.gobblin.writer.exception.NonTransientException;
 
 /**
  * Retry writer follows decorator pattern that retries on inner writer's failure.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/SchemaBasedPartitionedDataWriterBuilder.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/SchemaBasedPartitionedDataWriterBuilder.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/SchemaBasedPartitionedDataWriterBuilder.java
index 542db50..878d189 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/SchemaBasedPartitionedDataWriterBuilder.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/SchemaBasedPartitionedDataWriterBuilder.java
@@ -15,12 +15,12 @@
  * limitations under the License.
  */
 
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 import org.apache.avro.Schema;
 import org.apache.hadoop.fs.Path;
-import gobblin.configuration.State;
-import gobblin.writer.partitioner.SchemaBasedWriterPartitioner;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.writer.partitioner.SchemaBasedWriterPartitioner;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/SimpleDataWriter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/SimpleDataWriter.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/SimpleDataWriter.java
index ca3d1d8..4a96904 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/SimpleDataWriter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/SimpleDataWriter.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 import java.io.IOException;
 import java.io.OutputStream;
@@ -29,8 +29,8 @@ import com.google.common.base.Optional;
 import com.google.common.base.Preconditions;
 import com.google.common.primitives.Longs;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/SimpleDataWriterBuilder.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/SimpleDataWriterBuilder.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/SimpleDataWriterBuilder.java
index 82043e1..c81daa7 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/SimpleDataWriterBuilder.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/SimpleDataWriterBuilder.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 import java.io.IOException;
 import java.util.ArrayList;
@@ -24,11 +24,11 @@ import java.util.Map;
 
 import com.google.common.base.Preconditions;
 
-import gobblin.codec.StreamCodec;
-import gobblin.compression.CompressionConfigParser;
-import gobblin.compression.CompressionFactory;
-import gobblin.crypto.EncryptionConfigParser;
-import gobblin.crypto.EncryptionFactory;
+import org.apache.gobblin.codec.StreamCodec;
+import org.apache.gobblin.compression.CompressionConfigParser;
+import org.apache.gobblin.compression.CompressionFactory;
+import org.apache.gobblin.crypto.EncryptionConfigParser;
+import org.apache.gobblin.crypto.EncryptionFactory;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/ThrottleWriter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/ThrottleWriter.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/ThrottleWriter.java
index da19663..eccd69f 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/ThrottleWriter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/ThrottleWriter.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 import java.io.IOException;
 import java.util.concurrent.TimeUnit;
@@ -27,15 +27,15 @@ import com.github.rholder.retry.RetryerBuilder;
 import com.google.common.base.Optional;
 import com.google.common.base.Preconditions;
 
-import gobblin.stream.RecordEnvelope;
-import gobblin.util.Decorator;
-import gobblin.util.limiter.Limiter;
-import gobblin.util.limiter.RateBasedLimiter;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.instrumented.Instrumented;
-import gobblin.metrics.GobblinMetrics;
-import gobblin.util.FinalState;
+import org.apache.gobblin.stream.RecordEnvelope;
+import org.apache.gobblin.util.Decorator;
+import org.apache.gobblin.util.limiter.Limiter;
+import org.apache.gobblin.util.limiter.RateBasedLimiter;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.instrumented.Instrumented;
+import org.apache.gobblin.metrics.GobblinMetrics;
+import org.apache.gobblin.util.FinalState;
 
 /**
  * Throttle writer follows decorator pattern that throttles inner writer by either QPS or by bytes.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/http/AbstractHttpWriter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/AbstractHttpWriter.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/AbstractHttpWriter.java
index 3a339e3..1e2e086 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/AbstractHttpWriter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/AbstractHttpWriter.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.writer.http;
+package org.apache.gobblin.writer.http;
 
 import java.io.IOException;
 import java.net.URI;
@@ -41,8 +41,8 @@ import com.google.common.util.concurrent.ListenableFuture;
 import com.google.common.util.concurrent.ListeningExecutorService;
 import com.google.common.util.concurrent.MoreExecutors;
 
-import gobblin.instrumented.writer.InstrumentedDataWriter;
-import gobblin.util.ExecutorsUtils;
+import org.apache.gobblin.instrumented.writer.InstrumentedDataWriter;
+import org.apache.gobblin.util.ExecutorsUtils;
 
 /**
  * Base class for HTTP writers. Defines the main extension points for different implementations.
@@ -103,7 +103,7 @@ public abstract class AbstractHttpWriter<D> extends InstrumentedDataWriter<D> im
     this.client.close();
     ExecutorsUtils.shutdownExecutorService(this.singleThreadPool, Optional.of(log));
   }
- 
+
   /**
    * {@inheritDoc}
    */
@@ -112,7 +112,7 @@ public abstract class AbstractHttpWriter<D> extends InstrumentedDataWriter<D> im
     cleanup();
     super.close();
   }
-  
+
   /**
    * {@inheritDoc}
    */

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/http/AbstractHttpWriterBuilder.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/AbstractHttpWriterBuilder.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/AbstractHttpWriterBuilder.java
index 2bd9ade..db6d63b 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/AbstractHttpWriterBuilder.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/AbstractHttpWriterBuilder.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.writer.http;
+package org.apache.gobblin.writer.http;
 
 import java.net.URI;
 import java.net.URISyntaxException;
@@ -34,11 +34,11 @@ import com.google.common.collect.ImmutableMap;
 import com.typesafe.config.Config;
 import com.typesafe.config.ConfigFactory;
 
-import gobblin.config.ConfigBuilder;
-import gobblin.configuration.State;
-import gobblin.http.HttpClientConfiguratorLoader;
-import gobblin.writer.Destination;
-import gobblin.writer.FluentDataWriterBuilder;
+import org.apache.gobblin.config.ConfigBuilder;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.http.HttpClientConfiguratorLoader;
+import org.apache.gobblin.writer.Destination;
+import org.apache.gobblin.writer.FluentDataWriterBuilder;
 
 import lombok.Getter;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/http/DelegatingHttpClientConnectionManager.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/DelegatingHttpClientConnectionManager.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/DelegatingHttpClientConnectionManager.java
index 85c937d..d42ef9a 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/DelegatingHttpClientConnectionManager.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/DelegatingHttpClientConnectionManager.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.writer.http;
+package org.apache.gobblin.writer.http;
 
 import java.io.IOException;
 import java.util.concurrent.TimeUnit;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriter.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriter.java
index cce5f8a..644b052 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriter.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.writer.http;
+package org.apache.gobblin.writer.http;
 
 import java.io.IOException;
 import java.net.MalformedURLException;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriterBuilder.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriterBuilder.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriterBuilder.java
index 5593e21..efaff72 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriterBuilder.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriterBuilder.java
@@ -14,9 +14,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.writer.http;
+package org.apache.gobblin.writer.http;
 
-import gobblin.writer.DataWriter;
+import org.apache.gobblin.writer.DataWriter;
 
 import java.io.IOException;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriterDecoration.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriterDecoration.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriterDecoration.java
index e16cffc..8185d65 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriterDecoration.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriterDecoration.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.writer.http;
+package org.apache.gobblin.writer.http;
 
 import java.io.IOException;
 import java.net.URI;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriterDecorator.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriterDecorator.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriterDecorator.java
index dba2a1e..1531e13 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriterDecorator.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/HttpWriterDecorator.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.writer.http;
+package org.apache.gobblin.writer.http;
 
 import java.io.IOException;
 import java.net.URI;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestJsonWriter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestJsonWriter.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestJsonWriter.java
index dcad4c4..583e7aa 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestJsonWriter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestJsonWriter.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.writer.http;
+package org.apache.gobblin.writer.http;
 
 import org.apache.http.HttpHeaders;
 import org.apache.http.client.methods.HttpUriRequest;
@@ -25,7 +25,7 @@ import org.apache.http.entity.StringEntity;
 import com.google.common.base.Optional;
 import com.google.gson.JsonObject;
 
-import gobblin.converter.http.RestEntry;
+import org.apache.gobblin.converter.http.RestEntry;
 
 /**
  * Writes via Restful API that accepts JSON as a body

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestJsonWriterBuilder.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestJsonWriterBuilder.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestJsonWriterBuilder.java
index f42a3f2..c3e61fd 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestJsonWriterBuilder.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestJsonWriterBuilder.java
@@ -14,14 +14,14 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.writer.http;
+package org.apache.gobblin.writer.http;
 
 import java.io.IOException;
 
 import com.google.gson.JsonObject;
 
-import gobblin.converter.http.RestEntry;
-import gobblin.writer.DataWriter;
+import org.apache.gobblin.converter.http.RestEntry;
+import org.apache.gobblin.writer.DataWriter;
 
 /**
  * Builder that builds RestJsonWriter

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestWriter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestWriter.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestWriter.java
index e5e8385..3c49f09 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestWriter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestWriter.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.writer.http;
+package org.apache.gobblin.writer.http;
 
 import org.apache.http.HttpHeaders;
 import org.apache.http.client.methods.HttpUriRequest;
@@ -24,7 +24,7 @@ import org.apache.http.entity.StringEntity;
 
 import com.google.common.base.Optional;
 
-import gobblin.converter.http.RestEntry;
+import org.apache.gobblin.converter.http.RestEntry;
 
 /**
  * Writes via RESTful API that accepts plain text as a body and resource path from RestEntry

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestWriterBuilder.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestWriterBuilder.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestWriterBuilder.java
index 9d2b592..4a0c97b 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestWriterBuilder.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/RestWriterBuilder.java
@@ -14,12 +14,12 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.writer.http;
+package org.apache.gobblin.writer.http;
 
 import java.io.IOException;
 
-import gobblin.converter.http.RestEntry;
-import gobblin.writer.DataWriter;
+import org.apache.gobblin.converter.http.RestEntry;
+import org.apache.gobblin.writer.DataWriter;
 
 public class RestWriterBuilder extends AbstractHttpWriterBuilder<Void, RestEntry<String>, RestWriterBuilder> {
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/http/SalesForceRestWriterBuilder.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/SalesForceRestWriterBuilder.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/SalesForceRestWriterBuilder.java
index 652f63e..c0ed056 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/SalesForceRestWriterBuilder.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/SalesForceRestWriterBuilder.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.writer.http;
+package org.apache.gobblin.writer.http;
 
 import java.io.IOException;
 import java.util.Properties;
@@ -26,11 +26,11 @@ import com.google.gson.JsonObject;
 import com.typesafe.config.Config;
 import com.typesafe.config.ConfigFactory;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.converter.http.RestEntry;
-import gobblin.password.PasswordManager;
-import gobblin.writer.DataWriter;
-import gobblin.writer.http.SalesforceRestWriter.Operation;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.converter.http.RestEntry;
+import org.apache.gobblin.password.PasswordManager;
+import org.apache.gobblin.writer.DataWriter;
+import org.apache.gobblin.writer.http.SalesforceRestWriter.Operation;
 
 import lombok.AccessLevel;
 import lombok.Getter;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/http/SalesforceRestWriter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/SalesforceRestWriter.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/SalesforceRestWriter.java
index 8c55b38..239b38d 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/SalesforceRestWriter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/SalesforceRestWriter.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.writer.http;
+package org.apache.gobblin.writer.http;
 
 import java.io.IOException;
 import java.net.URI;
@@ -47,8 +47,8 @@ import com.google.gson.JsonElement;
 import com.google.gson.JsonObject;
 import com.google.gson.JsonParser;
 
-import gobblin.converter.http.RestEntry;
-import gobblin.writer.exception.NonTransientException;
+import org.apache.gobblin.converter.http.RestEntry;
+import org.apache.gobblin.writer.exception.NonTransientException;
 
 /**
  * Writes to Salesforce via RESTful API, supporting INSERT_ONLY_NOT_EXIST, and UPSERT.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/http/UnexpectedResponseException.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/UnexpectedResponseException.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/UnexpectedResponseException.java
index cd93221..36e10ca 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/http/UnexpectedResponseException.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/http/UnexpectedResponseException.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.writer.http;
+package org.apache.gobblin.writer.http;
 
 import java.io.IOException;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/initializer/MultiWriterInitializer.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/initializer/MultiWriterInitializer.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/initializer/MultiWriterInitializer.java
index 30ad36e..7b3ba3e 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/initializer/MultiWriterInitializer.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/initializer/MultiWriterInitializer.java
@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package gobblin.writer.initializer;
+package org.apache.gobblin.writer.initializer;
 
-import gobblin.initializer.Initializer;
-import gobblin.initializer.MultiInitializer;
+import org.apache.gobblin.initializer.Initializer;
+import org.apache.gobblin.initializer.MultiInitializer;
 
 import java.util.List;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/initializer/WriterInitializerFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/initializer/WriterInitializerFactory.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/initializer/WriterInitializerFactory.java
index bb725cc..8585cb2 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/initializer/WriterInitializerFactory.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/initializer/WriterInitializerFactory.java
@@ -15,13 +15,13 @@
  * limitations under the License.
  */
 
-package gobblin.writer.initializer;
+package org.apache.gobblin.writer.initializer;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.source.workunit.WorkUnitStream;
-import gobblin.util.ForkOperatorUtils;
-import gobblin.writer.DataWriterBuilder;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.source.workunit.WorkUnitStream;
+import org.apache.gobblin.util.ForkOperatorUtils;
+import org.apache.gobblin.writer.DataWriterBuilder;
 
 import java.util.List;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreClient.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreClient.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreClient.java
index b5b071a..56601bb 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreClient.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreClient.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.writer.objectstore;
+package org.apache.gobblin.writer.objectstore;
 
 import java.io.IOException;
 import java.io.InputStream;
@@ -23,8 +23,8 @@ import javax.annotation.Nonnull;
 
 import com.typesafe.config.Config;
 
-import gobblin.annotation.Alpha;
-import gobblin.writer.objectstore.response.GetObjectResponse;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.writer.objectstore.response.GetObjectResponse;
 
 /**
  * A client interface to interact with an object store. Supports basic operations like put,delete and get.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreDeleteOperation.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreDeleteOperation.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreDeleteOperation.java
index d1a7a75..f20d067 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreDeleteOperation.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreDeleteOperation.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.writer.objectstore;
+package org.apache.gobblin.writer.objectstore;
 
 import java.io.IOException;
 
@@ -28,8 +28,8 @@ import com.google.common.base.Preconditions;
 import com.typesafe.config.Config;
 import com.typesafe.config.ConfigFactory;
 
-import gobblin.annotation.Alpha;
-import gobblin.writer.objectstore.response.DeleteResponse;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.writer.objectstore.response.DeleteResponse;
 
 /**
  * An {@link ObjectStoreOperation} that deletes an object with <code>objectId</code> in the object store.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreOperation.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreOperation.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreOperation.java
index a250754..8ddea35 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreOperation.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreOperation.java
@@ -14,12 +14,12 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.writer.objectstore;
+package org.apache.gobblin.writer.objectstore;
 
 import java.io.IOException;
 
-import gobblin.annotation.Alpha;
-import gobblin.converter.objectstore.ObjectStoreConverter;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.converter.objectstore.ObjectStoreConverter;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreOperationBuilder.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreOperationBuilder.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreOperationBuilder.java
index 71dd996..80ab72b 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreOperationBuilder.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreOperationBuilder.java
@@ -14,9 +14,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.writer.objectstore;
+package org.apache.gobblin.writer.objectstore;
 
-import gobblin.annotation.Alpha;
+import org.apache.gobblin.annotation.Alpha;
 
 /**
  * Builder to build all types of {@link ObjectStoreOperation}s

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreWriter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreWriter.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreWriter.java
index f6cd07c..26e6fa7 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreWriter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/ObjectStoreWriter.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.writer.objectstore;
+package org.apache.gobblin.writer.objectstore;
 
 import java.io.IOException;
 
@@ -22,9 +22,9 @@ import lombok.Getter;
 
 import com.codahale.metrics.Counter;
 
-import gobblin.annotation.Alpha;
-import gobblin.configuration.State;
-import gobblin.instrumented.writer.InstrumentedDataWriter;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.instrumented.writer.InstrumentedDataWriter;
 
 /**
  * A writer to execute operations on a object in any object store. The record type of this writer is an {@link ObjectStoreOperation}.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/response/DeleteResponse.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/response/DeleteResponse.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/response/DeleteResponse.java
index a143600..5290a81 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/response/DeleteResponse.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/response/DeleteResponse.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.writer.objectstore.response;
+package org.apache.gobblin.writer.objectstore.response;
 
 import lombok.AllArgsConstructor;
 import lombok.Getter;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/response/GetObjectResponse.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/response/GetObjectResponse.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/response/GetObjectResponse.java
index 15b7c41..93ba4e4 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/response/GetObjectResponse.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/objectstore/response/GetObjectResponse.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.writer.objectstore.response;
+package org.apache.gobblin.writer.objectstore.response;
 
 import java.io.InputStream;
 
@@ -23,7 +23,7 @@ import lombok.Getter;
 
 import com.typesafe.config.Config;
 
-import gobblin.writer.objectstore.ObjectStoreClient;
+import org.apache.gobblin.writer.objectstore.ObjectStoreClient;
 
 /**
  * The response of {@link ObjectStoreClient#getObject(String)} that holds an {@link InputStream} to the object and object

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/SchemaBasedWriterPartitioner.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/SchemaBasedWriterPartitioner.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/SchemaBasedWriterPartitioner.java
index 9993056..cbd494c 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/SchemaBasedWriterPartitioner.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/SchemaBasedWriterPartitioner.java
@@ -15,13 +15,13 @@
  * limitations under the License.
  */
 
-package gobblin.writer.partitioner;
+package org.apache.gobblin.writer.partitioner;
 
 import org.apache.avro.Schema;
 import org.apache.avro.SchemaBuilder;
 import org.apache.avro.generic.GenericData;
 import org.apache.avro.generic.GenericRecord;
-import gobblin.configuration.State;
+import org.apache.gobblin.configuration.State;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/TimeBasedAvroWriterPartitioner.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/TimeBasedAvroWriterPartitioner.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/TimeBasedAvroWriterPartitioner.java
index 20109d2..54e5abc 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/TimeBasedAvroWriterPartitioner.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/TimeBasedAvroWriterPartitioner.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.writer.partitioner;
+package org.apache.gobblin.writer.partitioner;
 
 import java.util.List;
 
@@ -23,10 +23,10 @@ import org.apache.avro.generic.GenericRecord;
 
 import com.google.common.base.Optional;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.util.AvroUtils;
-import gobblin.util.ForkOperatorUtils;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.util.AvroUtils;
+import org.apache.gobblin.util.ForkOperatorUtils;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/TimeBasedWriterPartitioner.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/TimeBasedWriterPartitioner.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/TimeBasedWriterPartitioner.java
index 30a2dae..cf35f1e 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/TimeBasedWriterPartitioner.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/TimeBasedWriterPartitioner.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.writer.partitioner;
+package org.apache.gobblin.writer.partitioner;
 
 import java.util.Collections;
 
@@ -35,10 +35,10 @@ import com.google.common.base.Optional;
 import com.google.common.base.Preconditions;
 import com.google.common.base.Strings;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.util.DatePartitionType;
-import gobblin.util.ForkOperatorUtils;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.util.DatePartitionType;
+import org.apache.gobblin.util.ForkOperatorUtils;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/WorkUnitStateWriterPartitioner.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/WorkUnitStateWriterPartitioner.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/WorkUnitStateWriterPartitioner.java
index 8d708f8..4c4241f 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/WorkUnitStateWriterPartitioner.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/WorkUnitStateWriterPartitioner.java
@@ -14,10 +14,10 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.writer.partitioner;
+package org.apache.gobblin.writer.partitioner;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/test/GobblinTestEventBusWriter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/test/GobblinTestEventBusWriter.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/test/GobblinTestEventBusWriter.java
index 358e768..e9a4acd 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/test/GobblinTestEventBusWriter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/test/GobblinTestEventBusWriter.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.writer.test;
+package org.apache.gobblin.writer.test;
 
 import java.io.IOException;
 import java.util.concurrent.atomic.AtomicLong;
@@ -22,12 +22,12 @@ import java.util.concurrent.atomic.AtomicLong;
 import com.google.common.base.Optional;
 import com.google.common.eventbus.EventBus;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.util.ForkOperatorUtils;
-import gobblin.util.WriterUtils;
-import gobblin.writer.DataWriter;
-import gobblin.writer.DataWriterBuilder;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.util.ForkOperatorUtils;
+import org.apache.gobblin.util.WriterUtils;
+import org.apache.gobblin.writer.DataWriter;
+import org.apache.gobblin.writer.DataWriterBuilder;
 
 import lombok.Data;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/test/TestingEventBusAsserter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/test/TestingEventBusAsserter.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/test/TestingEventBusAsserter.java
index bc0e624..8c299d0 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/test/TestingEventBusAsserter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/test/TestingEventBusAsserter.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.writer.test;
+package org.apache.gobblin.writer.test;
 
 import java.io.Closeable;
 import java.io.IOException;
@@ -34,7 +34,7 @@ import com.google.common.base.Predicates;
 import com.google.common.eventbus.EventBus;
 import com.google.common.eventbus.Subscribe;
 
-import gobblin.writer.test.TestingEventBuses.Event;
+import org.apache.gobblin.writer.test.TestingEventBuses.Event;
 
 import lombok.AllArgsConstructor;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/test/TestingEventBuses.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/test/TestingEventBuses.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/test/TestingEventBuses.java
index 54247bb..c12a44c 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/test/TestingEventBuses.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/test/TestingEventBuses.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.writer.test;
+package org.apache.gobblin.writer.test;
 
 import java.util.concurrent.ExecutionException;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/async/AsyncDataDispatcherTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/async/AsyncDataDispatcherTest.java b/gobblin-core/src/test/java/org/apache/gobblin/async/AsyncDataDispatcherTest.java
index 7ced0c1..d53effe 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/async/AsyncDataDispatcherTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/async/AsyncDataDispatcherTest.java
@@ -1,4 +1,4 @@
-package gobblin.async;
+package org.apache.gobblin.async;
 
 import java.util.Queue;
 import java.util.concurrent.Callable;
@@ -10,7 +10,7 @@ import java.util.concurrent.Future;
 import org.testng.Assert;
 import org.testng.annotations.Test;
 
-import gobblin.util.ExponentialBackoff;
+import org.apache.gobblin.util.ExponentialBackoff;
 
 
 @Test

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/commit/FsRenameCommitStepTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/commit/FsRenameCommitStepTest.java b/gobblin-core/src/test/java/org/apache/gobblin/commit/FsRenameCommitStepTest.java
index 4b33c76..e91bd99 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/commit/FsRenameCommitStepTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/commit/FsRenameCommitStepTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.commit;
+package org.apache.gobblin.commit;
 
 import java.io.IOException;
 
@@ -27,7 +27,7 @@ import org.testng.annotations.AfterClass;
 import org.testng.annotations.BeforeClass;
 import org.testng.annotations.Test;
 
-import gobblin.configuration.State;
+import org.apache.gobblin.configuration.State;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/configuration/StateTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/configuration/StateTest.java b/gobblin-core/src/test/java/org/apache/gobblin/configuration/StateTest.java
index ecb8241..5d54e85 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/configuration/StateTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/configuration/StateTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.configuration;
+package org.apache.gobblin.configuration;
 
 import java.io.ByteArrayInputStream;
 import java.io.ByteArrayOutputStream;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/configuration/WorkUnitStateTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/configuration/WorkUnitStateTest.java b/gobblin-core/src/test/java/org/apache/gobblin/configuration/WorkUnitStateTest.java
index cd7eb74..1285737 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/configuration/WorkUnitStateTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/configuration/WorkUnitStateTest.java
@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package gobblin.configuration;
+package org.apache.gobblin.configuration;
 
-import gobblin.source.workunit.Extract;
+import org.apache.gobblin.source.workunit.Extract;
 
 import java.io.ByteArrayInputStream;
 import java.io.ByteArrayOutputStream;
@@ -28,7 +28,7 @@ import java.io.IOException;
 import org.testng.Assert;
 import org.testng.annotations.Test;
 
-import gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.source.workunit.WorkUnit;
 
 
 public class WorkUnitStateTest {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/configuration/workunit/MultiWorkUnitTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/configuration/workunit/MultiWorkUnitTest.java b/gobblin-core/src/test/java/org/apache/gobblin/configuration/workunit/MultiWorkUnitTest.java
index 09d9429..22684b2 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/configuration/workunit/MultiWorkUnitTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/configuration/workunit/MultiWorkUnitTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.configuration.workunit;
+package org.apache.gobblin.configuration.workunit;
 
 import java.io.ByteArrayInputStream;
 import java.io.ByteArrayOutputStream;
@@ -30,8 +30,8 @@ import org.testng.annotations.Test;
 
 import com.google.common.io.Closer;
 
-import gobblin.source.workunit.MultiWorkUnit;
-import gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.source.workunit.MultiWorkUnit;
+import org.apache.gobblin.source.workunit.WorkUnit;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/converter/EmptyIterableTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/converter/EmptyIterableTest.java b/gobblin-core/src/test/java/org/apache/gobblin/converter/EmptyIterableTest.java
index b1ee227..0a36704 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/converter/EmptyIterableTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/converter/EmptyIterableTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.converter;
+package org.apache.gobblin.converter;
 
 import java.util.Iterator;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/converter/GobblinMetricsPinotFlattenerConverterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/converter/GobblinMetricsPinotFlattenerConverterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/converter/GobblinMetricsPinotFlattenerConverterTest.java
index aed63d3..bcb423a 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/converter/GobblinMetricsPinotFlattenerConverterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/converter/GobblinMetricsPinotFlattenerConverterTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.converter;
+package org.apache.gobblin.converter;
 
 import java.util.List;
 
@@ -29,13 +29,13 @@ import com.google.common.collect.ImmutableMap;
 import com.google.common.collect.Lists;
 import com.google.common.collect.Sets;
 
-import gobblin.configuration.WorkUnitState;
-import gobblin.metrics.Metric;
-import gobblin.metrics.MetricReport;
-import gobblin.metrics.reporter.util.AvroBinarySerializer;
-import gobblin.metrics.reporter.util.AvroSerializer;
-import gobblin.metrics.reporter.util.NoopSchemaVersionWriter;
-import gobblin.util.AvroUtils;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.metrics.Metric;
+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.NoopSchemaVersionWriter;
+import org.apache.gobblin.util.AvroUtils;
 
 public class GobblinMetricsPinotFlattenerConverterTest {
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/AvroToBytesConverterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/AvroToBytesConverterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/AvroToBytesConverterTest.java
index f832589..89f0e94 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/AvroToBytesConverterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/AvroToBytesConverterTest.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.converter.avro;
+package org.apache.gobblin.converter.avro;
 
 import java.io.IOException;
 import java.util.Iterator;
@@ -26,9 +26,9 @@ import org.apache.commons.io.IOUtils;
 import org.testng.Assert;
 import org.testng.annotations.Test;
 
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.SchemaConversionException;
 
 
 public class AvroToBytesConverterTest {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/BytesToAvroConverterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/BytesToAvroConverterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/BytesToAvroConverterTest.java
index 6c8da1b..bcea977 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/BytesToAvroConverterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/BytesToAvroConverterTest.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.converter.avro;
+package org.apache.gobblin.converter.avro;
 
 import java.io.IOException;
 import java.io.InputStream;
@@ -27,9 +27,9 @@ import org.apache.commons.io.IOUtils;
 import org.junit.Assert;
 import org.testng.annotations.Test;
 
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.SchemaConversionException;
 
 
 public class BytesToAvroConverterTest {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/FlattenNestedKeyConverterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/FlattenNestedKeyConverterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/FlattenNestedKeyConverterTest.java
index 11413da..e109548 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/FlattenNestedKeyConverterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/FlattenNestedKeyConverterTest.java
@@ -1,4 +1,4 @@
-package gobblin.converter.avro;
+package org.apache.gobblin.converter.avro;
 
 import java.io.File;
 import java.io.IOException;
@@ -13,10 +13,10 @@ import org.testng.annotations.Test;
 
 import junit.framework.Assert;
 
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.SchemaConversionException;
-import gobblin.util.AvroUtils;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.util.AvroUtils;
 
 
 @Test

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/JsonIntermediateToAvroConverterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/JsonIntermediateToAvroConverterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/JsonIntermediateToAvroConverterTest.java
index cac3c68..558c1f6 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/JsonIntermediateToAvroConverterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/converter/avro/JsonIntermediateToAvroConverterTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.converter.avro;
+package org.apache.gobblin.converter.avro;
 
 import java.io.InputStreamReader;
 import java.lang.reflect.Type;
@@ -38,10 +38,10 @@ import com.google.gson.Gson;
 import com.google.gson.JsonArray;
 import com.google.gson.JsonObject;
 import com.google.gson.reflect.TypeToken;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.SourceState;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.workunit.Extract.TableType;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.SourceState;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.workunit.Extract.TableType;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/converter/csv/CsvToJsonConverterV2Test.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/converter/csv/CsvToJsonConverterV2Test.java b/gobblin-core/src/test/java/org/apache/gobblin/converter/csv/CsvToJsonConverterV2Test.java
index 261c3a1..6d38f0d 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/converter/csv/CsvToJsonConverterV2Test.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/converter/csv/CsvToJsonConverterV2Test.java
@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package gobblin.converter.csv;
+package org.apache.gobblin.converter.csv;
 
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.DataConversionException;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.DataConversionException;
 
 import java.io.IOException;
 import java.io.InputStreamReader;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/converter/filter/AvroFieldsPickConverterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/converter/filter/AvroFieldsPickConverterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/converter/filter/AvroFieldsPickConverterTest.java
index 6f8c75b..009bcc7 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/converter/filter/AvroFieldsPickConverterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/converter/filter/AvroFieldsPickConverterTest.java
@@ -15,11 +15,11 @@
  * limitations under the License.
  */
 
-package gobblin.converter.filter;
+package org.apache.gobblin.converter.filter;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.SchemaConversionException;
 
 import org.apache.avro.Schema;
 import org.skyscreamer.jsonassert.JSONAssert;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/converter/http/AvroToRestJsonEntryConverterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/converter/http/AvroToRestJsonEntryConverterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/converter/http/AvroToRestJsonEntryConverterTest.java
index 44e7374..f5c5981 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/converter/http/AvroToRestJsonEntryConverterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/converter/http/AvroToRestJsonEntryConverterTest.java
@@ -14,13 +14,13 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.converter.http;
+package org.apache.gobblin.converter.http;
 
 import java.io.File;
 import java.io.IOException;
 
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.DataConversionException;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.DataConversionException;
 
 import org.apache.avro.Schema;
 import org.apache.avro.file.DataFileReader;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/converter/objectstore/ObjectStoreDeleteConverterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/converter/objectstore/ObjectStoreDeleteConverterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/converter/objectstore/ObjectStoreDeleteConverterTest.java
index 8e45847..c4e5034 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/converter/objectstore/ObjectStoreDeleteConverterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/converter/objectstore/ObjectStoreDeleteConverterTest.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.converter.objectstore;
+package org.apache.gobblin.converter.objectstore;
 
 import org.apache.avro.Schema;
 import org.apache.avro.generic.GenericData;
@@ -26,7 +26,7 @@ import com.google.common.collect.Iterables;
 import com.google.common.primitives.Ints;
 import com.google.common.primitives.Longs;
 
-import gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.configuration.WorkUnitState;
 
 
 public class ObjectStoreDeleteConverterTest {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/converter/string/ObjectToStringConverterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/converter/string/ObjectToStringConverterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/converter/string/ObjectToStringConverterTest.java
index c187b0b..f7995ce 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/converter/string/ObjectToStringConverterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/converter/string/ObjectToStringConverterTest.java
@@ -16,13 +16,13 @@
  * limitations under the License.
  */
 
-package gobblin.converter.string;
+package org.apache.gobblin.converter.string;
 
 import java.util.Iterator;
 
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.SchemaConversionException;
 
 import org.testng.Assert;
 import org.testng.annotations.Test;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/converter/string/StringFilterConverterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/converter/string/StringFilterConverterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/converter/string/StringFilterConverterTest.java
index 2c02868..9cf0332 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/converter/string/StringFilterConverterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/converter/string/StringFilterConverterTest.java
@@ -15,11 +15,11 @@
  * limitations under the License.
  */
 
-package gobblin.converter.string;
+package org.apache.gobblin.converter.string;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.DataConversionException;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.DataConversionException;
 
 import java.util.Iterator;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/converter/string/StringSplitterConverterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/converter/string/StringSplitterConverterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/converter/string/StringSplitterConverterTest.java
index 95d4354..7e732dc 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/converter/string/StringSplitterConverterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/converter/string/StringSplitterConverterTest.java
@@ -15,13 +15,13 @@
  * limitations under the License.
  */
 
-package gobblin.converter.string;
+package org.apache.gobblin.converter.string;
 
 import java.util.Iterator;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.DataConversionException;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.DataConversionException;
 
 import org.testng.Assert;
 import org.testng.annotations.Test;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/converter/string/StringSplitterToListConverterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/converter/string/StringSplitterToListConverterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/converter/string/StringSplitterToListConverterTest.java
index 3f33f46..03d2b3a 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/converter/string/StringSplitterToListConverterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/converter/string/StringSplitterToListConverterTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.converter.string;
+package org.apache.gobblin.converter.string;
 
 import java.util.Iterator;
 import java.util.List;
@@ -25,9 +25,9 @@ import org.testng.annotations.Test;
 
 import com.google.common.collect.Lists;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.DataConversionException;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.DataConversionException;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/converter/string/TextToStringConverterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/converter/string/TextToStringConverterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/converter/string/TextToStringConverterTest.java
index 8dc0c94..7db8373 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/converter/string/TextToStringConverterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/converter/string/TextToStringConverterTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.converter.string;
+package org.apache.gobblin.converter.string;
 
 import java.util.Iterator;
 
@@ -23,8 +23,8 @@ import org.apache.hadoop.io.Text;
 import org.testng.Assert;
 import org.testng.annotations.Test;
 
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.DataConversionException;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.DataConversionException;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/fork/CopyableGenericRecordTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/fork/CopyableGenericRecordTest.java b/gobblin-core/src/test/java/org/apache/gobblin/fork/CopyableGenericRecordTest.java
index d97fe46..3170633 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/fork/CopyableGenericRecordTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/fork/CopyableGenericRecordTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.fork;
+package org.apache.gobblin.fork;
 
 import java.util.Arrays;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/fork/CopyableSchemaTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/fork/CopyableSchemaTest.java b/gobblin-core/src/test/java/org/apache/gobblin/fork/CopyableSchemaTest.java
index eaaa264..700e7b2 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/fork/CopyableSchemaTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/fork/CopyableSchemaTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.fork;
+package org.apache.gobblin.fork;
 
 import org.apache.avro.Schema;
 import org.testng.Assert;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/fork/IdentityForkOperatorTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/fork/IdentityForkOperatorTest.java b/gobblin-core/src/test/java/org/apache/gobblin/fork/IdentityForkOperatorTest.java
index a3c5b8b..c9f042a 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/fork/IdentityForkOperatorTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/fork/IdentityForkOperatorTest.java
@@ -15,16 +15,16 @@
  * limitations under the License.
  */
 
-package gobblin.fork;
+package org.apache.gobblin.fork;
 
-import gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.ConfigurationKeys;
 import java.util.Arrays;
 import java.util.List;
 
 import org.testng.Assert;
 import org.testng.annotations.Test;
 
-import gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.configuration.WorkUnitState;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/http/TestDefaultHttpClientConfiguration.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/http/TestDefaultHttpClientConfiguration.java b/gobblin-core/src/test/java/org/apache/gobblin/http/TestDefaultHttpClientConfiguration.java
index 7c97d2e..e82252d 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/http/TestDefaultHttpClientConfiguration.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/http/TestDefaultHttpClientConfiguration.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.http;
+package org.apache.gobblin.http;
 
 import org.apache.http.HttpHost;
 import org.testng.Assert;
@@ -25,8 +25,8 @@ import com.typesafe.config.Config;
 import com.typesafe.config.ConfigFactory;
 import com.typesafe.config.ConfigValueFactory;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
 
 /**
  * Unit tests for {@link DefaultHttpClientConfigurator}

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/http/TestHttpClientConfiguratorLoader.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/http/TestHttpClientConfiguratorLoader.java b/gobblin-core/src/test/java/org/apache/gobblin/http/TestHttpClientConfiguratorLoader.java
index 499e570..db50179 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/http/TestHttpClientConfiguratorLoader.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/http/TestHttpClientConfiguratorLoader.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.http;
+package org.apache.gobblin.http;
 
 import org.testng.Assert;
 import org.testng.Assert.ThrowingRunnable;
@@ -24,7 +24,7 @@ import com.typesafe.config.Config;
 import com.typesafe.config.ConfigFactory;
 import com.typesafe.config.ConfigValueFactory;
 
-import gobblin.configuration.State;
+import org.apache.gobblin.configuration.State;
 
 /**
  * Unit tests for {@link HttpClientConfiguratorLoader}

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/instrumented/InstrumentedTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/instrumented/InstrumentedTest.java b/gobblin-core/src/test/java/org/apache/gobblin/instrumented/InstrumentedTest.java
index c738204..6cea0de 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/instrumented/InstrumentedTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/instrumented/InstrumentedTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.instrumented;
+package org.apache.gobblin.instrumented;
 
 import java.util.HashMap;
 import java.util.Map;
@@ -23,12 +23,12 @@ import java.util.Map;
 import org.testng.Assert;
 import org.testng.annotations.Test;
 
-import gobblin.Constructs;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.metrics.GobblinMetrics;
-import gobblin.configuration.State;
-import gobblin.metrics.MetricContext;
-import gobblin.instrumented.extractor.InstrumentedExtractor;
+import org.apache.gobblin.Constructs;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.metrics.GobblinMetrics;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.metrics.MetricContext;
+import org.apache.gobblin.instrumented.extractor.InstrumentedExtractor;
 
 
 @Test(groups = { "gobblin.core" })

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/policies/count/RowCountRangePolicyTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/policies/count/RowCountRangePolicyTest.java b/gobblin-core/src/test/java/org/apache/gobblin/policies/count/RowCountRangePolicyTest.java
index be40401..f3b1de1 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/policies/count/RowCountRangePolicyTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/policies/count/RowCountRangePolicyTest.java
@@ -15,12 +15,12 @@
  * limitations under the License.
  */
 
-package gobblin.policies.count;
+package org.apache.gobblin.policies.count;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.qualitychecker.task.TaskLevelPolicy;
-import gobblin.qualitychecker.task.TaskLevelPolicy.Result;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicy;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicy.Result;
 
 import org.testng.Assert;
 import org.testng.annotations.Test;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/publisher/BaseDataPublisherTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/publisher/BaseDataPublisherTest.java b/gobblin-core/src/test/java/org/apache/gobblin/publisher/BaseDataPublisherTest.java
index 3522c29..ef68fd1 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/publisher/BaseDataPublisherTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/publisher/BaseDataPublisherTest.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.publisher;
+package org.apache.gobblin.publisher;
 
 import java.io.File;
 import java.io.FileInputStream;
@@ -38,15 +38,15 @@ import org.testng.annotations.Test;
 import com.google.common.collect.ImmutableList;
 import com.google.common.io.Files;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.metadata.MetadataMerger;
-import gobblin.metadata.types.GlobalMetadata;
-import gobblin.util.ForkOperatorUtils;
-import gobblin.writer.FsDataWriter;
-import gobblin.writer.FsWriterMetrics;
-import gobblin.writer.PartitionIdentifier;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.metadata.MetadataMerger;
+import org.apache.gobblin.metadata.types.GlobalMetadata;
+import org.apache.gobblin.util.ForkOperatorUtils;
+import org.apache.gobblin.writer.FsDataWriter;
+import org.apache.gobblin.writer.FsWriterMetrics;
+import org.apache.gobblin.writer.PartitionIdentifier;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowCountTaskLevelPolicyTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowCountTaskLevelPolicyTest.java b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowCountTaskLevelPolicyTest.java
index 690a1aa..e8edba6 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowCountTaskLevelPolicyTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowCountTaskLevelPolicyTest.java
@@ -15,19 +15,19 @@
  * limitations under the License.
  */
 
-package gobblin.qualitychecker;
+package org.apache.gobblin.qualitychecker;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.qualitychecker.task.TaskLevelPolicyCheckResults;
-import gobblin.qualitychecker.task.TaskLevelPolicyChecker;
-import gobblin.qualitychecker.task.TaskLevelPolicyCheckerBuilderFactory;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicyCheckResults;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicyChecker;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicyCheckerBuilderFactory;
 import java.util.Map;
 
 import org.testng.Assert;
 import org.testng.annotations.Test;
 
-import gobblin.configuration.State;
-import gobblin.qualitychecker.task.TaskLevelPolicy;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicy;
 
 
 @Test(groups = {"gobblin.qualitychecker"})

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowLevelQualityCheckerTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowLevelQualityCheckerTest.java b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowLevelQualityCheckerTest.java
index 26add73..1ce5868 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowLevelQualityCheckerTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowLevelQualityCheckerTest.java
@@ -15,13 +15,13 @@
  * limitations under the License.
  */
 
-package gobblin.qualitychecker;
+package org.apache.gobblin.qualitychecker;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.qualitychecker.row.RowLevelPolicyCheckResults;
-import gobblin.qualitychecker.row.RowLevelPolicyChecker;
-import gobblin.qualitychecker.row.RowLevelPolicyCheckerBuilderFactory;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.qualitychecker.row.RowLevelPolicyCheckResults;
+import org.apache.gobblin.qualitychecker.row.RowLevelPolicyChecker;
+import org.apache.gobblin.qualitychecker.row.RowLevelPolicyCheckerBuilderFactory;
 import java.io.File;
 import java.net.URI;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TaskLevelQualityCheckerTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TaskLevelQualityCheckerTest.java b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TaskLevelQualityCheckerTest.java
index 35d1f6c..8bd8edf 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TaskLevelQualityCheckerTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TaskLevelQualityCheckerTest.java
@@ -15,19 +15,19 @@
  * limitations under the License.
  */
 
-package gobblin.qualitychecker;
+package org.apache.gobblin.qualitychecker;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.qualitychecker.task.TaskLevelPolicy;
-import gobblin.qualitychecker.task.TaskLevelPolicyCheckResults;
-import gobblin.qualitychecker.task.TaskLevelPolicyChecker;
-import gobblin.qualitychecker.task.TaskLevelPolicyCheckerBuilderFactory;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicy;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicyCheckResults;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicyChecker;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicyCheckerBuilderFactory;
 import java.util.Map;
 
 import org.testng.Assert;
 import org.testng.annotations.Test;
 
-import gobblin.configuration.State;
+import org.apache.gobblin.configuration.State;
 
 
 @Test(groups = {"gobblin.qualitychecker"})

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestConstants.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestConstants.java b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestConstants.java
index 105047d..e0ece28 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestConstants.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestConstants.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.qualitychecker;
+package org.apache.gobblin.qualitychecker;
 
 public class TestConstants {
   public static final String TEST_FS_URI = "file://localhost/";

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestRowLevelPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestRowLevelPolicy.java b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestRowLevelPolicy.java
index 97a849f..7c4c33d 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestRowLevelPolicy.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestRowLevelPolicy.java
@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package gobblin.qualitychecker;
+package org.apache.gobblin.qualitychecker;
 
-import gobblin.configuration.State;
-import gobblin.qualitychecker.row.RowLevelPolicy;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.qualitychecker.row.RowLevelPolicy;
 
 
 public class TestRowLevelPolicy extends RowLevelPolicy {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestRowLevelPolicyFail.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestRowLevelPolicyFail.java b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestRowLevelPolicyFail.java
index e5cbcb5..fb2458a 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestRowLevelPolicyFail.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestRowLevelPolicyFail.java
@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package gobblin.qualitychecker;
+package org.apache.gobblin.qualitychecker;
 
-import gobblin.configuration.State;
-import gobblin.qualitychecker.row.RowLevelPolicy;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.qualitychecker.row.RowLevelPolicy;
 
 
 public class TestRowLevelPolicyFail extends RowLevelPolicy {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestTaskLevelPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestTaskLevelPolicy.java b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestTaskLevelPolicy.java
index 883440e..e995dd3 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestTaskLevelPolicy.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TestTaskLevelPolicy.java
@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package gobblin.qualitychecker;
+package org.apache.gobblin.qualitychecker;
 
-import gobblin.configuration.State;
-import gobblin.qualitychecker.task.TaskLevelPolicy;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicy;
 
 
 public class TestTaskLevelPolicy extends TaskLevelPolicy {


Mime
View raw message