gobblin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a...@apache.org
Subject [31/77] [abbrv] incubator-gobblin git commit: Updated package names, imports and shell scripts
Date Mon, 31 Jul 2017 07:52:49 GMT
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/SyncDataWriter.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/SyncDataWriter.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/SyncDataWriter.java
index fbd3c32..bb05f97 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/SyncDataWriter.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/SyncDataWriter.java
@@ -17,12 +17,12 @@
  * under the License.
  */
 
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 import java.io.Closeable;
 import java.io.IOException;
 
-import gobblin.annotation.Alpha;
+import org.apache.gobblin.annotation.Alpha;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/TrackerBasedWatermarkManager.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/TrackerBasedWatermarkManager.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/TrackerBasedWatermarkManager.java
index 500032f..378d467 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/TrackerBasedWatermarkManager.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/TrackerBasedWatermarkManager.java
@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 import java.io.IOException;
 import java.util.Map;
@@ -32,8 +32,8 @@ import com.google.common.annotations.VisibleForTesting;
 import com.google.common.base.Optional;
 import com.google.common.base.Preconditions;
 
-import gobblin.source.extractor.CheckpointableWatermark;
-import gobblin.util.ExecutorsUtils;
+import org.apache.gobblin.source.extractor.CheckpointableWatermark;
+import org.apache.gobblin.util.ExecutorsUtils;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkAwareWriter.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkAwareWriter.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkAwareWriter.java
index cc33532..9c9ef83 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkAwareWriter.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkAwareWriter.java
@@ -17,14 +17,14 @@
  * under the License.
  */
 
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 import java.io.IOException;
 import java.util.Map;
 
-import gobblin.annotation.Alpha;
-import gobblin.source.extractor.CheckpointableWatermark;
-import gobblin.stream.RecordEnvelope;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.source.extractor.CheckpointableWatermark;
+import org.apache.gobblin.stream.RecordEnvelope;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkAwareWriterWrapper.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkAwareWriterWrapper.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkAwareWriterWrapper.java
index 72fff25..e4ef251 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkAwareWriterWrapper.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkAwareWriterWrapper.java
@@ -17,15 +17,15 @@
  * under the License.
  */
 
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 import java.io.IOException;
 import java.util.Map;
 
 import com.google.common.base.Optional;
 
-import gobblin.source.extractor.CheckpointableWatermark;
-import gobblin.stream.RecordEnvelope;
+import org.apache.gobblin.source.extractor.CheckpointableWatermark;
+import org.apache.gobblin.stream.RecordEnvelope;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkManager.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkManager.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkManager.java
index 0d00f27..346eb60 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkManager.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkManager.java
@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 import java.io.Closeable;
 import java.util.Collections;
@@ -26,7 +26,7 @@ import java.util.Map;
 import lombok.Getter;
 import lombok.ToString;
 
-import gobblin.source.extractor.CheckpointableWatermark;
+import org.apache.gobblin.source.extractor.CheckpointableWatermark;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkTracker.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkTracker.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkTracker.java
index 1228223..8500774 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkTracker.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkTracker.java
@@ -17,11 +17,11 @@
  * under the License.
  */
 
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 import java.util.Map;
 
-import gobblin.source.extractor.CheckpointableWatermark;
+import org.apache.gobblin.source.extractor.CheckpointableWatermark;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkTrackerFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkTrackerFactory.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkTrackerFactory.java
index f319722..92c26a1 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkTrackerFactory.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkTrackerFactory.java
@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 import com.google.common.base.Preconditions;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteCallback.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteCallback.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteCallback.java
index ffa5fbf..fa93067 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteCallback.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteCallback.java
@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
-import gobblin.async.Callback;
+import org.apache.gobblin.async.Callback;
 
 
 public interface WriteCallback<T> extends Callback<WriteResponse<T>> {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteResponse.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteResponse.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteResponse.java
index 8661f8c..4f22c95 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteResponse.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteResponse.java
@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 /**
  * A class for encapsulating the system-native response and general statistics from a write

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteResponseFuture.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteResponseFuture.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteResponseFuture.java
index 92e7451..64666d0 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteResponseFuture.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteResponseFuture.java
@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.Future;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteResponseMapper.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteResponseMapper.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteResponseMapper.java
index e2d959e..7c69084 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteResponseMapper.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/WriteResponseMapper.java
@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 /**
  * An interface to implement a transformer from a system-native response type into a {@link WriteResponse}.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/exception/NonTransientException.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/exception/NonTransientException.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/exception/NonTransientException.java
index 85d265f..26e4a0b 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/exception/NonTransientException.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/exception/NonTransientException.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.writer.exception;
+package org.apache.gobblin.writer.exception;
 
 /**
  * NonTransientException that shows this is a permanent failure where retry cannot solve.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/main/java/org/apache/gobblin/writer/partitioner/WriterPartitioner.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/partitioner/WriterPartitioner.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/partitioner/WriterPartitioner.java
index c1a0e32..7246f47 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/partitioner/WriterPartitioner.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/partitioner/WriterPartitioner.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.writer.partitioner;
+package org.apache.gobblin.writer.partitioner;
 
 import org.apache.avro.Schema;
 import org.apache.avro.generic.GenericRecord;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/test/java/org/apache/gobblin/converter/AsyncConverter1to1Test.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/test/java/org/apache/gobblin/converter/AsyncConverter1to1Test.java b/gobblin-core-base/src/test/java/org/apache/gobblin/converter/AsyncConverter1to1Test.java
index 4dd1915..01ec3b4 100644
--- a/gobblin-core-base/src/test/java/org/apache/gobblin/converter/AsyncConverter1to1Test.java
+++ b/gobblin-core-base/src/test/java/org/apache/gobblin/converter/AsyncConverter1to1Test.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.converter;
+package org.apache.gobblin.converter;
 
 import java.util.List;
 import java.util.Map;
@@ -30,10 +30,10 @@ import com.google.common.collect.Lists;
 import com.google.common.collect.Maps;
 import com.google.common.collect.Sets;
 
-import gobblin.configuration.WorkUnitState;
-import gobblin.records.RecordStreamWithMetadata;
-import gobblin.stream.RecordEnvelope;
-import gobblin.util.ExponentialBackoff;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.records.RecordStreamWithMetadata;
+import org.apache.gobblin.stream.RecordEnvelope;
+import org.apache.gobblin.util.ExponentialBackoff;
 
 import io.reactivex.Flowable;
 import io.reactivex.schedulers.Schedulers;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/test/java/org/apache/gobblin/converter/SamplingConverterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/test/java/org/apache/gobblin/converter/SamplingConverterTest.java b/gobblin-core-base/src/test/java/org/apache/gobblin/converter/SamplingConverterTest.java
index 88ce969..0127419 100644
--- a/gobblin-core-base/src/test/java/org/apache/gobblin/converter/SamplingConverterTest.java
+++ b/gobblin-core-base/src/test/java/org/apache/gobblin/converter/SamplingConverterTest.java
@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package gobblin.converter;
+package org.apache.gobblin.converter;
 
 import java.util.Iterator;
 import java.util.Properties;
@@ -26,7 +26,7 @@ import java.util.Random;
 import org.testng.Assert;
 import org.testng.annotations.Test;
 
-import gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.configuration.WorkUnitState;
 
 
 @Test

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/test/java/org/apache/gobblin/converter/SingleRecordIterableTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/test/java/org/apache/gobblin/converter/SingleRecordIterableTest.java b/gobblin-core-base/src/test/java/org/apache/gobblin/converter/SingleRecordIterableTest.java
index a5bd8f8..e29bf48 100644
--- a/gobblin-core-base/src/test/java/org/apache/gobblin/converter/SingleRecordIterableTest.java
+++ b/gobblin-core-base/src/test/java/org/apache/gobblin/converter/SingleRecordIterableTest.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-base/src/test/java/org/apache/gobblin/converter/filter/AvroSchemaFieldRemoverTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/test/java/org/apache/gobblin/converter/filter/AvroSchemaFieldRemoverTest.java b/gobblin-core-base/src/test/java/org/apache/gobblin/converter/filter/AvroSchemaFieldRemoverTest.java
index 86df7d5..669d040 100644
--- a/gobblin-core-base/src/test/java/org/apache/gobblin/converter/filter/AvroSchemaFieldRemoverTest.java
+++ b/gobblin-core-base/src/test/java/org/apache/gobblin/converter/filter/AvroSchemaFieldRemoverTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.converter.filter;
+package org.apache.gobblin.converter.filter;
 
 import java.io.IOException;
 import java.io.InputStream;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/test/java/org/apache/gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/test/java/org/apache/gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverterTest.java b/gobblin-core-base/src/test/java/org/apache/gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverterTest.java
index 66dbe16..596ae69 100644
--- a/gobblin-core-base/src/test/java/org/apache/gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverterTest.java
+++ b/gobblin-core-base/src/test/java/org/apache/gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverterTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.converter.filter;
+package org.apache.gobblin.converter.filter;
 
 import java.io.IOException;
 import java.util.Properties;
@@ -24,8 +24,8 @@ import org.apache.avro.Schema;
 import org.testng.Assert;
 import org.testng.annotations.Test;
 
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.SchemaConversionException;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/test/java/org/apache/gobblin/crypto/EncryptionConfigParserTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/test/java/org/apache/gobblin/crypto/EncryptionConfigParserTest.java b/gobblin-core-base/src/test/java/org/apache/gobblin/crypto/EncryptionConfigParserTest.java
index 1b25085..68fbf37 100644
--- a/gobblin-core-base/src/test/java/org/apache/gobblin/crypto/EncryptionConfigParserTest.java
+++ b/gobblin-core-base/src/test/java/org/apache/gobblin/crypto/EncryptionConfigParserTest.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.crypto;
+package org.apache.gobblin.crypto;
 
 import java.util.Map;
 import java.util.Properties;
@@ -23,8 +23,8 @@ import org.testng.Assert;
 import org.testng.annotations.BeforeTest;
 import org.testng.annotations.Test;
 
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
 
 
 public class EncryptionConfigParserTest {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/converter/InstrumentedConverterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/converter/InstrumentedConverterTest.java b/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/converter/InstrumentedConverterTest.java
index 20702d3..fb5dfeb 100644
--- a/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/converter/InstrumentedConverterTest.java
+++ b/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/converter/InstrumentedConverterTest.java
@@ -15,22 +15,22 @@
  * limitations under the License.
  */
 
-package gobblin.instrumented.converter;
+package org.apache.gobblin.instrumented.converter;
 
 import java.util.Map;
 
 import org.testng.Assert;
 import org.testng.annotations.Test;
 
-import gobblin.MetricsHelper;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.Constructs;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.IdentityConverter;
-import gobblin.converter.SchemaConversionException;
-import gobblin.converter.SingleRecordIterable;
-import gobblin.metrics.MetricNames;
+import org.apache.gobblin.MetricsHelper;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.Constructs;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.IdentityConverter;
+import org.apache.gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.converter.SingleRecordIterable;
+import org.apache.gobblin.metrics.MetricNames;
 
 
 public class InstrumentedConverterTest {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractorTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractorTest.java b/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractorTest.java
index b3d607a..71b1bae 100644
--- a/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractorTest.java
+++ b/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractorTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.instrumented.extractor;
+package org.apache.gobblin.instrumented.extractor;
 
 import java.io.IOException;
 import java.util.Map;
@@ -24,15 +24,15 @@ import java.util.concurrent.atomic.AtomicBoolean;
 import org.testng.Assert;
 import org.testng.annotations.Test;
 
-import gobblin.MetricsHelper;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.Constructs;
-import gobblin.metrics.MetricNames;
-import gobblin.records.RecordStreamWithMetadata;
-import gobblin.source.extractor.DataRecordException;
-import gobblin.source.extractor.Extractor;
-import gobblin.stream.RecordEnvelope;
+import org.apache.gobblin.MetricsHelper;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.Constructs;
+import org.apache.gobblin.metrics.MetricNames;
+import org.apache.gobblin.records.RecordStreamWithMetadata;
+import org.apache.gobblin.source.extractor.DataRecordException;
+import org.apache.gobblin.source.extractor.Extractor;
+import org.apache.gobblin.stream.RecordEnvelope;
 
 
 public class InstrumentedExtractorTest {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperatorTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperatorTest.java b/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperatorTest.java
index bc25b3c..b7ed80f 100644
--- a/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperatorTest.java
+++ b/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperatorTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.instrumented.fork;
+package org.apache.gobblin.instrumented.fork;
 
 import java.io.IOException;
 import java.util.ArrayList;
@@ -25,12 +25,12 @@ import java.util.Map;
 import org.testng.Assert;
 import org.testng.annotations.Test;
 
-import gobblin.MetricsHelper;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.Constructs;
-import gobblin.fork.ForkOperator;
-import gobblin.metrics.MetricNames;
+import org.apache.gobblin.MetricsHelper;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.Constructs;
+import org.apache.gobblin.fork.ForkOperator;
+import org.apache.gobblin.metrics.MetricNames;
 
 
 public class InstrumentedForkOperatorTest {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyTest.java b/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyTest.java
index e72a4af..9caf850 100644
--- a/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyTest.java
+++ b/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyTest.java
@@ -15,20 +15,20 @@
  * limitations under the License.
  */
 
-package gobblin.instrumented.qualitychecker;
+package org.apache.gobblin.instrumented.qualitychecker;
 
 import java.util.Map;
 
 import org.testng.Assert;
 import org.testng.annotations.Test;
 
-import gobblin.MetricsHelper;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.Constructs;
-import gobblin.configuration.WorkUnitState;
-import gobblin.metrics.MetricNames;
-import gobblin.qualitychecker.row.RowLevelPolicy;
+import org.apache.gobblin.MetricsHelper;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.Constructs;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.metrics.MetricNames;
+import org.apache.gobblin.qualitychecker.row.RowLevelPolicy;
 
 
 public class InstrumentedRowLevelPolicyTest {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriterTest.java b/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriterTest.java
index afb06ac..b912b59 100644
--- a/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriterTest.java
+++ b/gobblin-core-base/src/test/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriterTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.instrumented.writer;
+package org.apache.gobblin.instrumented.writer;
 
 import java.io.IOException;
 import java.util.Map;
@@ -23,14 +23,14 @@ import java.util.Map;
 import org.testng.Assert;
 import org.testng.annotations.Test;
 
-import gobblin.MetricsHelper;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.Constructs;
-import gobblin.configuration.WorkUnitState;
-import gobblin.metrics.MetricNames;
-import gobblin.stream.RecordEnvelope;
-import gobblin.writer.DataWriter;
+import org.apache.gobblin.MetricsHelper;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.Constructs;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.metrics.MetricNames;
+import org.apache.gobblin.stream.RecordEnvelope;
+import org.apache.gobblin.writer.DataWriter;
 
 
 public class InstrumentedDataWriterTest {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/test/java/org/apache/gobblin/source/extractor/extract/AbstractSourceTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/test/java/org/apache/gobblin/source/extractor/extract/AbstractSourceTest.java b/gobblin-core-base/src/test/java/org/apache/gobblin/source/extractor/extract/AbstractSourceTest.java
index 6a7a775..02b14136 100644
--- a/gobblin-core-base/src/test/java/org/apache/gobblin/source/extractor/extract/AbstractSourceTest.java
+++ b/gobblin-core-base/src/test/java/org/apache/gobblin/source/extractor/extract/AbstractSourceTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.extract;
+package org.apache.gobblin.source.extractor.extract;
 
 import java.io.IOException;
 import java.util.Collections;
@@ -27,13 +27,13 @@ import org.testng.annotations.Test;
 
 import com.google.common.collect.Lists;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.SourceState;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.configuration.WorkUnitState.WorkingState;
-import gobblin.source.extractor.Extractor;
-import gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.SourceState;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.configuration.WorkUnitState.WorkingState;
+import org.apache.gobblin.source.extractor.Extractor;
+import org.apache.gobblin.source.workunit.WorkUnit;
 
 
 @Test(groups = { "gobblin.source.extractor.extract" })

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/test/java/org/apache/gobblin/writer/AsyncWriterManagerTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/test/java/org/apache/gobblin/writer/AsyncWriterManagerTest.java b/gobblin-core-base/src/test/java/org/apache/gobblin/writer/AsyncWriterManagerTest.java
index 8b1a249..fcc1c3c 100644
--- a/gobblin-core-base/src/test/java/org/apache/gobblin/writer/AsyncWriterManagerTest.java
+++ b/gobblin-core-base/src/test/java/org/apache/gobblin/writer/AsyncWriterManagerTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 import java.io.IOException;
 import java.util.Properties;
@@ -34,15 +34,15 @@ import com.typesafe.config.ConfigFactory;
 
 import lombok.extern.slf4j.Slf4j;
 
-import gobblin.metrics.RootMetricContext;
-import gobblin.metrics.reporter.OutputStreamReporter;
-import gobblin.test.ConstantTimingType;
-import gobblin.test.ErrorManager;
-import gobblin.test.NthTimingType;
-import gobblin.test.TestUtils;
-import gobblin.test.TimingManager;
-import gobblin.test.TimingResult;
-import gobblin.test.TimingType;
+import org.apache.gobblin.metrics.RootMetricContext;
+import org.apache.gobblin.metrics.reporter.OutputStreamReporter;
+import org.apache.gobblin.test.ConstantTimingType;
+import org.apache.gobblin.test.ErrorManager;
+import org.apache.gobblin.test.NthTimingType;
+import org.apache.gobblin.test.TestUtils;
+import org.apache.gobblin.test.TimingManager;
+import org.apache.gobblin.test.TimingResult;
+import org.apache.gobblin.test.TimingType;
 
 
 @Slf4j

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/test/java/org/apache/gobblin/writer/FineGrainedWatermarkTrackerTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/test/java/org/apache/gobblin/writer/FineGrainedWatermarkTrackerTest.java b/gobblin-core-base/src/test/java/org/apache/gobblin/writer/FineGrainedWatermarkTrackerTest.java
index 382a6da..59f231e 100644
--- a/gobblin-core-base/src/test/java/org/apache/gobblin/writer/FineGrainedWatermarkTrackerTest.java
+++ b/gobblin-core-base/src/test/java/org/apache/gobblin/writer/FineGrainedWatermarkTrackerTest.java
@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 import java.io.IOException;
 import java.util.Map;
@@ -38,10 +38,10 @@ import com.typesafe.config.ConfigFactory;
 
 import lombok.extern.slf4j.Slf4j;
 
-import gobblin.source.extractor.CheckpointableWatermark;
-import gobblin.source.extractor.DefaultCheckpointableWatermark;
-import gobblin.source.extractor.extract.LongWatermark;
-import gobblin.util.ExecutorsUtils;
+import org.apache.gobblin.source.extractor.CheckpointableWatermark;
+import org.apache.gobblin.source.extractor.DefaultCheckpointableWatermark;
+import org.apache.gobblin.source.extractor.extract.LongWatermark;
+import org.apache.gobblin.util.ExecutorsUtils;
 
 
 @Slf4j

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/test/java/org/apache/gobblin/writer/MultiWriterWatermarkManagerTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/test/java/org/apache/gobblin/writer/MultiWriterWatermarkManagerTest.java b/gobblin-core-base/src/test/java/org/apache/gobblin/writer/MultiWriterWatermarkManagerTest.java
index 6136ba4..c07d9c4 100644
--- a/gobblin-core-base/src/test/java/org/apache/gobblin/writer/MultiWriterWatermarkManagerTest.java
+++ b/gobblin-core-base/src/test/java/org/apache/gobblin/writer/MultiWriterWatermarkManagerTest.java
@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 import java.io.IOException;
 import java.util.ArrayList;
@@ -31,10 +31,10 @@ import org.testng.annotations.Test;
 
 import com.google.common.base.Optional;
 
-import gobblin.source.extractor.CheckpointableWatermark;
-import gobblin.source.extractor.DefaultCheckpointableWatermark;
-import gobblin.stream.RecordEnvelope;
-import gobblin.source.extractor.extract.LongWatermark;
+import org.apache.gobblin.source.extractor.CheckpointableWatermark;
+import org.apache.gobblin.source.extractor.DefaultCheckpointableWatermark;
+import org.apache.gobblin.stream.RecordEnvelope;
+import org.apache.gobblin.source.extractor.extract.LongWatermark;
 
 import static org.mockito.Matchers.any;
 import static org.mockito.Mockito.*;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core-base/src/test/java/org/apache/gobblin/writer/WatermarkTrackerTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/test/java/org/apache/gobblin/writer/WatermarkTrackerTest.java b/gobblin-core-base/src/test/java/org/apache/gobblin/writer/WatermarkTrackerTest.java
index 6ba7263..168004a 100644
--- a/gobblin-core-base/src/test/java/org/apache/gobblin/writer/WatermarkTrackerTest.java
+++ b/gobblin-core-base/src/test/java/org/apache/gobblin/writer/WatermarkTrackerTest.java
@@ -17,13 +17,13 @@
  * under the License.
  */
 
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 import org.testng.Assert;
 import org.testng.annotations.Test;
 
-import gobblin.source.extractor.DefaultCheckpointableWatermark;
-import gobblin.source.extractor.extract.LongWatermark;
+import org.apache.gobblin.source.extractor.DefaultCheckpointableWatermark;
+import org.apache.gobblin.source.extractor.extract.LongWatermark;
 
 
 @Test

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/async/AsyncDataDispatcher.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/async/AsyncDataDispatcher.java b/gobblin-core/src/main/java/org/apache/gobblin/async/AsyncDataDispatcher.java
index 8422ad8..f50c802 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/async/AsyncDataDispatcher.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/async/AsyncDataDispatcher.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.async;
+package org.apache.gobblin.async;
 
 import java.util.Queue;
 import java.util.concurrent.ArrayBlockingQueue;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/async/AsyncRequest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/async/AsyncRequest.java b/gobblin-core/src/main/java/org/apache/gobblin/async/AsyncRequest.java
index e6bb642..c0aad92 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/async/AsyncRequest.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/async/AsyncRequest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.async;
+package org.apache.gobblin.async;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -23,7 +23,7 @@ import java.util.List;
 import lombok.Getter;
 import lombok.Setter;
 
-import gobblin.net.Request;
+import org.apache.gobblin.net.Request;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/async/AsyncRequestBuilder.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/async/AsyncRequestBuilder.java b/gobblin-core/src/main/java/org/apache/gobblin/async/AsyncRequestBuilder.java
index 546db86..6c66218 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/async/AsyncRequestBuilder.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/async/AsyncRequestBuilder.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.async;
+package org.apache.gobblin.async;
 
 import java.util.Queue;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/async/BufferedRecord.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/async/BufferedRecord.java b/gobblin-core/src/main/java/org/apache/gobblin/async/BufferedRecord.java
index 474d0a9..4a43016 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/async/BufferedRecord.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/async/BufferedRecord.java
@@ -15,12 +15,12 @@
  * limitations under the License.
  */
 
-package gobblin.async;
+package org.apache.gobblin.async;
 
 import lombok.AllArgsConstructor;
 import lombok.Getter;
 
-import gobblin.async.Callback;
+import org.apache.gobblin.async.Callback;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/async/DispatchException.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/async/DispatchException.java b/gobblin-core/src/main/java/org/apache/gobblin/async/DispatchException.java
index 7e419a0..5eed080 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/async/DispatchException.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/async/DispatchException.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.async;
+package org.apache.gobblin.async;
 
 /**
  * Exception for dispatching failures. By default, it is a fatal exception

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/commit/FsRenameCommitStep.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/commit/FsRenameCommitStep.java b/gobblin-core/src/main/java/org/apache/gobblin/commit/FsRenameCommitStep.java
index 7e0d30a..a4bb223 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/commit/FsRenameCommitStep.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/commit/FsRenameCommitStep.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.commit;
+package org.apache.gobblin.commit;
 
 import java.io.IOException;
 import java.net.URI;
@@ -25,10 +25,10 @@ import org.apache.hadoop.fs.Path;
 
 import com.google.common.base.Preconditions;
 
-import gobblin.annotation.Alpha;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.util.HadoopUtils;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.util.HadoopUtils;
 
 import lombok.extern.slf4j.Slf4j;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/commit/SpeculativeAttemptAwareConstruct.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/commit/SpeculativeAttemptAwareConstruct.java b/gobblin-core/src/main/java/org/apache/gobblin/commit/SpeculativeAttemptAwareConstruct.java
index 6c66ef2..6bb5903 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/commit/SpeculativeAttemptAwareConstruct.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/commit/SpeculativeAttemptAwareConstruct.java
@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package gobblin.commit;
+package org.apache.gobblin.commit;
 
-import gobblin.annotation.Alpha;
+import org.apache.gobblin.annotation.Alpha;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/config/ConfigBuilder.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/config/ConfigBuilder.java b/gobblin-core/src/main/java/org/apache/gobblin/config/ConfigBuilder.java
index 0ecb64d..875b2fc 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/config/ConfigBuilder.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/config/ConfigBuilder.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.config;
+package org.apache.gobblin.config;
 
 import java.util.HashMap;
 import java.util.Map;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/EmptyIterable.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/EmptyIterable.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/EmptyIterable.java
index dec1924..c6aee6b 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/converter/EmptyIterable.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/EmptyIterable.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.converter;
+package org.apache.gobblin.converter;
 
 /**
  * @deprecated. Please use {@link gobblin.util.EmptyIterable} instead.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/GobblinMetricsPinotFlattenerConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/GobblinMetricsPinotFlattenerConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/GobblinMetricsPinotFlattenerConverter.java
index c5d0bd2..3a9526b 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/converter/GobblinMetricsPinotFlattenerConverter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/GobblinMetricsPinotFlattenerConverter.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.converter;
+package org.apache.gobblin.converter;
 
 import java.io.IOException;
 import java.io.InputStream;
@@ -31,7 +31,7 @@ import com.google.common.base.Function;
 import com.google.common.collect.Iterables;
 import com.google.common.collect.Lists;
 
-import gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.configuration.WorkUnitState;
 
 import lombok.extern.slf4j.Slf4j;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/StringSchemaInjector.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/StringSchemaInjector.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/StringSchemaInjector.java
index fbe8001..1dcfa34 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/converter/StringSchemaInjector.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/StringSchemaInjector.java
@@ -15,12 +15,12 @@
  * limitations under the License.
  */
 
-package gobblin.converter;
+package org.apache.gobblin.converter;
 
 import com.google.common.base.Preconditions;
 import com.google.common.collect.Lists;
 
-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/main/java/org/apache/gobblin/converter/avro/AvroFieldRetrieverConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroFieldRetrieverConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroFieldRetrieverConverter.java
index 455c8f1..f8114b7 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroFieldRetrieverConverter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroFieldRetrieverConverter.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.converter.avro;
+package org.apache.gobblin.converter.avro;
 
 import org.apache.avro.Schema;
 import org.apache.avro.generic.GenericRecord;
@@ -23,15 +23,15 @@ import org.apache.avro.generic.GenericRecord;
 import com.google.common.base.Optional;
 import com.google.common.base.Preconditions;
 
-import gobblin.converter.Converter;
-import gobblin.converter.SchemaConversionException;
-import gobblin.converter.SingleRecordIterable;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.EmptyIterable;
-import gobblin.util.AvroUtils;
-import gobblin.util.ForkOperatorUtils;
+import org.apache.gobblin.converter.Converter;
+import org.apache.gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.converter.SingleRecordIterable;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.EmptyIterable;
+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/converter/avro/AvroRecordToAvroWritableConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroRecordToAvroWritableConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroRecordToAvroWritableConverter.java
index d13c594..b1d8079 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroRecordToAvroWritableConverter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroRecordToAvroWritableConverter.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.converter.avro;
+package org.apache.gobblin.converter.avro;
 
 import java.rmi.server.UID;
 
@@ -26,10 +26,10 @@ import org.apache.hadoop.hive.serde2.avro.AvroGenericRecordWritable;
 
 import com.google.common.collect.Lists;
 
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.Converter;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.Converter;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.SchemaConversionException;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroToAvroCopyableConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroToAvroCopyableConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroToAvroCopyableConverter.java
index 7420f8b..13d1d0a 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroToAvroCopyableConverter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroToAvroCopyableConverter.java
@@ -15,18 +15,18 @@
  * limitations under the License.
  */
 
-package gobblin.converter.avro;
+package org.apache.gobblin.converter.avro;
 
 import org.apache.avro.Schema;
 import org.apache.avro.generic.GenericRecord;
 
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.Converter;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.SchemaConversionException;
-import gobblin.converter.SingleRecordIterable;
-import gobblin.fork.CopyableGenericRecord;
-import gobblin.fork.CopyableSchema;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.Converter;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.converter.SingleRecordIterable;
+import org.apache.gobblin.fork.CopyableGenericRecord;
+import org.apache.gobblin.fork.CopyableSchema;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroToBytesConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroToBytesConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroToBytesConverter.java
index a89b0d6..ecf98d4 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroToBytesConverter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroToBytesConverter.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.ByteArrayOutputStream;
 import java.io.IOException;
@@ -26,10 +26,10 @@ import org.apache.avro.generic.GenericRecord;
 import org.apache.avro.io.BinaryEncoder;
 import org.apache.avro.io.EncoderFactory;
 
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.Converter;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.Converter;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.SchemaConversionException;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/BytesToAvroConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/BytesToAvroConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/BytesToAvroConverter.java
index 285777c..bdb8fb3 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/BytesToAvroConverter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/BytesToAvroConverter.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.Collections;
@@ -27,10 +27,10 @@ import org.apache.avro.io.DecoderFactory;
 
 import com.google.common.base.Preconditions;
 
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.Converter;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.Converter;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.SchemaConversionException;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/FlattenNestedKeyConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/FlattenNestedKeyConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/FlattenNestedKeyConverter.java
index 9506ba3..ccf0819 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/FlattenNestedKeyConverter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/FlattenNestedKeyConverter.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.converter.avro;
+package org.apache.gobblin.converter.avro;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -31,15 +31,15 @@ import com.google.common.base.Optional;
 import com.google.common.collect.Maps;
 import com.typesafe.config.Config;
 
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.Converter;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.SchemaConversionException;
-import gobblin.converter.SingleRecordIterable;
-import gobblin.util.AvroUtils;
-import gobblin.util.ConfigUtils;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.Converter;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.converter.SingleRecordIterable;
+import org.apache.gobblin.util.AvroUtils;
+import org.apache.gobblin.util.ConfigUtils;
 
-import static gobblin.util.AvroUtils.FIELD_LOCATION_DELIMITER;
+import static org.apache.gobblin.util.AvroUtils.FIELD_LOCATION_DELIMITER;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/JsonElementConversionFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/JsonElementConversionFactory.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/JsonElementConversionFactory.java
index 22916a9..aa015a1 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/JsonElementConversionFactory.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/JsonElementConversionFactory.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.converter.avro;
+package org.apache.gobblin.converter.avro;
 
 import java.io.UnsupportedEncodingException;
 import java.nio.ByteBuffer;
@@ -39,8 +39,8 @@ import com.google.gson.JsonArray;
 import com.google.gson.JsonElement;
 import com.google.gson.JsonObject;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/JsonIntermediateToAvroConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/JsonIntermediateToAvroConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/JsonIntermediateToAvroConverter.java
index 92eb3fc..0735c03 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/JsonIntermediateToAvroConverter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/JsonIntermediateToAvroConverter.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.converter.avro;
+package org.apache.gobblin.converter.avro;
 
 import java.io.IOException;
 import java.util.ArrayList;
@@ -37,15 +37,15 @@ import com.google.gson.JsonArray;
 import com.google.gson.JsonElement;
 import com.google.gson.JsonObject;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.EmptyIterable;
-import gobblin.converter.SchemaConversionException;
-import gobblin.converter.SingleRecordIterable;
-import gobblin.converter.ToAvroConverterBase;
-import gobblin.util.AvroUtils;
-import gobblin.util.WriterUtils;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.EmptyIterable;
+import org.apache.gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.converter.SingleRecordIterable;
+import org.apache.gobblin.converter.ToAvroConverterBase;
+import org.apache.gobblin.util.AvroUtils;
+import org.apache.gobblin.util.WriterUtils;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/UnsupportedDateTypeException.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/UnsupportedDateTypeException.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/UnsupportedDateTypeException.java
index 69ca6a0..260c638 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/UnsupportedDateTypeException.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/UnsupportedDateTypeException.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.converter.avro;
+package org.apache.gobblin.converter.avro;
 
 public class UnsupportedDateTypeException extends Exception {
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/csv/CsvToJsonConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/csv/CsvToJsonConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/csv/CsvToJsonConverter.java
index ba093c2..8672b6b 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/converter/csv/CsvToJsonConverter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/csv/CsvToJsonConverter.java
@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package gobblin.converter.csv;
+package org.apache.gobblin.converter.csv;
 
-import gobblin.converter.Converter;
-import gobblin.converter.SingleRecordIterable;
+import org.apache.gobblin.converter.Converter;
+import org.apache.gobblin.converter.SingleRecordIterable;
 import java.io.IOException;
 import java.util.List;
 
@@ -30,11 +30,11 @@ import com.google.gson.JsonNull;
 import com.google.gson.JsonObject;
 import com.google.gson.JsonParser;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.SchemaConversionException;
-import gobblin.source.extractor.utils.InputStreamCSVReader;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.source.extractor.utils.InputStreamCSVReader;
 
 
 public class CsvToJsonConverter extends Converter<String, JsonArray, String, JsonObject> {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/csv/CsvToJsonConverterV2.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/csv/CsvToJsonConverterV2.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/csv/CsvToJsonConverterV2.java
index 95e7c51..f33dae7 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/converter/csv/CsvToJsonConverterV2.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/csv/CsvToJsonConverterV2.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.converter.csv;
+package org.apache.gobblin.converter.csv;
 
 import java.util.Iterator;
 import java.util.List;
@@ -31,11 +31,11 @@ import com.google.gson.JsonNull;
 import com.google.gson.JsonObject;
 import com.google.gson.JsonParser;
 
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.Converter;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.SchemaConversionException;
-import gobblin.converter.SingleRecordIterable;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.Converter;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.converter.SingleRecordIterable;
 
 /**
  * CsvToJsonConverterV2 accepts already deserialized (parsed) CSV row, String[], where you can use

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/filter/AvroFieldsPickConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/filter/AvroFieldsPickConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/filter/AvroFieldsPickConverter.java
index b0eb533..b38ca92 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/converter/filter/AvroFieldsPickConverter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/filter/AvroFieldsPickConverter.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.converter.filter;
+package org.apache.gobblin.converter.filter;
 
 import java.io.IOException;
 import java.util.Iterator;
@@ -31,13 +31,13 @@ import com.google.common.base.Preconditions;
 import com.google.common.base.Splitter;
 import com.google.common.collect.Lists;
 import com.google.common.collect.Maps;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.AvroToAvroConverterBase;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.SchemaConversionException;
-import gobblin.converter.SingleRecordIterable;
-import gobblin.util.AvroUtils;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.AvroToAvroConverterBase;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.converter.SingleRecordIterable;
+import org.apache.gobblin.util.AvroUtils;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/filter/AvroFilterConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/filter/AvroFilterConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/filter/AvroFilterConverter.java
index d3fd8b2..a67cee0 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/converter/filter/AvroFilterConverter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/filter/AvroFilterConverter.java
@@ -15,23 +15,23 @@
  * limitations under the License.
  */
 
-package gobblin.converter.filter;
+package org.apache.gobblin.converter.filter;
 
-import gobblin.converter.AvroToAvroConverterBase;
-import gobblin.converter.Converter;
-import gobblin.converter.SchemaConversionException;
-import gobblin.converter.SingleRecordIterable;
+import org.apache.gobblin.converter.AvroToAvroConverterBase;
+import org.apache.gobblin.converter.Converter;
+import org.apache.gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.converter.SingleRecordIterable;
 import org.apache.avro.Schema;
 import org.apache.avro.generic.GenericRecord;
 
 import com.google.common.base.Optional;
 import com.google.common.base.Preconditions;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.EmptyIterable;
-import gobblin.util.AvroUtils;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.EmptyIterable;
+import org.apache.gobblin.util.AvroUtils;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/http/AvroToRestJsonEntryConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/http/AvroToRestJsonEntryConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/http/AvroToRestJsonEntryConverter.java
index fd8a332..ff5cc10 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/converter/http/AvroToRestJsonEntryConverter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/http/AvroToRestJsonEntryConverter.java
@@ -14,7 +14,7 @@
  * 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 org.apache.avro.Schema;
 import org.apache.avro.generic.GenericRecord;
@@ -27,11 +27,11 @@ import com.typesafe.config.ConfigParseOptions;
 import com.typesafe.config.ConfigRenderOptions;
 import com.typesafe.config.ConfigSyntax;
 
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.Converter;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.SchemaConversionException;
-import gobblin.converter.SingleRecordIterable;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.Converter;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.converter.SingleRecordIterable;
 
 /**
  * Converts Avro to RestJsonEntry.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/http/RestEntry.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/http/RestEntry.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/http/RestEntry.java
index 65d8e07..92f9d1b 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/converter/http/RestEntry.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/http/RestEntry.java
@@ -14,7 +14,7 @@
  * 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 com.google.common.base.Optional;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/initializer/ConverterInitializerFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/initializer/ConverterInitializerFactory.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/initializer/ConverterInitializerFactory.java
index e315ed1..5cb6951 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/converter/initializer/ConverterInitializerFactory.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/initializer/ConverterInitializerFactory.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.converter.initializer;
+package org.apache.gobblin.converter.initializer;
 
 import java.util.List;
 
@@ -23,11 +23,11 @@ import com.google.common.base.Preconditions;
 import com.google.common.base.Splitter;
 import com.google.common.collect.Lists;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.converter.Converter;
-import gobblin.util.ForkOperatorUtils;
-import gobblin.source.workunit.WorkUnitStream;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.converter.Converter;
+import org.apache.gobblin.util.ForkOperatorUtils;
+import org.apache.gobblin.source.workunit.WorkUnitStream;
 
 
 public class ConverterInitializerFactory {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/initializer/MultiConverterInitializer.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/initializer/MultiConverterInitializer.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/initializer/MultiConverterInitializer.java
index 09881e9..14ac3e1 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/converter/initializer/MultiConverterInitializer.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/initializer/MultiConverterInitializer.java
@@ -15,13 +15,13 @@
  * limitations under the License.
  */
 
-package gobblin.converter.initializer;
+package org.apache.gobblin.converter.initializer;
 
 import java.util.List;
 
 import lombok.ToString;
-import gobblin.initializer.Initializer;
-import gobblin.initializer.MultiInitializer;
+import org.apache.gobblin.initializer.Initializer;
+import org.apache.gobblin.initializer.MultiInitializer;
 
 
 @ToString

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/json/JsonStringToJsonIntermediateConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/json/JsonStringToJsonIntermediateConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/json/JsonStringToJsonIntermediateConverter.java
index b9ba6b4..c73e58f 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/converter/json/JsonStringToJsonIntermediateConverter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/json/JsonStringToJsonIntermediateConverter.java
@@ -15,13 +15,13 @@
  * limitations under the License.
  */
 
-package gobblin.converter.json;
+package org.apache.gobblin.converter.json;
 
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.Converter;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.SchemaConversionException;
-import gobblin.converter.SingleRecordIterable;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.Converter;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.converter.SingleRecordIterable;
 
 import java.io.IOException;
 import java.util.Map;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/json/JsonToStringConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/json/JsonToStringConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/json/JsonToStringConverter.java
index 6dbce40..f8b957b 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/converter/json/JsonToStringConverter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/json/JsonToStringConverter.java
@@ -15,16 +15,16 @@
  * limitations under the License.
  */
 
-package gobblin.converter.json;
+package org.apache.gobblin.converter.json;
 
 import com.google.common.collect.Lists;
 import com.google.gson.Gson;
 import com.google.gson.JsonObject;
 
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.Converter;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.Converter;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.SchemaConversionException;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/objectstore/ObjectStoreConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/objectstore/ObjectStoreConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/objectstore/ObjectStoreConverter.java
index 39f1897..f5703f6 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/converter/objectstore/ObjectStoreConverter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/objectstore/ObjectStoreConverter.java
@@ -14,13 +14,13 @@
  * 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 gobblin.annotation.Alpha;
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.Converter;
-import gobblin.converter.SchemaConversionException;
-import gobblin.writer.objectstore.ObjectStoreOperation;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.Converter;
+import org.apache.gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.writer.objectstore.ObjectStoreOperation;
 
 /**
  * A converter of {@link ObjectStoreOperation}s. The output record of any subclasses is of type {@link ObjectStoreOperation}

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/objectstore/ObjectStoreDeleteConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/objectstore/ObjectStoreDeleteConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/objectstore/ObjectStoreDeleteConverter.java
index 500b2ac..9dc0d65 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/converter/objectstore/ObjectStoreDeleteConverter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/objectstore/ObjectStoreDeleteConverter.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.GenericRecord;
@@ -27,13 +27,13 @@ import com.google.common.base.Preconditions;
 import com.google.common.primitives.Ints;
 import com.google.common.primitives.Longs;
 
-import gobblin.annotation.Alpha;
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.SingleRecordIterable;
-import gobblin.util.AvroUtils;
-import gobblin.writer.objectstore.ObjectStoreDeleteOperation;
-import gobblin.writer.objectstore.ObjectStoreOperationBuilder;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.SingleRecordIterable;
+import org.apache.gobblin.util.AvroUtils;
+import org.apache.gobblin.writer.objectstore.ObjectStoreDeleteOperation;
+import org.apache.gobblin.writer.objectstore.ObjectStoreOperationBuilder;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/serde/HiveSerDeConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/serde/HiveSerDeConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/serde/HiveSerDeConverter.java
index 2913aaa..7e52991 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/converter/serde/HiveSerDeConverter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/serde/HiveSerDeConverter.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.converter.serde;
+package org.apache.gobblin.converter.serde;
 
 import java.io.IOException;
 
@@ -38,13 +38,13 @@ import com.google.common.base.Throwables;
 
 import lombok.extern.slf4j.Slf4j;
 
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.SchemaConversionException;
-import gobblin.converter.SingleRecordIterable;
-import gobblin.hive.HiveSerDeWrapper;
-import gobblin.instrumented.converter.InstrumentedConverter;
-import gobblin.util.HadoopUtils;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.converter.SingleRecordIterable;
+import org.apache.gobblin.hive.HiveSerDeWrapper;
+import org.apache.gobblin.instrumented.converter.InstrumentedConverter;
+import org.apache.gobblin.util.HadoopUtils;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/string/ObjectToStringConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/string/ObjectToStringConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/string/ObjectToStringConverter.java
index db21feb..a66262f 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/converter/string/ObjectToStringConverter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/string/ObjectToStringConverter.java
@@ -15,13 +15,13 @@
  * limitations under the License.
  */
 
-package gobblin.converter.string;
+package org.apache.gobblin.converter.string;
 
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.Converter;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.SchemaConversionException;
-import gobblin.converter.SingleRecordIterable;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.Converter;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.converter.SingleRecordIterable;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringFilterConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringFilterConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringFilterConverter.java
index 36b5bd0..fe65c7b 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringFilterConverter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringFilterConverter.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.converter.string;
+package org.apache.gobblin.converter.string;
 
 import java.util.regex.Matcher;
 import java.util.regex.Pattern;
@@ -23,14 +23,14 @@ import java.util.regex.Pattern;
 import com.google.common.base.Optional;
 import com.google.common.base.Strings;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.Converter;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.EmptyIterable;
-import gobblin.converter.SchemaConversionException;
-import gobblin.converter.SingleRecordIterable;
-import gobblin.util.ForkOperatorUtils;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.Converter;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.EmptyIterable;
+import org.apache.gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.converter.SingleRecordIterable;
+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/converter/string/StringSplitterConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringSplitterConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringSplitterConverter.java
index 66f1e6c..03b7578 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringSplitterConverter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringSplitterConverter.java
@@ -15,17 +15,17 @@
  * limitations under the License.
  */
 
-package gobblin.converter.string;
+package org.apache.gobblin.converter.string;
 
 import com.google.common.base.Preconditions;
 import com.google.common.base.Splitter;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.Converter;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.SchemaConversionException;
-import gobblin.util.ForkOperatorUtils;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.Converter;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.util.ForkOperatorUtils;
 
 /**
  * Implementation of {@link Converter} that splits a string based on a delimiter specified by

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringSplitterToListConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringSplitterToListConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringSplitterToListConverter.java
index 1c7cefe..4880834 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringSplitterToListConverter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringSplitterToListConverter.java
@@ -15,20 +15,20 @@
  * limitations under the License.
  */
 
-package gobblin.converter.string;
+package org.apache.gobblin.converter.string;
 
 import java.util.List;
 
 import com.google.common.base.Preconditions;
 import com.google.common.base.Splitter;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.Converter;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.SchemaConversionException;
-import gobblin.converter.SingleRecordIterable;
-import gobblin.util.ForkOperatorUtils;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.Converter;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.converter.SingleRecordIterable;
+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/converter/string/StringToBytesConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringToBytesConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringToBytesConverter.java
index dc3b467..b1a4ae0 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringToBytesConverter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/string/StringToBytesConverter.java
@@ -15,15 +15,15 @@
  * limitations under the License.
  */
 
-package gobblin.converter.string;
+package org.apache.gobblin.converter.string;
 
 import com.google.common.base.Charsets;
 import com.google.common.collect.Lists;
 
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.Converter;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.Converter;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.SchemaConversionException;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/converter/string/TextToStringConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/string/TextToStringConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/string/TextToStringConverter.java
index a66a196..0b11869 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/converter/string/TextToStringConverter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/string/TextToStringConverter.java
@@ -15,15 +15,15 @@
  * limitations under the License.
  */
 
-package gobblin.converter.string;
+package org.apache.gobblin.converter.string;
 
 import org.apache.hadoop.io.Text;
 
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.Converter;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.SchemaConversionException;
-import gobblin.converter.SingleRecordIterable;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.Converter;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.converter.SingleRecordIterable;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/fork/CopyableGenericRecord.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/fork/CopyableGenericRecord.java b/gobblin-core/src/main/java/org/apache/gobblin/fork/CopyableGenericRecord.java
index 9a867f7..84d2e72 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/fork/CopyableGenericRecord.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/fork/CopyableGenericRecord.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.fork;
+package org.apache.gobblin.fork;
 
 import org.apache.avro.generic.GenericData;
 import org.apache.avro.generic.GenericRecord;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/fork/CopyableSchema.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/fork/CopyableSchema.java b/gobblin-core/src/main/java/org/apache/gobblin/fork/CopyableSchema.java
index ed3b205..fb80a52 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/fork/CopyableSchema.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/fork/CopyableSchema.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.fork;
+package org.apache.gobblin.fork;
 
 import org.apache.avro.Schema;
 


Mime
View raw message