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; /**
