You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gobblin.apache.org by ab...@apache.org on 2017/07/31 07:52:45 UTC
[27/77] [abbrv] incubator-gobblin git commit: Updated package names,
imports and shell scripts
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;
/**