gobblin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a...@apache.org
Subject [29/77] [abbrv] incubator-gobblin git commit: Updated package names, imports and shell scripts
Date Mon, 31 Jul 2017 07:52:47 GMT
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/restapi/RestApiExtractor.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/restapi/RestApiExtractor.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/restapi/RestApiExtractor.java
index 803bc5c..b9eeddd 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/restapi/RestApiExtractor.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/restapi/RestApiExtractor.java
@@ -15,13 +15,13 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.extract.restapi;
+package org.apache.gobblin.source.extractor.extract.restapi;
 
 import com.google.common.collect.ImmutableList;
 
-import gobblin.source.extractor.exception.RestApiConnectionException;
-import gobblin.source.extractor.exception.RestApiProcessingException;
-import gobblin.source.extractor.utils.Utils;
+import org.apache.gobblin.source.extractor.exception.RestApiConnectionException;
+import org.apache.gobblin.source.extractor.exception.RestApiProcessingException;
+import org.apache.gobblin.source.extractor.utils.Utils;
 
 import java.io.IOException;
 import java.util.Iterator;
@@ -35,19 +35,19 @@ import com.google.gson.JsonElement;
 import com.google.gson.JsonObject;
 import com.google.common.base.Splitter;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.extractor.watermark.Predicate;
-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.extract.QueryBasedExtractor;
-import gobblin.source.extractor.extract.Command;
-import gobblin.source.extractor.extract.CommandOutput;
-import gobblin.source.extractor.extract.SourceSpecificLayer;
-import gobblin.source.extractor.schema.Schema;
-import gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.extractor.watermark.Predicate;
+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.extract.QueryBasedExtractor;
+import org.apache.gobblin.source.extractor.extract.Command;
+import org.apache.gobblin.source.extractor.extract.CommandOutput;
+import org.apache.gobblin.source.extractor.extract.SourceSpecificLayer;
+import org.apache.gobblin.source.extractor.schema.Schema;
+import org.apache.gobblin.source.workunit.WorkUnit;
 import lombok.extern.slf4j.Slf4j;
 
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/restapi/RestApiSpecificLayer.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/restapi/RestApiSpecificLayer.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/restapi/RestApiSpecificLayer.java
index 51200bc..6bc96d0 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/restapi/RestApiSpecificLayer.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/restapi/RestApiSpecificLayer.java
@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.extract.restapi;
+package org.apache.gobblin.source.extractor.extract.restapi;
 
-import gobblin.source.extractor.exception.RestApiConnectionException;
+import org.apache.gobblin.source.extractor.exception.RestApiConnectionException;
 
 import org.apache.http.HttpEntity;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/sftp/SftpExtractor.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/sftp/SftpExtractor.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/sftp/SftpExtractor.java
index 9e401fe..a4e9ec0 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/sftp/SftpExtractor.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/sftp/SftpExtractor.java
@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.extract.sftp;
+package org.apache.gobblin.source.extractor.extract.sftp;
 
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.extractor.filebased.FileBasedExtractor;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.extractor.filebased.FileBasedExtractor;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/sftp/SftpFsHelper.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/sftp/SftpFsHelper.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/sftp/SftpFsHelper.java
index a67b2a3..694c3dd 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/sftp/SftpFsHelper.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/sftp/SftpFsHelper.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.extract.sftp;
+package org.apache.gobblin.source.extractor.extract.sftp;
 
 import java.io.File;
 import java.io.IOException;
@@ -47,12 +47,12 @@ import com.jcraft.jsch.SftpException;
 import com.jcraft.jsch.SftpProgressMonitor;
 import com.jcraft.jsch.UserInfo;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.password.PasswordManager;
-import gobblin.source.extractor.filebased.FileBasedHelperException;
-import gobblin.source.extractor.filebased.TimestampAwareFileBasedHelper;
-import gobblin.util.io.SeekableFSInputStream;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.password.PasswordManager;
+import org.apache.gobblin.source.extractor.filebased.FileBasedHelperException;
+import org.apache.gobblin.source.extractor.filebased.TimestampAwareFileBasedHelper;
+import org.apache.gobblin.util.io.SeekableFSInputStream;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/sftp/SftpLightWeightFileSystem.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/sftp/SftpLightWeightFileSystem.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/sftp/SftpLightWeightFileSystem.java
index ced1e9f..6b79cd0 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/sftp/SftpLightWeightFileSystem.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/sftp/SftpLightWeightFileSystem.java
@@ -15,13 +15,13 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.extract.sftp;
+package org.apache.gobblin.source.extractor.extract.sftp;
 
-import gobblin.configuration.State;
-import gobblin.source.extractor.extract.sftp.SftpFsHelper.SftpGetMonitor;
-import gobblin.source.extractor.filebased.FileBasedHelperException;
-import gobblin.util.HadoopUtils;
-import gobblin.util.io.SeekableFSInputStream;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.source.extractor.extract.sftp.SftpFsHelper.SftpGetMonitor;
+import org.apache.gobblin.source.extractor.filebased.FileBasedHelperException;
+import org.apache.gobblin.util.HadoopUtils;
+import org.apache.gobblin.util.io.SeekableFSInputStream;
 
 import java.io.IOException;
 import java.io.InputStream;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/sftp/SftpSource.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/sftp/SftpSource.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/sftp/SftpSource.java
index 2f6358f..710d7e2 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/sftp/SftpSource.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/sftp/SftpSource.java
@@ -15,15 +15,15 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.extract.sftp;
+package org.apache.gobblin.source.extractor.extract.sftp;
 
-import gobblin.source.extractor.Extractor;
-import gobblin.source.extractor.filebased.FileBasedHelperException;
+import org.apache.gobblin.source.extractor.Extractor;
+import org.apache.gobblin.source.extractor.filebased.FileBasedHelperException;
 import java.io.IOException;
 
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.extractor.filebased.FileBasedSource;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.extractor.filebased.FileBasedSource;
 
 
 public class SftpSource<S, D> extends FileBasedSource<S, D> {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/CsvFileDownloader.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/CsvFileDownloader.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/CsvFileDownloader.java
index 7255b7b..62828a3 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/CsvFileDownloader.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/CsvFileDownloader.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.source.extractor.filebased;
+package org.apache.gobblin.source.extractor.filebased;
 
 import java.io.IOException;
 import java.io.InputStreamReader;
@@ -27,8 +27,8 @@ import com.opencsv.CSVReader;
 
 import lombok.extern.slf4j.Slf4j;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
 
 /**
  * A {@link FileDownloader} that downloads a single file and iterates line by line.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/FileBasedExtractor.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/FileBasedExtractor.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/FileBasedExtractor.java
index 99e0508..a8becca 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/FileBasedExtractor.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/FileBasedExtractor.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;
 import java.lang.reflect.InvocationTargetException;
@@ -31,12 +31,12 @@ import org.slf4j.LoggerFactory;
 import com.google.common.collect.Lists;
 import com.google.common.io.Closer;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.instrumented.extractor.InstrumentedExtractor;
-import gobblin.metrics.Counters;
-import gobblin.source.extractor.DataRecordException;
-import gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.instrumented.extractor.InstrumentedExtractor;
+import org.apache.gobblin.metrics.Counters;
+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/main/java/org/apache/gobblin/source/extractor/filebased/FileBasedHelper.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/FileBasedHelper.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/FileBasedHelper.java
index 92faa98..2239702 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/FileBasedHelper.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/FileBasedHelper.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.filebased;
+package org.apache.gobblin.source.extractor.filebased;
 
 import java.io.Closeable;
 import java.io.InputStream;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/FileBasedHelperException.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/FileBasedHelperException.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/FileBasedHelperException.java
index bd52b79..33ae4e8 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/FileBasedHelperException.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/FileBasedHelperException.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.filebased;
+package org.apache.gobblin.source.extractor.filebased;
 
 public class FileBasedHelperException extends Exception {
   private static final long serialVersionUID = 1L;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/FileBasedSource.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/FileBasedSource.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/FileBasedSource.java
index 07310af..a26b052 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/FileBasedSource.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/FileBasedSource.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.filebased;
+package org.apache.gobblin.source.extractor.filebased;
 
 import java.io.File;
 import java.io.IOException;
@@ -39,14 +39,14 @@ import com.google.common.base.Throwables;
 import com.google.common.collect.Lists;
 import com.google.common.collect.Sets;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.SourceState;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.extractor.extract.AbstractSource;
-import gobblin.source.workunit.Extract;
-import gobblin.source.workunit.WorkUnit;
-import gobblin.source.workunit.Extract.TableType;
+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.extract.AbstractSource;
+import org.apache.gobblin.source.workunit.Extract;
+import org.apache.gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.source.workunit.Extract.TableType;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/FileByteIterator.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/FileByteIterator.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/FileByteIterator.java
index 53eea0a..af3d295 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/FileByteIterator.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/FileByteIterator.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.filebased;
+package org.apache.gobblin.source.extractor.filebased;
 
 import java.io.BufferedInputStream;
 import java.io.IOException;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/FileDownloader.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/FileDownloader.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/FileDownloader.java
index 44b002c..fbc6d10 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/FileDownloader.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/FileDownloader.java
@@ -14,12 +14,12 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.source.extractor.filebased;
+package org.apache.gobblin.source.extractor.filebased;
 
 import java.io.IOException;
 import java.util.Iterator;
 
-import gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.ConfigurationKeys;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/GZIPFileDownloader.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/GZIPFileDownloader.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/GZIPFileDownloader.java
index 8bd373d..1142418 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/GZIPFileDownloader.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/GZIPFileDownloader.java
@@ -14,9 +14,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.source.extractor.filebased;
+package org.apache.gobblin.source.extractor.filebased;
 
-import gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.ConfigurationKeys;
 
 import java.io.IOException;
 import java.io.InputStream;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/SingleFileDownloader.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/SingleFileDownloader.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/SingleFileDownloader.java
index 51424d3..43df80e 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/SingleFileDownloader.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/SingleFileDownloader.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.source.extractor.filebased;
+package org.apache.gobblin.source.extractor.filebased;
 
 import java.io.IOException;
 import java.io.InputStream;
@@ -24,7 +24,7 @@ import lombok.extern.slf4j.Slf4j;
 
 import org.apache.commons.io.IOUtils;
 
-import gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.ConfigurationKeys;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/SizeAwareFileBasedHelper.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/SizeAwareFileBasedHelper.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/SizeAwareFileBasedHelper.java
index 95dcbfa..5d2eed2 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/SizeAwareFileBasedHelper.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/SizeAwareFileBasedHelper.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.filebased;
+package org.apache.gobblin.source.extractor.filebased;
 
 /**
  * A File helper that extends {@link FileBasedHelper} and has functionality to get file size.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/SizeAwareFileBasedHelperDecorator.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/SizeAwareFileBasedHelperDecorator.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/SizeAwareFileBasedHelperDecorator.java
index 2604ba4..8d20ab7 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/SizeAwareFileBasedHelperDecorator.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/SizeAwareFileBasedHelperDecorator.java
@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.filebased;
+package org.apache.gobblin.source.extractor.filebased;
 
-import gobblin.util.Decorator;
+import org.apache.gobblin.util.Decorator;
 
 import java.io.IOException;
 import java.io.InputStream;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/TextFileBasedSource.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/TextFileBasedSource.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/TextFileBasedSource.java
index 8a45456..ae623a3 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/TextFileBasedSource.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/TextFileBasedSource.java
@@ -15,17 +15,17 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.filebased;
+package org.apache.gobblin.source.extractor.filebased;
 
 import java.io.IOException;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.extractor.Extractor;
-import gobblin.source.extractor.hadoop.HadoopFsHelper;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.extractor.Extractor;
+import org.apache.gobblin.source.extractor.hadoop.HadoopFsHelper;
 
-import static gobblin.configuration.ConfigurationKeys.*;
+import static org.apache.gobblin.configuration.ConfigurationKeys.*;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/TimestampAwareFileBasedHelper.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/TimestampAwareFileBasedHelper.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/TimestampAwareFileBasedHelper.java
index 13972a6..9759224 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/TimestampAwareFileBasedHelper.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/TimestampAwareFileBasedHelper.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.filebased;
+package org.apache.gobblin.source.extractor.filebased;
 
 /**
  * A File helper that extends {@link SizeAwareFileBasedHelper} and has functionality to get file modified time.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/TokenBasedFileInputStreamExtractor.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/TokenBasedFileInputStreamExtractor.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/TokenBasedFileInputStreamExtractor.java
index 4a16a39..8af42f7 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/TokenBasedFileInputStreamExtractor.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/TokenBasedFileInputStreamExtractor.java
@@ -15,14 +15,14 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.filebased;
+package org.apache.gobblin.source.extractor.filebased;
 
 import com.google.common.base.Preconditions;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.extractor.filebased.FileBasedExtractor;
-import gobblin.source.extractor.filebased.FileBasedHelper;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.extractor.filebased.FileBasedExtractor;
+import org.apache.gobblin.source.extractor.filebased.FileBasedHelper;
 
 import lombok.extern.slf4j.Slf4j;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/TokenizedFileDownloader.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/TokenizedFileDownloader.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/TokenizedFileDownloader.java
index 0cdabaf..a20c4ff 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/TokenizedFileDownloader.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/TokenizedFileDownloader.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;
 import java.io.InputStream;
@@ -25,7 +25,7 @@ import java.util.Scanner;
 import com.google.common.annotations.VisibleForTesting;
 import com.google.common.base.Preconditions;
 
-import gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.ConfigurationKeys;
 
 import lombok.Setter;
 import lombok.extern.slf4j.Slf4j;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/AvroFileExtractor.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/AvroFileExtractor.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/AvroFileExtractor.java
index 1ec2200..b610107 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/AvroFileExtractor.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/AvroFileExtractor.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.Iterator;
@@ -25,10 +25,10 @@ import org.apache.avro.generic.GenericRecord;
 
 import com.google.common.base.Throwables;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.extractor.filebased.FileBasedExtractor;
-import gobblin.source.extractor.filebased.FileBasedHelperException;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.extractor.filebased.FileBasedExtractor;
+import org.apache.gobblin.source.extractor.filebased.FileBasedHelperException;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/AvroFileSource.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/AvroFileSource.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/AvroFileSource.java
index f736758..f189b47 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/AvroFileSource.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/AvroFileSource.java
@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.hadoop;
+package org.apache.gobblin.source.extractor.hadoop;
 
-import gobblin.source.extractor.filebased.FileBasedHelperException;
+import org.apache.gobblin.source.extractor.filebased.FileBasedHelperException;
 import java.io.IOException;
 import java.util.List;
 
@@ -28,11 +28,11 @@ import org.slf4j.LoggerFactory;
 
 import com.google.common.collect.Lists;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.extractor.Extractor;
-import gobblin.source.extractor.filebased.FileBasedSource;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.extractor.Extractor;
+import org.apache.gobblin.source.extractor.filebased.FileBasedSource;
 
 
 public class AvroFileSource extends FileBasedSource<Schema, GenericRecord> {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/AvroFsHelper.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/AvroFsHelper.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/AvroFsHelper.java
index 71b9d04..d3e2632 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/AvroFsHelper.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/AvroFsHelper.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.io.InputStream;
@@ -32,12 +32,12 @@ import org.apache.hadoop.io.compress.CompressionCodecFactory;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.source.extractor.filebased.FileBasedHelperException;
-import gobblin.source.extractor.filebased.SizeAwareFileBasedHelper;
-import gobblin.source.extractor.utils.ProxyFsInput;
-import gobblin.util.HadoopUtils;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.source.extractor.filebased.FileBasedHelperException;
+import org.apache.gobblin.source.extractor.filebased.SizeAwareFileBasedHelper;
+import org.apache.gobblin.source.extractor.utils.ProxyFsInput;
+import org.apache.gobblin.util.HadoopUtils;
 
 
 public class AvroFsHelper extends HadoopFsHelper implements SizeAwareFileBasedHelper {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/HadoopFileInputExtractor.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/HadoopFileInputExtractor.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/HadoopFileInputExtractor.java
index 61663b2..d794a75 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/HadoopFileInputExtractor.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/HadoopFileInputExtractor.java
@@ -15,14 +15,14 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.hadoop;
+package org.apache.gobblin.source.extractor.hadoop;
 
 import java.io.IOException;
 
 import org.apache.hadoop.mapreduce.RecordReader;
 
-import gobblin.source.extractor.DataRecordException;
-import gobblin.source.extractor.Extractor;
+import org.apache.gobblin.source.extractor.DataRecordException;
+import org.apache.gobblin.source.extractor.Extractor;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/HadoopFileInputSource.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/HadoopFileInputSource.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/HadoopFileInputSource.java
index 91e76c2..ef8ada0 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/HadoopFileInputSource.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/HadoopFileInputSource.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;
@@ -35,15 +35,15 @@ import com.google.common.base.Preconditions;
 import com.google.common.collect.ImmutableList;
 import com.google.common.collect.Lists;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.SourceState;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.extractor.Extractor;
-import gobblin.source.extractor.extract.AbstractSource;
-import gobblin.source.workunit.Extract;
-import gobblin.source.workunit.WorkUnit;
-import gobblin.util.HadoopUtils;
+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.Extractor;
+import org.apache.gobblin.source.extractor.extract.AbstractSource;
+import org.apache.gobblin.source.workunit.Extract;
+import org.apache.gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.util.HadoopUtils;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/HadoopFsHelper.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/HadoopFsHelper.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/HadoopFsHelper.java
index 6000a42..9eca739 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/HadoopFsHelper.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/HadoopFsHelper.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.io.InputStream;
@@ -33,13 +33,13 @@ import org.apache.hadoop.io.compress.CompressionCodecFactory;
 
 import com.google.common.base.Strings;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.source.extractor.filebased.FileBasedHelper;
-import gobblin.source.extractor.filebased.FileBasedHelperException;
-import gobblin.source.extractor.filebased.TimestampAwareFileBasedHelper;
-import gobblin.util.HadoopUtils;
-import gobblin.util.ProxiedFileSystemWrapper;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.source.extractor.filebased.FileBasedHelper;
+import org.apache.gobblin.source.extractor.filebased.FileBasedHelperException;
+import org.apache.gobblin.source.extractor.filebased.TimestampAwareFileBasedHelper;
+import org.apache.gobblin.util.HadoopUtils;
+import org.apache.gobblin.util.ProxiedFileSystemWrapper;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/HadoopTextInputSource.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/HadoopTextInputSource.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/HadoopTextInputSource.java
index df34539..12f09ef 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/HadoopTextInputSource.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/HadoopTextInputSource.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.hadoop;
+package org.apache.gobblin.source.extractor.hadoop;
 
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.io.LongWritable;
@@ -26,8 +26,8 @@ import org.apache.hadoop.mapreduce.lib.input.FileSplit;
 import org.apache.hadoop.mapreduce.lib.input.TextInputFormat;
 import org.apache.hadoop.util.ReflectionUtils;
 
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/OldApiHadoopFileInputExtractor.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/OldApiHadoopFileInputExtractor.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/OldApiHadoopFileInputExtractor.java
index f276ce0..82ad726 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/OldApiHadoopFileInputExtractor.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/OldApiHadoopFileInputExtractor.java
@@ -15,14 +15,14 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.hadoop;
+package org.apache.gobblin.source.extractor.hadoop;
 
 import java.io.IOException;
 
 import org.apache.hadoop.mapred.RecordReader;
 
-import gobblin.source.extractor.DataRecordException;
-import gobblin.source.extractor.Extractor;
+import org.apache.gobblin.source.extractor.DataRecordException;
+import org.apache.gobblin.source.extractor.Extractor;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/OldApiHadoopFileInputSource.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/OldApiHadoopFileInputSource.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/OldApiHadoopFileInputSource.java
index 9134362..85e7cf6 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/OldApiHadoopFileInputSource.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/OldApiHadoopFileInputSource.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;
@@ -34,15 +34,15 @@ import com.google.common.base.Preconditions;
 import com.google.common.collect.ImmutableList;
 import com.google.common.collect.Lists;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.SourceState;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.extractor.Extractor;
-import gobblin.source.extractor.extract.AbstractSource;
-import gobblin.source.workunit.Extract;
-import gobblin.source.workunit.WorkUnit;
-import gobblin.util.HadoopUtils;
+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.Extractor;
+import org.apache.gobblin.source.extractor.extract.AbstractSource;
+import org.apache.gobblin.source.workunit.Extract;
+import org.apache.gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.util.HadoopUtils;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/OldApiHadoopTextInputSource.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/OldApiHadoopTextInputSource.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/OldApiHadoopTextInputSource.java
index 3a1f7b0..2f891f6 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/OldApiHadoopTextInputSource.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/OldApiHadoopTextInputSource.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.hadoop;
+package org.apache.gobblin.source.extractor.hadoop;
 
 import org.apache.hadoop.io.LongWritable;
 import org.apache.hadoop.io.Text;
@@ -26,8 +26,8 @@ import org.apache.hadoop.mapred.RecordReader;
 import org.apache.hadoop.mapred.TextInputFormat;
 import org.apache.hadoop.util.ReflectionUtils;
 
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/OldApiWritableFileExtractor.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/OldApiWritableFileExtractor.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/OldApiWritableFileExtractor.java
index faa4f31..bcef013 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/OldApiWritableFileExtractor.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/OldApiWritableFileExtractor.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;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/OldApiWritableFileSource.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/OldApiWritableFileSource.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/OldApiWritableFileSource.java
index 9c2a6ee..2abcee9 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/OldApiWritableFileSource.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/OldApiWritableFileSource.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.hadoop;
+package org.apache.gobblin.source.extractor.hadoop;
 
 import java.util.List;
 
@@ -24,10 +24,10 @@ import org.apache.hadoop.mapred.FileSplit;
 
 import org.apache.hadoop.mapred.RecordReader;
 
-import gobblin.configuration.SourceState;
-import gobblin.configuration.WorkUnitState;
-import gobblin.hive.HiveSerDeWrapper;
-import gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.configuration.SourceState;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.hive.HiveSerDeWrapper;
+import org.apache.gobblin.source.workunit.WorkUnit;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/partition/AppendMaxLimitType.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/partition/AppendMaxLimitType.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/partition/AppendMaxLimitType.java
index bf2f715..c31df38 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/partition/AppendMaxLimitType.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/partition/AppendMaxLimitType.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.partition;
+package org.apache.gobblin.source.extractor.partition;
 
 public enum AppendMaxLimitType {
   CURRENTDATE, CURRENTHOUR, CURRENTMINUTE, CURRENTSECOND;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/partition/Partition.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/partition/Partition.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/partition/Partition.java
index bdb5a15..a92a782 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/partition/Partition.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/partition/Partition.java
@@ -1,10 +1,10 @@
-package gobblin.source.extractor.partition;
+package org.apache.gobblin.source.extractor.partition;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.source.Source;
-import gobblin.source.extractor.WatermarkInterval;
-import gobblin.source.extractor.extract.LongWatermark;
-import gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.source.Source;
+import org.apache.gobblin.source.extractor.WatermarkInterval;
+import org.apache.gobblin.source.extractor.extract.LongWatermark;
+import org.apache.gobblin.source.workunit.WorkUnit;
 
 import lombok.EqualsAndHashCode;
 import lombok.Getter;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/partition/Partitioner.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/partition/Partitioner.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/partition/Partitioner.java
index a74a98c..90da5b5 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/partition/Partitioner.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/partition/Partitioner.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.partition;
+package org.apache.gobblin.source.extractor.partition;
 
 import java.util.ArrayList;
 import java.util.Collections;
@@ -32,16 +32,16 @@ import com.google.common.annotations.VisibleForTesting;
 import com.google.common.base.Strings;
 import com.google.common.collect.Maps;
 
-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.DateWatermark;
-import gobblin.source.extractor.watermark.HourWatermark;
-import gobblin.source.extractor.watermark.SimpleWatermark;
-import gobblin.source.extractor.watermark.TimestampWatermark;
-import gobblin.source.extractor.watermark.WatermarkPredicate;
-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.DateWatermark;
+import org.apache.gobblin.source.extractor.watermark.HourWatermark;
+import org.apache.gobblin.source.extractor.watermark.SimpleWatermark;
+import org.apache.gobblin.source.extractor.watermark.TimestampWatermark;
+import org.apache.gobblin.source.extractor.watermark.WatermarkPredicate;
+import org.apache.gobblin.source.extractor.watermark.WatermarkType;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/resultset/RecordSet.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/resultset/RecordSet.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/resultset/RecordSet.java
index 7b413c7..7266ffc 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/resultset/RecordSet.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/resultset/RecordSet.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.resultset;
+package org.apache.gobblin.source.extractor.resultset;
 
 /**
  * An interface to extract data records using an iterator

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/resultset/RecordSetList.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/resultset/RecordSetList.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/resultset/RecordSetList.java
index bc04e79..df632bd 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/resultset/RecordSetList.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/resultset/RecordSetList.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.resultset;
+package org.apache.gobblin.source.extractor.resultset;
 
 import java.util.ArrayList;
 import java.util.Iterator;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/schema/ArrayDataType.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/schema/ArrayDataType.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/schema/ArrayDataType.java
index e51597d..67ee9a7 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/schema/ArrayDataType.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/schema/ArrayDataType.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.schema;
+package org.apache.gobblin.source.extractor.schema;
 
 import lombok.Getter;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/schema/ColumnAttributes.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/schema/ColumnAttributes.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/schema/ColumnAttributes.java
index 9385c36..aff0fa8 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/schema/ColumnAttributes.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/schema/ColumnAttributes.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.schema;
+package org.apache.gobblin.source.extractor.schema;
 
 /**
  * Attributes of column in projection list

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/schema/ColumnNameCase.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/schema/ColumnNameCase.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/schema/ColumnNameCase.java
index fb394df..a8fa69f 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/schema/ColumnNameCase.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/schema/ColumnNameCase.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.schema;
+package org.apache.gobblin.source.extractor.schema;
 
 public enum ColumnNameCase {
   TOUPPER, TOLOWER, NOCHANGE;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/schema/DataType.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/schema/DataType.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/schema/DataType.java
index 99f0b79..5f5c0a2 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/schema/DataType.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/schema/DataType.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.schema;
+package org.apache.gobblin.source.extractor.schema;
 
 import lombok.Getter;
 import lombok.Setter;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/schema/EnumDataType.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/schema/EnumDataType.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/schema/EnumDataType.java
index d9c86ad..aa49bd9 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/schema/EnumDataType.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/schema/EnumDataType.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.schema;
+package org.apache.gobblin.source.extractor.schema;
 
 import java.util.List;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/schema/MapDataType.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/schema/MapDataType.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/schema/MapDataType.java
index 71f0b70..f2e51e6 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/schema/MapDataType.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/schema/MapDataType.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.schema;
+package org.apache.gobblin.source.extractor.schema;
 
 public class MapDataType extends DataType {
   String values;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/schema/Schema.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/schema/Schema.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/schema/Schema.java
index 4954d01..abd38b8 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/schema/Schema.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/schema/Schema.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.schema;
+package org.apache.gobblin.source.extractor.schema;
 
 import com.google.gson.JsonObject;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/utils/InputStreamCSVReader.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/utils/InputStreamCSVReader.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/utils/InputStreamCSVReader.java
index 80e4613..1aa0ed5 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/utils/InputStreamCSVReader.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/utils/InputStreamCSVReader.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.utils;
+package org.apache.gobblin.source.extractor.utils;
 
 import java.io.BufferedReader;
 import java.io.ByteArrayInputStream;
@@ -26,7 +26,7 @@ import java.io.Reader;
 import java.io.StreamTokenizer;
 import java.util.ArrayList;
 
-import gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.ConfigurationKeys;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/utils/ProxyFsInput.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/utils/ProxyFsInput.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/utils/ProxyFsInput.java
index 73ceac0..b0aaf60 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/utils/ProxyFsInput.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/utils/ProxyFsInput.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.utils;
+package org.apache.gobblin.source.extractor.utils;
 
 import java.io.Closeable;
 import java.io.IOException;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/utils/Utils.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/utils/Utils.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/utils/Utils.java
index 4c8d682..7496268 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/utils/Utils.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/utils/Utils.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.utils;
+package org.apache.gobblin.source.extractor.utils;
 
 import java.text.ParseException;
 import java.text.SimpleDateFormat;
@@ -44,8 +44,8 @@ import com.google.gson.JsonArray;
 import com.google.gson.JsonElement;
 import com.google.gson.JsonObject;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.source.extractor.watermark.WatermarkType;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.source.extractor.watermark.WatermarkType;
 
 
 public class Utils {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/DateWatermark.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/DateWatermark.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/DateWatermark.java
index 57add2e..064087a 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/DateWatermark.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/DateWatermark.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.watermark;
+package org.apache.gobblin.source.extractor.watermark;
 
 import java.math.RoundingMode;
 import java.text.ParseException;
@@ -33,8 +33,8 @@ import com.google.common.collect.Maps;
 import com.google.common.math.DoubleMath;
 import com.google.common.primitives.Ints;
 
-import gobblin.source.extractor.extract.QueryBasedExtractor;
-import gobblin.source.extractor.utils.Utils;
+import org.apache.gobblin.source.extractor.extract.QueryBasedExtractor;
+import org.apache.gobblin.source.extractor.utils.Utils;
 
 
 public class DateWatermark implements Watermark {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/HourWatermark.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/HourWatermark.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/HourWatermark.java
index e9f71ab..0b3e1af 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/HourWatermark.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/HourWatermark.java
@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.watermark;
+package org.apache.gobblin.source.extractor.watermark;
 
-import gobblin.source.extractor.extract.QueryBasedExtractor;
-import gobblin.source.extractor.utils.Utils;
+import org.apache.gobblin.source.extractor.extract.QueryBasedExtractor;
+import org.apache.gobblin.source.extractor.utils.Utils;
 
 import java.math.RoundingMode;
 import java.text.ParseException;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/Predicate.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/Predicate.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/Predicate.java
index 8ff9ae4..67c1dd3 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/Predicate.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/Predicate.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.watermark;
+package org.apache.gobblin.source.extractor.watermark;
 
 /**
  * An implementation for predicate conditions

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/SimpleWatermark.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/SimpleWatermark.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/SimpleWatermark.java
index c6aee58..86e6a4e 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/SimpleWatermark.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/SimpleWatermark.java
@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.watermark;
+package org.apache.gobblin.source.extractor.watermark;
 
-import gobblin.source.extractor.extract.QueryBasedExtractor;
-import gobblin.source.extractor.utils.Utils;
+import org.apache.gobblin.source.extractor.extract.QueryBasedExtractor;
+import org.apache.gobblin.source.extractor.utils.Utils;
 
 import java.math.RoundingMode;
 import java.util.HashMap;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/TimestampWatermark.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/TimestampWatermark.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/TimestampWatermark.java
index 4467abf..c325d9a 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/TimestampWatermark.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/TimestampWatermark.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.watermark;
+package org.apache.gobblin.source.extractor.watermark;
 
 import java.math.RoundingMode;
 import java.text.ParseException;
@@ -31,8 +31,8 @@ import com.google.common.base.Preconditions;
 import com.google.common.math.DoubleMath;
 import com.google.common.primitives.Ints;
 
-import gobblin.source.extractor.extract.QueryBasedExtractor;
-import gobblin.source.extractor.utils.Utils;
+import org.apache.gobblin.source.extractor.extract.QueryBasedExtractor;
+import org.apache.gobblin.source.extractor.utils.Utils;
 
 
 public class TimestampWatermark implements Watermark {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/Watermark.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/Watermark.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/Watermark.java
index 55194d3..e83fc65 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/Watermark.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/Watermark.java
@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.watermark;
+package org.apache.gobblin.source.extractor.watermark;
 
-import gobblin.source.extractor.extract.QueryBasedExtractor;
+import org.apache.gobblin.source.extractor.extract.QueryBasedExtractor;
 import java.util.HashMap;
 
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/WatermarkPredicate.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/WatermarkPredicate.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/WatermarkPredicate.java
index 9ba4aa0..48f527d 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/WatermarkPredicate.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/WatermarkPredicate.java
@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.watermark;
+package org.apache.gobblin.source.extractor.watermark;
 
-import gobblin.source.extractor.extract.QueryBasedExtractor;
+import org.apache.gobblin.source.extractor.extract.QueryBasedExtractor;
 import java.util.HashMap;
 
 import org.apache.commons.lang3.StringUtils;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/WatermarkType.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/WatermarkType.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/WatermarkType.java
index a420df3..171e583 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/WatermarkType.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/WatermarkType.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.watermark;
+package org.apache.gobblin.source.extractor.watermark;
 
 public enum WatermarkType {
   TIMESTAMP, DATE, HOUR, SIMPLE;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/source/workunit/MultiWorkUnitWeightedQueue.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/workunit/MultiWorkUnitWeightedQueue.java b/gobblin-core/src/main/java/org/apache/gobblin/source/workunit/MultiWorkUnitWeightedQueue.java
index c256351..50e097e 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/workunit/MultiWorkUnitWeightedQueue.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/workunit/MultiWorkUnitWeightedQueue.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.workunit;
+package org.apache.gobblin.source.workunit;
 
 import java.util.List;
 import java.util.PriorityQueue;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/state/ConstructState.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/state/ConstructState.java b/gobblin-core/src/main/java/org/apache/gobblin/state/ConstructState.java
index 885038c..faa3069 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/state/ConstructState.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/state/ConstructState.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.state;
+package org.apache.gobblin.state;
 
 import java.lang.reflect.Type;
 import java.util.Map;
@@ -26,9 +26,9 @@ import com.google.common.collect.Maps;
 import com.google.gson.Gson;
 import com.google.gson.reflect.TypeToken;
 
-import gobblin.Constructs;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.Constructs;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/util/TestUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/util/TestUtils.java b/gobblin-core/src/main/java/org/apache/gobblin/util/TestUtils.java
index 0ed6054..26e980a 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/util/TestUtils.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/util/TestUtils.java
@@ -15,16 +15,16 @@
  * limitations under the License.
  */
 
-package gobblin.util;
+package org.apache.gobblin.util;
 
 import com.typesafe.config.ConfigFactory;
 
-import gobblin.broker.SharedResourcesBrokerFactory;
-import gobblin.broker.gobblin_scopes.GobblinScopeTypes;
-import gobblin.broker.gobblin_scopes.JobScopeInstance;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.broker.SharedResourcesBrokerFactory;
+import org.apache.gobblin.broker.gobblin_scopes.GobblinScopeTypes;
+import org.apache.gobblin.broker.gobblin_scopes.JobScopeInstance;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.workunit.WorkUnit;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/AbstractAsyncDataWriter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/AbstractAsyncDataWriter.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/AbstractAsyncDataWriter.java
index c1199a5..286d7d9 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/AbstractAsyncDataWriter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/AbstractAsyncDataWriter.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 import java.io.IOException;
 import java.util.concurrent.Future;
@@ -23,12 +23,12 @@ import java.util.concurrent.Future;
 import javax.annotation.Nullable;
 import javax.annotation.concurrent.ThreadSafe;
 
-import gobblin.async.AsyncDataDispatcher;
-import gobblin.async.BufferedRecord;
-import gobblin.writer.AsyncDataWriter;
-import gobblin.writer.FutureWrappedWriteCallback;
-import gobblin.writer.WriteCallback;
-import gobblin.writer.WriteResponse;
+import org.apache.gobblin.async.AsyncDataDispatcher;
+import org.apache.gobblin.async.BufferedRecord;
+import org.apache.gobblin.writer.AsyncDataWriter;
+import org.apache.gobblin.writer.FutureWrappedWriteCallback;
+import org.apache.gobblin.writer.WriteCallback;
+import org.apache.gobblin.writer.WriteResponse;
 
 
 /**

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

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/AvroHdfsDataWriter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/AvroHdfsDataWriter.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/AvroHdfsDataWriter.java
index 1bfffdb..44e33b9 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/AvroHdfsDataWriter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/AvroHdfsDataWriter.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 import java.io.IOException;
 import java.io.OutputStream;
@@ -32,10 +32,10 @@ import org.apache.hadoop.fs.FileSystem;
 import com.google.common.base.Optional;
 import com.google.common.base.Preconditions;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.util.ForkOperatorUtils;
-import gobblin.util.WriterUtils;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.util.ForkOperatorUtils;
+import org.apache.gobblin.util.WriterUtils;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/CloseOnFlushWriterWrapper.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/CloseOnFlushWriterWrapper.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/CloseOnFlushWriterWrapper.java
index 746140a..2c81e52 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/CloseOnFlushWriterWrapper.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/CloseOnFlushWriterWrapper.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.function.Supplier;
@@ -25,12 +25,12 @@ import org.slf4j.LoggerFactory;
 import com.github.rholder.retry.RetryerBuilder;
 import com.google.common.base.Preconditions;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.records.ControlMessageHandler;
-import gobblin.stream.RecordEnvelope;
-import gobblin.util.Decorator;
-import gobblin.util.FinalState;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.records.ControlMessageHandler;
+import org.apache.gobblin.stream.RecordEnvelope;
+import org.apache.gobblin.util.Decorator;
+import org.apache.gobblin.util.FinalState;
 
 /**
  * The {@link CloseOnFlushWriterWrapper} closes the wrapped writer on flush and creates a new writer using a

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/ConsoleWriter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/ConsoleWriter.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/ConsoleWriter.java
index a45c8fc..858bff8 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/ConsoleWriter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/ConsoleWriter.java
@@ -15,15 +15,15 @@
  * limitations under the License.
  */
 
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 import java.io.IOException;
 import java.util.Map;
 
 import lombok.extern.slf4j.Slf4j;
 
-import gobblin.source.extractor.CheckpointableWatermark;
-import gobblin.stream.RecordEnvelope;
+import org.apache.gobblin.source.extractor.CheckpointableWatermark;
+import org.apache.gobblin.stream.RecordEnvelope;
 
 
 /**

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

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/DataWriterWrapperBuilder.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/DataWriterWrapperBuilder.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/DataWriterWrapperBuilder.java
index 3804f67..7510cef 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/DataWriterWrapperBuilder.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/DataWriterWrapperBuilder.java
@@ -14,14 +14,14 @@
  * 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 org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import gobblin.configuration.State;
+import org.apache.gobblin.configuration.State;
 
 /**
  * The purpose of this class is to add more feature to DataWriter such as retry or throttle.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/FsDataWriter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/FsDataWriter.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/FsDataWriter.java
index 661a693..f4e4931 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/FsDataWriter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/FsDataWriter.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 import java.io.IOException;
 import java.io.OutputStream;
@@ -35,17 +35,17 @@ import com.google.common.collect.ImmutableSet;
 import com.google.common.collect.Lists;
 import com.google.common.io.Closer;
 
-import gobblin.codec.StreamCodec;
-import gobblin.commit.SpeculativeAttemptAwareConstruct;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.metadata.types.GlobalMetadata;
-import gobblin.util.FinalState;
-import gobblin.util.ForkOperatorUtils;
-import gobblin.util.HadoopUtils;
-import gobblin.util.JobConfigurationUtils;
-import gobblin.util.WriterUtils;
-import gobblin.util.recordcount.IngestionRecordCountProvider;
+import org.apache.gobblin.codec.StreamCodec;
+import org.apache.gobblin.commit.SpeculativeAttemptAwareConstruct;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.metadata.types.GlobalMetadata;
+import org.apache.gobblin.util.FinalState;
+import org.apache.gobblin.util.ForkOperatorUtils;
+import org.apache.gobblin.util.HadoopUtils;
+import org.apache.gobblin.util.JobConfigurationUtils;
+import org.apache.gobblin.util.WriterUtils;
+import org.apache.gobblin.util.recordcount.IngestionRecordCountProvider;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/FsDataWriterBuilder.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/FsDataWriterBuilder.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/FsDataWriterBuilder.java
index 59a9ddc..76757c3 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/FsDataWriterBuilder.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/FsDataWriterBuilder.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 import java.util.Collections;
 import java.util.List;
@@ -24,12 +24,12 @@ import org.apache.avro.Schema;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.hadoop.fs.Path;
 
-import gobblin.codec.StreamCodec;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.util.AvroUtils;
-import gobblin.util.ForkOperatorUtils;
-import gobblin.util.WriterUtils;
+import org.apache.gobblin.codec.StreamCodec;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.util.AvroUtils;
+import org.apache.gobblin.util.ForkOperatorUtils;
+import org.apache.gobblin.util.WriterUtils;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/HiveWritableHdfsDataWriter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/HiveWritableHdfsDataWriter.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/HiveWritableHdfsDataWriter.java
index 5de4491..b1a3046 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/HiveWritableHdfsDataWriter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/HiveWritableHdfsDataWriter.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 import java.io.IOException;
 import java.util.concurrent.atomic.AtomicLong;
@@ -27,7 +27,7 @@ import org.apache.hadoop.mapred.JobConf;
 
 import com.google.common.base.Preconditions;
 
-import gobblin.configuration.State;
+import org.apache.gobblin.configuration.State;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/HiveWritableHdfsDataWriterBuilder.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/HiveWritableHdfsDataWriterBuilder.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/HiveWritableHdfsDataWriterBuilder.java
index 4456459..5dba861 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/HiveWritableHdfsDataWriterBuilder.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/HiveWritableHdfsDataWriterBuilder.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
 import java.io.IOException;
 
@@ -25,8 +25,8 @@ import org.apache.hadoop.io.Writable;
 import com.google.common.base.Preconditions;
 import com.google.common.base.Strings;
 
-import gobblin.configuration.State;
-import gobblin.hive.HiveSerDeWrapper;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.hive.HiveSerDeWrapper;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/MetadataAwareWriter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/MetadataAwareWriter.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/MetadataAwareWriter.java
index 1569a60..023973a 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/MetadataAwareWriter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/MetadataAwareWriter.java
@@ -14,9 +14,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.writer;
+package org.apache.gobblin.writer;
 
-import gobblin.metadata.types.GlobalMetadata;
+import org.apache.gobblin.metadata.types.GlobalMetadata;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-core/src/main/java/org/apache/gobblin/writer/MetadataWriterWrapper.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/MetadataWriterWrapper.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/MetadataWriterWrapper.java
index 94c387b..1f549f7 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/MetadataWriterWrapper.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/MetadataWriterWrapper.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 java.io.IOException;
 import java.util.Set;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.metadata.GlobalMetadataCollector;
-import gobblin.metadata.types.GlobalMetadata;
-import gobblin.type.RecordWithMetadata;
-import gobblin.util.ForkOperatorUtils;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.metadata.GlobalMetadataCollector;
+import org.apache.gobblin.metadata.types.GlobalMetadata;
+import org.apache.gobblin.type.RecordWithMetadata;
+import org.apache.gobblin.util.ForkOperatorUtils;
 
 
 /**


Mime
View raw message