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:47 UTC
[29/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/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;
/**