gobblin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a...@apache.org
Subject [27/77] [abbrv] incubator-gobblin git commit: Updated package names, imports and shell scripts
Date Mon, 31 Jul 2017 07:52:45 GMT
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/row/FrontLoadedSamplerTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/row/FrontLoadedSamplerTest.java b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/row/FrontLoadedSamplerTest.java
index 73feb1d..eae084f 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/row/FrontLoadedSamplerTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/row/FrontLoadedSamplerTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.qualitychecker.row;
+package org.apache.gobblin.qualitychecker.row;
 
 import java.util.List;
 import java.util.stream.Collectors;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/recordaccess/AvroGenericRecordAccessorTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/recordaccess/AvroGenericRecordAccessorTest.java b/gobblin-core/src/test/java/org/apache/gobblin/recordaccess/AvroGenericRecordAccessorTest.java
index c91bf3c..3bd8338 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/recordaccess/AvroGenericRecordAccessorTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/recordaccess/AvroGenericRecordAccessorTest.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package gobblin.recordaccess;
+package org.apache.gobblin.recordaccess;
 
 import java.io.ByteArrayOutputStream;
 import java.io.File;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/recordaccess/RecordAccessorProviderFactoryTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/recordaccess/RecordAccessorProviderFactoryTest.java b/gobblin-core/src/test/java/org/apache/gobblin/recordaccess/RecordAccessorProviderFactoryTest.java
index 53da61a..99f819b 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/recordaccess/RecordAccessorProviderFactoryTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/recordaccess/RecordAccessorProviderFactoryTest.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package gobblin.recordaccess;
+package org.apache.gobblin.recordaccess;
 
 import java.io.IOException;
 import java.util.Map;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/security/ssl/SSLContextFactoryTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/security/ssl/SSLContextFactoryTest.java b/gobblin-core/src/test/java/org/apache/gobblin/security/ssl/SSLContextFactoryTest.java
index c7e9b6c..34b3e98 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/security/ssl/SSLContextFactoryTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/security/ssl/SSLContextFactoryTest.java
@@ -1,4 +1,4 @@
-package gobblin.security.ssl;
+package org.apache.gobblin.security.ssl;
 
 import java.io.IOException;
 import java.util.HashMap;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/serde/HiveSerDeTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/serde/HiveSerDeTest.java b/gobblin-core/src/test/java/org/apache/gobblin/serde/HiveSerDeTest.java
index 1dda0a5..ec7086e 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/serde/HiveSerDeTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/serde/HiveSerDeTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.serde;
+package org.apache.gobblin.serde;
 
 import java.io.FileReader;
 import java.io.IOException;
@@ -34,22 +34,22 @@ import com.google.common.collect.ImmutableList;
 import com.google.common.collect.Iterators;
 import com.google.common.io.Closer;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.SourceState;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.serde.HiveSerDeConverter;
-import gobblin.source.extractor.DataRecordException;
-import gobblin.source.extractor.hadoop.OldApiWritableFileExtractor;
-import gobblin.source.extractor.hadoop.OldApiWritableFileSource;
-import gobblin.source.workunit.WorkUnit;
-import gobblin.util.HadoopUtils;
-import gobblin.writer.Destination;
-import gobblin.writer.Destination.DestinationType;
-import gobblin.writer.HiveWritableHdfsDataWriter;
-import gobblin.writer.HiveWritableHdfsDataWriterBuilder;
-import gobblin.writer.WriterOutputFormat;
+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.converter.DataConversionException;
+import org.apache.gobblin.converter.serde.HiveSerDeConverter;
+import org.apache.gobblin.source.extractor.DataRecordException;
+import org.apache.gobblin.source.extractor.hadoop.OldApiWritableFileExtractor;
+import org.apache.gobblin.source.extractor.hadoop.OldApiWritableFileSource;
+import org.apache.gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.util.HadoopUtils;
+import org.apache.gobblin.writer.Destination;
+import org.apache.gobblin.writer.Destination.DestinationType;
+import org.apache.gobblin.writer.HiveWritableHdfsDataWriter;
+import org.apache.gobblin.writer.HiveWritableHdfsDataWriterBuilder;
+import org.apache.gobblin.writer.WriterOutputFormat;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/source/RegexBasedPartitionedRetrieverTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/source/RegexBasedPartitionedRetrieverTest.java b/gobblin-core/src/test/java/org/apache/gobblin/source/RegexBasedPartitionedRetrieverTest.java
index 208a5ae..cb35eb6 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/source/RegexBasedPartitionedRetrieverTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/source/RegexBasedPartitionedRetrieverTest.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.source;
+package org.apache.gobblin.source;
 
 import java.io.IOException;
 import java.nio.file.FileVisitResult;
@@ -30,8 +30,8 @@ import org.testng.annotations.AfterClass;
 import org.testng.annotations.BeforeClass;
 import org.testng.annotations.Test;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.SourceState;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.SourceState;
 
 
 public class RegexBasedPartitionedRetrieverTest {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/DatePartitionedAvroFileExtractorTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/DatePartitionedAvroFileExtractorTest.java b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/DatePartitionedAvroFileExtractorTest.java
index 145c522..be4f161 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/DatePartitionedAvroFileExtractorTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/DatePartitionedAvroFileExtractorTest.java
@@ -10,7 +10,7 @@
  * CONDITIONS OF ANY KIND, either express or implied.
  */
 
-package gobblin.source.extractor;
+package org.apache.gobblin.source.extractor;
 
 import java.io.File;
 import java.io.IOException;
@@ -29,23 +29,23 @@ import org.testng.annotations.AfterClass;
 import org.testng.annotations.BeforeClass;
 import org.testng.annotations.Test;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.SourceState;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.DatePartitionedAvroFileSource;
-import gobblin.source.workunit.Extract.TableType;
-import gobblin.source.workunit.MultiWorkUnit;
-import gobblin.source.workunit.WorkUnit;
-import gobblin.stream.RecordEnvelope;
-import gobblin.writer.AvroDataWriterBuilder;
-import gobblin.writer.DataWriter;
-import gobblin.writer.DataWriterBuilder;
-import gobblin.writer.Destination;
-import gobblin.writer.PartitionedDataWriter;
-import gobblin.writer.WriterOutputFormat;
-import gobblin.writer.partitioner.TimeBasedAvroWriterPartitioner;
-import gobblin.writer.partitioner.TimeBasedWriterPartitioner;
+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.source.DatePartitionedAvroFileSource;
+import org.apache.gobblin.source.workunit.Extract.TableType;
+import org.apache.gobblin.source.workunit.MultiWorkUnit;
+import org.apache.gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.stream.RecordEnvelope;
+import org.apache.gobblin.writer.AvroDataWriterBuilder;
+import org.apache.gobblin.writer.DataWriter;
+import org.apache.gobblin.writer.DataWriterBuilder;
+import org.apache.gobblin.writer.Destination;
+import org.apache.gobblin.writer.PartitionedDataWriter;
+import org.apache.gobblin.writer.WriterOutputFormat;
+import org.apache.gobblin.writer.partitioner.TimeBasedAvroWriterPartitioner;
+import org.apache.gobblin.writer.partitioner.TimeBasedWriterPartitioner;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/extract/QueryBasedExtractorTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/extract/QueryBasedExtractorTest.java b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/extract/QueryBasedExtractorTest.java
index 826be4b..d1641ac 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/extract/QueryBasedExtractorTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/extract/QueryBasedExtractorTest.java
@@ -1,18 +1,18 @@
-package gobblin.source.extractor.extract;
-
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.extractor.DataRecordException;
-import gobblin.source.extractor.exception.HighWatermarkException;
-import gobblin.source.extractor.exception.RecordCountException;
-import gobblin.source.extractor.exception.SchemaException;
-import gobblin.source.extractor.partition.Partition;
-import gobblin.source.extractor.partition.Partitioner;
-import gobblin.source.extractor.watermark.Predicate;
-import gobblin.source.extractor.watermark.WatermarkPredicate;
-import gobblin.source.extractor.watermark.WatermarkType;
-import gobblin.source.workunit.WorkUnit;
+package org.apache.gobblin.source.extractor.extract;
+
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.extractor.DataRecordException;
+import org.apache.gobblin.source.extractor.exception.HighWatermarkException;
+import org.apache.gobblin.source.extractor.exception.RecordCountException;
+import org.apache.gobblin.source.extractor.exception.SchemaException;
+import org.apache.gobblin.source.extractor.partition.Partition;
+import org.apache.gobblin.source.extractor.partition.Partitioner;
+import org.apache.gobblin.source.extractor.watermark.Predicate;
+import org.apache.gobblin.source.extractor.watermark.WatermarkPredicate;
+import org.apache.gobblin.source.extractor.watermark.WatermarkType;
+import org.apache.gobblin.source.workunit.WorkUnit;
 import java.io.IOException;
 import java.util.ArrayList;
 import java.util.Iterator;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/extract/QueryBasedSourceTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/extract/QueryBasedSourceTest.java b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/extract/QueryBasedSourceTest.java
index d552574..c589660 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/extract/QueryBasedSourceTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/extract/QueryBasedSourceTest.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.source.extractor.extract;
+package org.apache.gobblin.source.extractor.extract;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -27,16 +27,16 @@ import org.testng.annotations.Test;
 import com.google.common.base.Optional;
 import com.google.common.collect.ImmutableSet;
 
-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.extract.QueryBasedSource.SourceEntity;
-import gobblin.source.workunit.Extract;
-import gobblin.source.workunit.Extract.TableType;
-import gobblin.source.workunit.WorkUnit;
-import gobblin.util.dataset.DatasetUtils;
+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.extract.QueryBasedSource.SourceEntity;
+import org.apache.gobblin.source.workunit.Extract;
+import org.apache.gobblin.source.workunit.Extract.TableType;
+import org.apache.gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.util.dataset.DatasetUtils;
 
 /**
  * Unit tests for {@link QueryBasedSource}

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/filebased/FileBasedExtractorTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/filebased/FileBasedExtractorTest.java b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/filebased/FileBasedExtractorTest.java
index bfb0a28..e91cc08 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/filebased/FileBasedExtractorTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/filebased/FileBasedExtractorTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.filebased;
+package org.apache.gobblin.source.extractor.filebased;
 
 import java.io.IOException;
 
@@ -28,10 +28,10 @@ import org.mockito.Mockito;
 import org.testng.Assert;
 import org.testng.annotations.Test;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.extractor.DataRecordException;
-import gobblin.source.extractor.Extractor;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.extractor.DataRecordException;
+import org.apache.gobblin.source.extractor.Extractor;
 
 
 @Test

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/filebased/FileBasedSourceTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/filebased/FileBasedSourceTest.java b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/filebased/FileBasedSourceTest.java
index e8cdfe7..8cceff2 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/filebased/FileBasedSourceTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/filebased/FileBasedSourceTest.java
@@ -15,16 +15,16 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.filebased;
-
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.SourceState;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.extractor.DataRecordException;
-import gobblin.source.extractor.Extractor;
-import gobblin.source.workunit.Extract;
-import gobblin.source.workunit.WorkUnit;
+package org.apache.gobblin.source.extractor.filebased;
+
+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.source.extractor.DataRecordException;
+import org.apache.gobblin.source.extractor.Extractor;
+import org.apache.gobblin.source.workunit.Extract;
+import org.apache.gobblin.source.workunit.WorkUnit;
 import org.junit.Assert;
 import org.testng.annotations.Test;
 import org.testng.collections.Lists;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/filebased/TokenizedFileDownloaderTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/filebased/TokenizedFileDownloaderTest.java b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/filebased/TokenizedFileDownloaderTest.java
index 1cedba8..a7c7637 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/filebased/TokenizedFileDownloaderTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/filebased/TokenizedFileDownloaderTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.filebased;
+package org.apache.gobblin.source.extractor.filebased;
 
 import java.io.ByteArrayInputStream;
 import java.io.InputStream;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/hadoop/HadoopFileInputSourceTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/hadoop/HadoopFileInputSourceTest.java b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/hadoop/HadoopFileInputSourceTest.java
index ba2fa5f..af5908b 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/hadoop/HadoopFileInputSourceTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/hadoop/HadoopFileInputSourceTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.hadoop;
+package org.apache.gobblin.source.extractor.hadoop;
 
 import java.io.IOException;
 import java.util.List;
@@ -31,9 +31,9 @@ import org.testng.annotations.Test;
 
 import com.google.common.io.Closer;
 
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.extractor.DataRecordException;
-import gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.extractor.DataRecordException;
+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/source/extractor/hadoop/HadoopFsHelperTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/hadoop/HadoopFsHelperTest.java b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/hadoop/HadoopFsHelperTest.java
index 5af0a53..bb52d92 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/hadoop/HadoopFsHelperTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/hadoop/HadoopFsHelperTest.java
@@ -15,15 +15,15 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.hadoop;
+package org.apache.gobblin.source.extractor.hadoop;
 
 import java.io.IOException;
 import java.io.InputStream;
 import java.net.URL;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.SourceState;
-import gobblin.source.extractor.filebased.FileBasedHelperException;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.SourceState;
+import org.apache.gobblin.source.extractor.filebased.FileBasedHelperException;
 
 import org.apache.commons.io.IOUtils;
 import org.apache.hadoop.conf.Configuration;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/hadoop/OldApiHadoopFileInputSourceTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/hadoop/OldApiHadoopFileInputSourceTest.java b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/hadoop/OldApiHadoopFileInputSourceTest.java
index 104e06b..e28c4a4 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/hadoop/OldApiHadoopFileInputSourceTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/hadoop/OldApiHadoopFileInputSourceTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.hadoop;
+package org.apache.gobblin.source.extractor.hadoop;
 
 import java.io.File;
 import java.io.IOException;
@@ -34,12 +34,12 @@ import org.testng.annotations.Test;
 import com.google.common.io.Closer;
 import com.google.common.io.Files;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.SourceState;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.extractor.DataRecordException;
-import gobblin.source.workunit.Extract;
-import gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.SourceState;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.extractor.DataRecordException;
+import org.apache.gobblin.source.workunit.Extract;
+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/source/extractor/partition/PartitionerTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/partition/PartitionerTest.java b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/partition/PartitionerTest.java
index cfad7b9..d4d2811 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/partition/PartitionerTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/partition/PartitionerTest.java
@@ -1,4 +1,4 @@
-package gobblin.source.extractor.partition;
+package org.apache.gobblin.source.extractor.partition;
 
 import java.util.ArrayList;
 import java.util.Collections;
@@ -8,11 +8,11 @@ import org.joda.time.DateTime;
 import org.testng.Assert;
 import org.testng.annotations.Test;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.SourceState;
-import gobblin.source.extractor.extract.ExtractType;
-import gobblin.source.extractor.utils.Utils;
-import gobblin.source.extractor.watermark.WatermarkType;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.SourceState;
+import org.apache.gobblin.source.extractor.extract.ExtractType;
+import org.apache.gobblin.source.extractor.utils.Utils;
+import org.apache.gobblin.source.extractor.watermark.WatermarkType;
 
 /**
  * Unit tests for {@link PartitionerTest}

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/DateWatermarkTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/DateWatermarkTest.java b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/DateWatermarkTest.java
index 12b0861..2466fdc 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/DateWatermarkTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/DateWatermarkTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.watermark;
+package org.apache.gobblin.source.extractor.watermark;
 
 import java.util.Map;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/HourWatermarkTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/HourWatermarkTest.java b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/HourWatermarkTest.java
index 5654bd9..a631cfd 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/HourWatermarkTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/HourWatermarkTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.watermark;
+package org.apache.gobblin.source.extractor.watermark;
 
 import java.util.Map;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/SimpleWatermarkTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/SimpleWatermarkTest.java b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/SimpleWatermarkTest.java
index dbbc845..d4d8754 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/SimpleWatermarkTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/SimpleWatermarkTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.watermark;
+package org.apache.gobblin.source.extractor.watermark;
 
 import java.util.HashMap;
 import java.util.Map;
@@ -24,7 +24,7 @@ import org.testng.Assert;
 import org.testng.annotations.BeforeClass;
 import org.testng.annotations.Test;
 
-import gobblin.source.extractor.extract.QueryBasedExtractor;
+import org.apache.gobblin.source.extractor.extract.QueryBasedExtractor;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/TimestampWatermarkTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/TimestampWatermarkTest.java b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/TimestampWatermarkTest.java
index 6720da5..bc94a4b 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/TimestampWatermarkTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/source/extractor/watermark/TimestampWatermarkTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.watermark;
+package org.apache.gobblin.source.extractor.watermark;
 
 import java.text.ParseException;
 import java.text.SimpleDateFormat;
@@ -28,7 +28,7 @@ import org.testng.Assert;
 import org.testng.annotations.BeforeClass;
 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/source/workunit/MultiWorkUnitWeightedQueueTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/source/workunit/MultiWorkUnitWeightedQueueTest.java b/gobblin-core/src/test/java/org/apache/gobblin/source/workunit/MultiWorkUnitWeightedQueueTest.java
index 3ee8f0e..cd34f04 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/source/workunit/MultiWorkUnitWeightedQueueTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/source/workunit/MultiWorkUnitWeightedQueueTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.workunit;
+package org.apache.gobblin.source.workunit;
 
 import java.util.List;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/state/ConstructStateTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/state/ConstructStateTest.java b/gobblin-core/src/test/java/org/apache/gobblin/state/ConstructStateTest.java
index fa6c55d..7adca72 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/state/ConstructStateTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/state/ConstructStateTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.state;
+package org.apache.gobblin.state;
 
 import java.util.Properties;
 
@@ -24,8 +24,8 @@ import org.testng.annotations.Test;
 
 import com.google.common.collect.ImmutableMap;
 
-import gobblin.Constructs;
-import gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.Constructs;
+import org.apache.gobblin.configuration.WorkUnitState;
 
 
 public class ConstructStateTest {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/writer/AvroHdfsDataWriterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/AvroHdfsDataWriterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/AvroHdfsDataWriterTest.java
index b729a18..bbe772d 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/writer/AvroHdfsDataWriterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/AvroHdfsDataWriterTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 import java.io.File;
 import java.io.IOException;
@@ -38,9 +38,9 @@ import com.google.gson.Gson;
 import com.google.gson.JsonElement;
 import com.google.gson.reflect.TypeToken;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.util.FinalState;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.util.FinalState;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/writer/CloseOnFlushWriterWrapperTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/CloseOnFlushWriterWrapperTest.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/CloseOnFlushWriterWrapperTest.java
index 84a81ec..11b2274 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/writer/CloseOnFlushWriterWrapperTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/CloseOnFlushWriterWrapperTest.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.ArrayList;
@@ -24,9 +24,9 @@ import java.util.function.Supplier;
 import org.testng.Assert;
 import org.testng.annotations.Test;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.stream.RecordEnvelope;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.stream.RecordEnvelope;
 
 public class CloseOnFlushWriterWrapperTest {
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/writer/ConsoleWriterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/ConsoleWriterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/ConsoleWriterTest.java
index f86752f..8d73aec 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/writer/ConsoleWriterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/ConsoleWriterTest.java
@@ -15,17 +15,17 @@
  * limitations under the License.
  */
 
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 import java.io.IOException;
 
 import org.testng.Assert;
 import org.testng.annotations.Test;
 
-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.Mockito.mock;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/writer/DestinationTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/DestinationTest.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/DestinationTest.java
index 4c28d81..ab18c49 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/writer/DestinationTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/DestinationTest.java
@@ -15,12 +15,12 @@
  * limitations under the License.
  */
 
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 import org.testng.Assert;
 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/writer/MetadataWriterWrapperTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/MetadataWriterWrapperTest.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/MetadataWriterWrapperTest.java
index e73e75d..8eaee91 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/writer/MetadataWriterWrapperTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/MetadataWriterWrapperTest.java
@@ -1,4 +1,4 @@
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 import java.io.IOException;
 import java.util.Arrays;
@@ -7,11 +7,11 @@ import org.testng.Assert;
 import org.testng.annotations.BeforeMethod;
 import org.testng.annotations.Test;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.metadata.types.GlobalMetadata;
-import gobblin.metadata.types.Metadata;
-import gobblin.type.RecordWithMetadata;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.metadata.types.GlobalMetadata;
+import org.apache.gobblin.metadata.types.Metadata;
+import org.apache.gobblin.type.RecordWithMetadata;
 
 
 public class MetadataWriterWrapperTest {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/writer/PartitionedWriterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/PartitionedWriterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/PartitionedWriterTest.java
index 92275c2..6db9cf9 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/writer/PartitionedWriterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/PartitionedWriterTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 import java.io.IOException;
 import java.util.Collections;
@@ -26,14 +26,14 @@ import org.apache.avro.generic.GenericRecord;
 import org.testng.Assert;
 import org.testng.annotations.Test;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.source.extractor.CheckpointableWatermark;
-import gobblin.source.extractor.DefaultCheckpointableWatermark;
-import gobblin.stream.RecordEnvelope;
-import gobblin.source.extractor.extract.LongWatermark;
-import gobblin.writer.test.TestPartitionAwareWriterBuilder;
-import gobblin.writer.test.TestPartitioner;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+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 org.apache.gobblin.writer.test.TestPartitionAwareWriterBuilder;
+import org.apache.gobblin.writer.test.TestPartitioner;
 
 import static org.mockito.Matchers.any;
 import static org.mockito.Mockito.mock;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/writer/RetryWriterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/RetryWriterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/RetryWriterTest.java
index fb1f694..e0d6883 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/writer/RetryWriterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/RetryWriterTest.java
@@ -14,16 +14,16 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 import static org.mockito.Mockito.*;
 
 import java.io.IOException;
 
-import gobblin.configuration.State;
-import gobblin.stream.RecordEnvelope;
-import gobblin.writer.exception.NonTransientException;
-import gobblin.util.FinalState;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.stream.RecordEnvelope;
+import org.apache.gobblin.writer.exception.NonTransientException;
+import org.apache.gobblin.util.FinalState;
 
 import org.junit.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/writer/SimpleDataWriterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/SimpleDataWriterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/SimpleDataWriterTest.java
index fd2d5d8..020ad5e 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/writer/SimpleDataWriterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/SimpleDataWriterTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 import java.io.BufferedReader;
 import java.io.DataInputStream;
@@ -41,11 +41,11 @@ import org.testng.annotations.Test;
 
 import com.google.common.collect.ImmutableList;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.crypto.EncryptionConfigParser;
-import gobblin.crypto.EncryptionFactory;
-import gobblin.metadata.types.GlobalMetadata;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.crypto.EncryptionConfigParser;
+import org.apache.gobblin.crypto.EncryptionFactory;
+import org.apache.gobblin.metadata.types.GlobalMetadata;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/writer/TestConstants.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/TestConstants.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/TestConstants.java
index 71e7f0a..8af13b8 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/writer/TestConstants.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/TestConstants.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 /**
  * Test constants.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/writer/ThrottleWriterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/ThrottleWriterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/ThrottleWriterTest.java
index b945b45..0fd4dd1 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/writer/ThrottleWriterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/ThrottleWriterTest.java
@@ -14,17 +14,17 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 import static org.mockito.Mockito.*;
 
 import java.io.IOException;
 import java.util.concurrent.TimeUnit;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.writer.ThrottleWriter.ThrottleType;
-import gobblin.util.FinalState;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.writer.ThrottleWriter.ThrottleType;
+import org.apache.gobblin.util.FinalState;
 
 import org.apache.commons.lang3.mutable.MutableLong;
 import org.mockito.invocation.InvocationOnMock;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/writer/http/SalesforceRestWriterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/http/SalesforceRestWriterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/http/SalesforceRestWriterTest.java
index 2d8ec90..07adcc0 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/writer/http/SalesforceRestWriterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/http/SalesforceRestWriterTest.java
@@ -14,19 +14,19 @@
  * 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 static org.mockito.Mockito.*;
-import static gobblin.writer.http.SalesForceRestWriterBuilder.*;
+import static org.apache.gobblin.writer.http.SalesForceRestWriterBuilder.*;
 
 import java.io.ByteArrayInputStream;
 import java.io.IOException;
 import java.net.URI;
 import java.net.URISyntaxException;
 
-import gobblin.configuration.State;
-import gobblin.converter.http.RestEntry;
-import gobblin.writer.http.SalesforceRestWriter.Operation;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.converter.http.RestEntry;
+import org.apache.gobblin.writer.http.SalesforceRestWriter.Operation;
 
 import org.apache.http.HttpEntity;
 import org.apache.http.StatusLine;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/writer/objectstore/ObjectStoreWriterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/objectstore/ObjectStoreWriterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/objectstore/ObjectStoreWriterTest.java
index 2214dcd..cd2ae9e 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/writer/objectstore/ObjectStoreWriterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/objectstore/ObjectStoreWriterTest.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;
@@ -34,10 +34,10 @@ import com.google.common.collect.Maps;
 import com.typesafe.config.Config;
 import com.typesafe.config.ConfigFactory;
 
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.objectstore.ObjectStoreDeleteConverter;
-import gobblin.writer.objectstore.response.GetObjectResponse;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.objectstore.ObjectStoreDeleteConverter;
+import org.apache.gobblin.writer.objectstore.response.GetObjectResponse;
 
 
 public class ObjectStoreWriterTest {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/writer/partitioner/SchemaBasedWriterPartitionerTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/partitioner/SchemaBasedWriterPartitionerTest.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/partitioner/SchemaBasedWriterPartitionerTest.java
index 6d4d719..dbb0522 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/writer/partitioner/SchemaBasedWriterPartitionerTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/partitioner/SchemaBasedWriterPartitionerTest.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/src/test/java/org/apache/gobblin/writer/partitioner/TimeBasedAvroWriterPartitionerTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/partitioner/TimeBasedAvroWriterPartitionerTest.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/partitioner/TimeBasedAvroWriterPartitionerTest.java
index 65fa24f..e593aa1 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/writer/partitioner/TimeBasedAvroWriterPartitionerTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/partitioner/TimeBasedAvroWriterPartitionerTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.writer.partitioner;
+package org.apache.gobblin.writer.partitioner;
 
 import java.io.File;
 import java.io.IOException;
@@ -31,15 +31,15 @@ import org.testng.annotations.AfterClass;
 import org.testng.annotations.BeforeClass;
 import org.testng.annotations.Test;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.stream.RecordEnvelope;
-import gobblin.writer.AvroDataWriterBuilder;
-import gobblin.writer.DataWriter;
-import gobblin.writer.DataWriterBuilder;
-import gobblin.writer.Destination;
-import gobblin.writer.PartitionedDataWriter;
-import gobblin.writer.WriterOutputFormat;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.stream.RecordEnvelope;
+import org.apache.gobblin.writer.AvroDataWriterBuilder;
+import org.apache.gobblin.writer.DataWriter;
+import org.apache.gobblin.writer.DataWriterBuilder;
+import org.apache.gobblin.writer.Destination;
+import org.apache.gobblin.writer.PartitionedDataWriter;
+import org.apache.gobblin.writer.WriterOutputFormat;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/writer/test/GobblinTestEventBusWriterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/test/GobblinTestEventBusWriterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/test/GobblinTestEventBusWriterTest.java
index 3b0c1bd..026f0a7 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/writer/test/GobblinTestEventBusWriterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/test/GobblinTestEventBusWriterTest.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.TimeoutException;
@@ -22,9 +22,9 @@ import java.util.concurrent.TimeoutException;
 import org.testng.Assert;
 import org.testng.annotations.Test;
 
-import gobblin.source.workunit.WorkUnit;
-import gobblin.writer.Destination;
-import gobblin.writer.Destination.DestinationType;
+import org.apache.gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.writer.Destination;
+import org.apache.gobblin.writer.Destination.DestinationType;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/writer/test/TestPartitionAwareWriterBuilder.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/test/TestPartitionAwareWriterBuilder.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/test/TestPartitionAwareWriterBuilder.java
index 75fe6c5..8b1e0ca 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/writer/test/TestPartitionAwareWriterBuilder.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/test/TestPartitionAwareWriterBuilder.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.writer.test;
+package org.apache.gobblin.writer.test;
 
 import java.io.IOException;
 import java.util.Queue;
@@ -24,9 +24,9 @@ import org.apache.avro.Schema;
 
 import com.google.common.collect.Queues;
 
-import gobblin.commit.SpeculativeAttemptAwareConstruct;
-import gobblin.writer.DataWriter;
-import gobblin.writer.PartitionAwareDataWriterBuilder;
+import org.apache.gobblin.commit.SpeculativeAttemptAwareConstruct;
+import org.apache.gobblin.writer.DataWriter;
+import org.apache.gobblin.writer.PartitionAwareDataWriterBuilder;
 
 import lombok.Data;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/writer/test/TestPartitioner.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/test/TestPartitioner.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/test/TestPartitioner.java
index dfdce01..affdf20 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/writer/test/TestPartitioner.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/test/TestPartitioner.java
@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package gobblin.writer.test;
+package org.apache.gobblin.writer.test;
 
-import gobblin.configuration.State;
-import gobblin.writer.partitioner.WriterPartitioner;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.writer.partitioner.WriterPartitioner;
 
 import org.apache.avro.Schema;
 import org.apache.avro.SchemaBuilder;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/java/org/apache/gobblin/writer/test/TestingEventBusAsserterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/test/TestingEventBusAsserterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/test/TestingEventBusAsserterTest.java
index a9a8cd3..8a4bf39 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/writer/test/TestingEventBusAsserterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/test/TestingEventBusAsserterTest.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.Arrays;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/test/resources/converter/record_with_arrays.avsc
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/resources/converter/record_with_arrays.avsc b/gobblin-core/src/test/resources/converter/record_with_arrays.avsc
index ba6beb5..b979e0a 100644
--- a/gobblin-core/src/test/resources/converter/record_with_arrays.avsc
+++ b/gobblin-core/src/test/resources/converter/record_with_arrays.avsc
@@ -1,7 +1,7 @@
 {
     "name": "NestedTestRecord",
     "type": "record",
-    "namespace": "gobblin.test",
+    "namesapce" : "org.apache.gobblin.test",
     "fields": [
         {
             "name": "fieldToEncrypt",

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/avro/AvroSchemaManager.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/avro/AvroSchemaManager.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/avro/AvroSchemaManager.java
index cadee5d..4d99825 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/avro/AvroSchemaManager.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/avro/AvroSchemaManager.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.data.management.conversion.hive.avro;
+package org.apache.gobblin.data.management.conversion.hive.avro;
 
 import java.io.IOException;
 import java.net.URI;
@@ -36,12 +36,12 @@ import com.google.common.base.Preconditions;
 import com.google.common.collect.Maps;
 import com.google.common.hash.Hashing;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.data.management.conversion.hive.query.HiveAvroORCQueryGenerator;
-import gobblin.hive.avro.HiveAvroSerDeManager;
-import gobblin.util.AvroUtils;
-import gobblin.util.HadoopUtils;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.data.management.conversion.hive.query.HiveAvroORCQueryGenerator;
+import org.apache.gobblin.hive.avro.HiveAvroSerDeManager;
+import org.apache.gobblin.util.AvroUtils;
+import org.apache.gobblin.util.HadoopUtils;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/avro/SchemaNotFoundException.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/avro/SchemaNotFoundException.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/avro/SchemaNotFoundException.java
index f954087..0f7e09d 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/avro/SchemaNotFoundException.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/avro/SchemaNotFoundException.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.data.management.conversion.hive.avro;
+package org.apache.gobblin.data.management.conversion.hive.avro;
 
 /**
  * An exception thrown when Schema was not found.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/AbstractAvroToOrcConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/AbstractAvroToOrcConverter.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/AbstractAvroToOrcConverter.java
index a9265b7..4687276 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/AbstractAvroToOrcConverter.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/AbstractAvroToOrcConverter.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.data.management.conversion.hive.converter;
+package org.apache.gobblin.data.management.conversion.hive.converter;
 
 import java.io.IOException;
 import java.util.Arrays;
@@ -53,23 +53,23 @@ import com.google.common.collect.ImmutableMap;
 import com.google.common.collect.Lists;
 import com.google.common.collect.Maps;
 
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.Converter;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.SingleRecordIterable;
-import gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDataset;
-import gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDataset.ConversionConfig;
-import gobblin.data.management.conversion.hive.entities.QueryBasedHiveConversionEntity;
-import gobblin.data.management.conversion.hive.entities.QueryBasedHivePublishEntity;
-import gobblin.data.management.conversion.hive.events.EventWorkunitUtils;
-import gobblin.data.management.conversion.hive.query.HiveAvroORCQueryGenerator;
-import gobblin.data.management.copy.hive.HiveDatasetFinder;
-import gobblin.data.management.copy.hive.HiveUtils;
-import gobblin.data.management.copy.hive.WhitelistBlacklist;
-import gobblin.hive.HiveMetastoreClientPool;
-import gobblin.metrics.event.sla.SlaEventKeys;
-import gobblin.util.AutoReturnableObject;
-import gobblin.util.HadoopUtils;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.Converter;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.SingleRecordIterable;
+import org.apache.gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDataset;
+import org.apache.gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDataset.ConversionConfig;
+import org.apache.gobblin.data.management.conversion.hive.entities.QueryBasedHiveConversionEntity;
+import org.apache.gobblin.data.management.conversion.hive.entities.QueryBasedHivePublishEntity;
+import org.apache.gobblin.data.management.conversion.hive.events.EventWorkunitUtils;
+import org.apache.gobblin.data.management.conversion.hive.query.HiveAvroORCQueryGenerator;
+import org.apache.gobblin.data.management.copy.hive.HiveDatasetFinder;
+import org.apache.gobblin.data.management.copy.hive.HiveUtils;
+import org.apache.gobblin.data.management.copy.hive.WhitelistBlacklist;
+import org.apache.gobblin.hive.HiveMetastoreClientPool;
+import org.apache.gobblin.metrics.event.sla.SlaEventKeys;
+import org.apache.gobblin.util.AutoReturnableObject;
+import org.apache.gobblin.util.HadoopUtils;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/HiveAvroToFlattenedOrcConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/HiveAvroToFlattenedOrcConverter.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/HiveAvroToFlattenedOrcConverter.java
index cc392e0..51fa101 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/HiveAvroToFlattenedOrcConverter.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/HiveAvroToFlattenedOrcConverter.java
@@ -14,13 +14,13 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.data.management.conversion.hive.converter;
+package org.apache.gobblin.data.management.conversion.hive.converter;
 
 import org.apache.avro.Schema;
 
-import gobblin.configuration.WorkUnitState;
-import gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDataset.ConversionConfig;
-import gobblin.util.AvroFlattener;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDataset.ConversionConfig;
+import org.apache.gobblin.util.AvroFlattener;
 
 /**
  * An Avro to ORC converter for avro to flattened ORC. {@link OrcFormats#FLATTENED_ORC}

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/HiveAvroToNestedOrcConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/HiveAvroToNestedOrcConverter.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/HiveAvroToNestedOrcConverter.java
index b786cee..8bf01cf 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/HiveAvroToNestedOrcConverter.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/HiveAvroToNestedOrcConverter.java
@@ -14,12 +14,12 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.data.management.conversion.hive.converter;
+package org.apache.gobblin.data.management.conversion.hive.converter;
 
 import org.apache.avro.Schema;
 
-import gobblin.configuration.WorkUnitState;
-import gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDataset.ConversionConfig;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDataset.ConversionConfig;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/dataset/ConvertibleHiveDataset.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/dataset/ConvertibleHiveDataset.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/dataset/ConvertibleHiveDataset.java
index 07f8854..ba42811 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/dataset/ConvertibleHiveDataset.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/dataset/ConvertibleHiveDataset.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.data.management.conversion.hive.dataset;
+package org.apache.gobblin.data.management.conversion.hive.dataset;
 
 import java.util.List;
 import java.util.Map;
@@ -34,10 +34,10 @@ import com.google.common.collect.Maps;
 import com.google.common.collect.Sets;
 import com.typesafe.config.Config;
 
-import gobblin.data.management.copy.hive.HiveDataset;
-import gobblin.data.management.copy.hive.HiveDatasetFinder;
-import gobblin.hive.HiveMetastoreClientPool;
-import gobblin.util.ConfigUtils;
+import org.apache.gobblin.data.management.copy.hive.HiveDataset;
+import org.apache.gobblin.data.management.copy.hive.HiveDatasetFinder;
+import org.apache.gobblin.hive.HiveMetastoreClientPool;
+import org.apache.gobblin.util.ConfigUtils;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/dataset/ConvertibleHiveDatasetFinder.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/dataset/ConvertibleHiveDatasetFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/dataset/ConvertibleHiveDatasetFinder.java
index 7be1320..61fbd31 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/dataset/ConvertibleHiveDatasetFinder.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/dataset/ConvertibleHiveDatasetFinder.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.data.management.conversion.hive.dataset;
+package org.apache.gobblin.data.management.conversion.hive.dataset;
 
 import java.io.IOException;
 import java.util.Properties;
@@ -24,8 +24,8 @@ import org.apache.hadoop.hive.metastore.api.Table;
 
 import com.typesafe.config.Config;
 
-import gobblin.data.management.copy.hive.HiveDatasetFinder;
-import gobblin.metrics.event.EventSubmitter;
+import org.apache.gobblin.data.management.copy.hive.HiveDatasetFinder;
+import org.apache.gobblin.metrics.event.EventSubmitter;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/QueryBasedHiveConversionEntity.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/QueryBasedHiveConversionEntity.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/QueryBasedHiveConversionEntity.java
index 1cf9836..1486fe5 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/QueryBasedHiveConversionEntity.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/QueryBasedHiveConversionEntity.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.data.management.conversion.hive.entities;
+package org.apache.gobblin.data.management.conversion.hive.entities;
 
 import java.util.List;
 
@@ -25,15 +25,15 @@ import lombok.ToString;
 import com.google.common.base.Optional;
 import com.google.common.collect.Lists;
 
-import gobblin.converter.Converter;
-import gobblin.data.management.conversion.hive.converter.AbstractAvroToOrcConverter;
-import gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDataset;
-import gobblin.data.management.conversion.hive.extractor.HiveConvertExtractor;
-import gobblin.data.management.conversion.hive.writer.HiveQueryExecutionWriter;
-import gobblin.hive.HivePartition;
-import gobblin.hive.HiveRegistrationUnit;
-import gobblin.hive.HiveTable;
-import gobblin.source.extractor.Extractor;
+import org.apache.gobblin.converter.Converter;
+import org.apache.gobblin.data.management.conversion.hive.converter.AbstractAvroToOrcConverter;
+import org.apache.gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDataset;
+import org.apache.gobblin.data.management.conversion.hive.extractor.HiveConvertExtractor;
+import org.apache.gobblin.data.management.conversion.hive.writer.HiveQueryExecutionWriter;
+import org.apache.gobblin.hive.HivePartition;
+import org.apache.gobblin.hive.HiveRegistrationUnit;
+import org.apache.gobblin.hive.HiveTable;
+import org.apache.gobblin.source.extractor.Extractor;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/QueryBasedHivePublishEntity.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/QueryBasedHivePublishEntity.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/QueryBasedHivePublishEntity.java
index 01d2156..26ab758 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/QueryBasedHivePublishEntity.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/QueryBasedHivePublishEntity.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.data.management.conversion.hive.entities;
+package org.apache.gobblin.data.management.conversion.hive.entities;
 
 import java.util.List;
 import java.util.Map;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/SchemaAwareHivePartition.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/SchemaAwareHivePartition.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/SchemaAwareHivePartition.java
index 6bc4bb1..9e1828e 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/SchemaAwareHivePartition.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/SchemaAwareHivePartition.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.data.management.conversion.hive.entities;
+package org.apache.gobblin.data.management.conversion.hive.entities;
 
 import lombok.Getter;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/SchemaAwareHiveTable.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/SchemaAwareHiveTable.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/SchemaAwareHiveTable.java
index a985258..575ccc2 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/SchemaAwareHiveTable.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/entities/SchemaAwareHiveTable.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.data.management.conversion.hive.entities;
+package org.apache.gobblin.data.management.conversion.hive.entities;
 
 import lombok.EqualsAndHashCode;
 import lombok.Getter;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/events/EventConstants.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/events/EventConstants.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/events/EventConstants.java
index 0cf0719..826c489 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/events/EventConstants.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/events/EventConstants.java
@@ -14,9 +14,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.data.management.conversion.hive.events;
+package org.apache.gobblin.data.management.conversion.hive.events;
 
-import gobblin.metrics.event.sla.SlaEventKeys;
+import org.apache.gobblin.metrics.event.sla.SlaEventKeys;
 
 /**
  * Event names and metadata names used by hive conversion.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/events/EventWorkunitUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/events/EventWorkunitUtils.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/events/EventWorkunitUtils.java
index 5da1680..71c821d 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/events/EventWorkunitUtils.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/events/EventWorkunitUtils.java
@@ -14,19 +14,19 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.data.management.conversion.hive.events;
+package org.apache.gobblin.data.management.conversion.hive.events;
 
 import java.util.List;
 
 import org.apache.hadoop.hive.ql.metadata.Partition;
 import org.apache.hadoop.hive.ql.metadata.Table;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.metrics.event.sla.SlaEventKeys;
-import gobblin.source.extractor.extract.LongWatermark;
-import gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.metrics.event.sla.SlaEventKeys;
+import org.apache.gobblin.source.extractor.extract.LongWatermark;
+import org.apache.gobblin.source.workunit.WorkUnit;
 
 /**
  * Utilities to set event metadata into {@link WorkUnit}s

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveBaseExtractor.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveBaseExtractor.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveBaseExtractor.java
index 4eb3263..107fa89 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveBaseExtractor.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveBaseExtractor.java
@@ -15,17 +15,17 @@
  * limitations under the License.
  */
 
-package gobblin.data.management.conversion.hive.extractor;
+package org.apache.gobblin.data.management.conversion.hive.extractor;
 
 import java.io.IOException;
 import com.google.common.base.Optional;
-import gobblin.configuration.WorkUnitState;
-import gobblin.data.management.conversion.hive.source.HiveWorkUnit;
-import gobblin.data.management.conversion.hive.watermarker.PartitionLevelWatermarker;
-import gobblin.data.management.copy.hive.HiveDataset;
-import gobblin.data.management.copy.hive.HiveDatasetFinder;
-import gobblin.hive.HiveMetastoreClientPool;
-import gobblin.source.extractor.Extractor;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.data.management.conversion.hive.source.HiveWorkUnit;
+import org.apache.gobblin.data.management.conversion.hive.watermarker.PartitionLevelWatermarker;
+import org.apache.gobblin.data.management.copy.hive.HiveDataset;
+import org.apache.gobblin.data.management.copy.hive.HiveDatasetFinder;
+import org.apache.gobblin.hive.HiveMetastoreClientPool;
+import org.apache.gobblin.source.extractor.Extractor;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveBaseExtractorFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveBaseExtractorFactory.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveBaseExtractorFactory.java
index 08680ec..d5a3489 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveBaseExtractorFactory.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveBaseExtractorFactory.java
@@ -15,13 +15,13 @@
  * limitations under the License.
  */
 
-package gobblin.data.management.conversion.hive.extractor;
+package org.apache.gobblin.data.management.conversion.hive.extractor;
 
 import java.io.IOException;
 import org.apache.hadoop.fs.FileSystem;
 import org.apache.hadoop.hive.ql.metadata.HiveException;
 import org.apache.thrift.TException;
-import gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.configuration.WorkUnitState;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveConvertExtractor.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveConvertExtractor.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveConvertExtractor.java
index c02d41e..c00292b 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveConvertExtractor.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveConvertExtractor.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.data.management.conversion.hive.extractor;
+package org.apache.gobblin.data.management.conversion.hive.extractor;
 
 import java.io.IOException;
 import java.util.List;
@@ -33,16 +33,16 @@ import org.apache.thrift.TException;
 import com.google.common.base.Optional;
 import com.google.common.collect.Lists;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.data.management.conversion.hive.avro.AvroSchemaManager;
-import gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDataset;
-import gobblin.data.management.conversion.hive.entities.QueryBasedHiveConversionEntity;
-import gobblin.data.management.conversion.hive.entities.SchemaAwareHivePartition;
-import gobblin.data.management.conversion.hive.entities.SchemaAwareHiveTable;
-import gobblin.data.management.conversion.hive.watermarker.PartitionLevelWatermarker;
-import gobblin.source.extractor.DataRecordException;
-import gobblin.util.AutoReturnableObject;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.data.management.conversion.hive.avro.AvroSchemaManager;
+import org.apache.gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDataset;
+import org.apache.gobblin.data.management.conversion.hive.entities.QueryBasedHiveConversionEntity;
+import org.apache.gobblin.data.management.conversion.hive.entities.SchemaAwareHivePartition;
+import org.apache.gobblin.data.management.conversion.hive.entities.SchemaAwareHiveTable;
+import org.apache.gobblin.data.management.conversion.hive.watermarker.PartitionLevelWatermarker;
+import org.apache.gobblin.source.extractor.DataRecordException;
+import org.apache.gobblin.util.AutoReturnableObject;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveConvertExtractorFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveConvertExtractorFactory.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveConvertExtractorFactory.java
index 4a2c48c..4a190d8 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveConvertExtractorFactory.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveConvertExtractorFactory.java
@@ -15,13 +15,13 @@
  * limitations under the License.
  */
 
-package gobblin.data.management.conversion.hive.extractor;
+package org.apache.gobblin.data.management.conversion.hive.extractor;
 
 import java.io.IOException;
 import org.apache.hadoop.fs.FileSystem;
 import org.apache.hadoop.hive.ql.metadata.HiveException;
 import org.apache.thrift.TException;
-import gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.configuration.WorkUnitState;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/provider/DatePatternUpdateProvider.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/provider/DatePatternUpdateProvider.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/provider/DatePatternUpdateProvider.java
index 16154b3..6337856 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/provider/DatePatternUpdateProvider.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/provider/DatePatternUpdateProvider.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.data.management.conversion.hive.provider;
+package org.apache.gobblin.data.management.conversion.hive.provider;
 
 import java.util.Arrays;
 
@@ -27,7 +27,7 @@ import org.joda.time.DateTimeZone;
 import org.joda.time.format.DateTimeFormat;
 import org.joda.time.format.DateTimeFormatter;
 
-import gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.ConfigurationKeys;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/provider/HdfsBasedUpdateProvider.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/provider/HdfsBasedUpdateProvider.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/provider/HdfsBasedUpdateProvider.java
index 7eaa369..bd2fe77 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/provider/HdfsBasedUpdateProvider.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/provider/HdfsBasedUpdateProvider.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.data.management.conversion.hive.provider;
+package org.apache.gobblin.data.management.conversion.hive.provider;
 
 import java.io.IOException;
 import java.util.concurrent.Callable;
@@ -30,8 +30,8 @@ import org.apache.hadoop.hive.ql.metadata.Table;
 import com.google.common.cache.Cache;
 import com.google.common.cache.CacheBuilder;
 
-import gobblin.hive.HivePartition;
-import gobblin.hive.HiveTable;
+import org.apache.gobblin.hive.HivePartition;
+import org.apache.gobblin.hive.HiveTable;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/provider/HiveMetastoreBasedUpdateProvider.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/provider/HiveMetastoreBasedUpdateProvider.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/provider/HiveMetastoreBasedUpdateProvider.java
index 619a274..2c33ef9 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/provider/HiveMetastoreBasedUpdateProvider.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/provider/HiveMetastoreBasedUpdateProvider.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.data.management.conversion.hive.provider;
+package org.apache.gobblin.data.management.conversion.hive.provider;
 
 import java.util.concurrent.TimeUnit;
 
@@ -23,7 +23,7 @@ import lombok.NoArgsConstructor;
 import org.apache.hadoop.hive.ql.metadata.Partition;
 import org.apache.hadoop.hive.ql.metadata.Table;
 
-import gobblin.annotation.Alpha;
+import org.apache.gobblin.annotation.Alpha;
 
 
 /**


Mime
View raw message