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:54 UTC
[36/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-api/src/main/java/org/apache/gobblin/runtime/api/SpecExecutorInstance.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/SpecExecutorInstance.java b/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/SpecExecutorInstance.java
index 3587f1a..47569f3 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/SpecExecutorInstance.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/SpecExecutorInstance.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.api;
+package org.apache.gobblin.runtime.api;
import java.net.URI;
import java.util.Map;
@@ -23,7 +23,7 @@ import java.util.concurrent.Future;
import com.typesafe.config.Config;
-import gobblin.annotation.Alpha;
+import org.apache.gobblin.annotation.Alpha;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/SpecExecutorInstanceConsumer.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/SpecExecutorInstanceConsumer.java b/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/SpecExecutorInstanceConsumer.java
index b209d3e..475c5af 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/SpecExecutorInstanceConsumer.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/SpecExecutorInstanceConsumer.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.api;
+package org.apache.gobblin.runtime.api;
import java.util.List;
import java.util.concurrent.Future;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/SpecExecutorInstanceProducer.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/SpecExecutorInstanceProducer.java b/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/SpecExecutorInstanceProducer.java
index b3f94f2..12508da 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/SpecExecutorInstanceProducer.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/SpecExecutorInstanceProducer.java
@@ -15,13 +15,13 @@
* limitations under the License.
*/
-package gobblin.runtime.api;
+package org.apache.gobblin.runtime.api;
import java.net.URI;
import java.util.List;
import java.util.concurrent.Future;
-import gobblin.annotation.Alpha;
+import org.apache.gobblin.annotation.Alpha;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/Source.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/Source.java b/gobblin-api/src/main/java/org/apache/gobblin/source/Source.java
index ecc3917..7b9b82a 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/source/Source.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/source/Source.java
@@ -15,15 +15,15 @@
* limitations under the License.
*/
-package gobblin.source;
+package org.apache.gobblin.source;
-import gobblin.configuration.SourceState;
-import gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.configuration.SourceState;
+import org.apache.gobblin.configuration.WorkUnitState;
import java.io.IOException;
import java.util.List;
-import gobblin.source.extractor.Extractor;
-import gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.source.extractor.Extractor;
+import org.apache.gobblin.source.workunit.WorkUnit;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/WorkUnitStreamSource.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/WorkUnitStreamSource.java b/gobblin-api/src/main/java/org/apache/gobblin/source/WorkUnitStreamSource.java
index 13d7049..2137ebc 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/source/WorkUnitStreamSource.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/source/WorkUnitStreamSource.java
@@ -15,10 +15,10 @@
* limitations under the License.
*/
-package gobblin.source;
+package org.apache.gobblin.source;
-import gobblin.configuration.SourceState;
-import gobblin.source.workunit.WorkUnitStream;
+import org.apache.gobblin.configuration.SourceState;
+import org.apache.gobblin.source.workunit.WorkUnitStream;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/CheckpointableWatermark.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/CheckpointableWatermark.java b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/CheckpointableWatermark.java
index 4d366b4..38673b8 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/CheckpointableWatermark.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/CheckpointableWatermark.java
@@ -17,9 +17,9 @@
* under the License.
*/
-package gobblin.source.extractor;
+package org.apache.gobblin.source.extractor;
-import gobblin.annotation.Alpha;
+import org.apache.gobblin.annotation.Alpha;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/ComparableWatermark.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/ComparableWatermark.java b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/ComparableWatermark.java
index cc00e70..361f315 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/ComparableWatermark.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/ComparableWatermark.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.source.extractor;
+package org.apache.gobblin.source.extractor;
/**
* {@link Watermark} that is also {@link Comparable}.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/DataRecordException.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/DataRecordException.java b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/DataRecordException.java
index 7f8915b..b1b66c0 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/DataRecordException.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/DataRecordException.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.source.extractor;
+package org.apache.gobblin.source.extractor;
public class DataRecordException extends Exception {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/Extractor.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/Extractor.java b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/Extractor.java
index fb3134a..6a1af0f 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/Extractor.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/Extractor.java
@@ -15,15 +15,15 @@
* limitations under the License.
*/
-package gobblin.source.extractor;
+package org.apache.gobblin.source.extractor;
import java.io.Closeable;
import java.io.IOException;
import java.util.concurrent.atomic.AtomicBoolean;
-import gobblin.records.RecordStreamWithMetadata;
-import gobblin.stream.RecordEnvelope;
-import gobblin.stream.StreamEntity;
+import org.apache.gobblin.records.RecordStreamWithMetadata;
+import org.apache.gobblin.stream.RecordEnvelope;
+import org.apache.gobblin.stream.StreamEntity;
import edu.umd.cs.findbugs.annotations.SuppressWarnings;
import io.reactivex.Emitter;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/StreamingExtractor.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/StreamingExtractor.java b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/StreamingExtractor.java
index 1b8328f..035bcdc 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/StreamingExtractor.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/StreamingExtractor.java
@@ -17,12 +17,12 @@
* under the License.
*/
-package gobblin.source.extractor;
+package org.apache.gobblin.source.extractor;
import java.io.IOException;
-import gobblin.annotation.Alpha;
-import gobblin.writer.WatermarkStorage;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.writer.WatermarkStorage;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/Watermark.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/Watermark.java b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/Watermark.java
index 5e61d37..391e876 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/Watermark.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/Watermark.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.source.extractor;
+package org.apache.gobblin.source.extractor;
import com.google.gson.JsonElement;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/WatermarkInterval.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/WatermarkInterval.java b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/WatermarkInterval.java
index 0e42220..37f70bd 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/WatermarkInterval.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/WatermarkInterval.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.source.extractor;
+package org.apache.gobblin.source.extractor;
import com.google.gson.JsonElement;
import com.google.gson.JsonObject;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/WatermarkSerializerHelper.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/WatermarkSerializerHelper.java b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/WatermarkSerializerHelper.java
index 7d15745..e4ae0fc 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/WatermarkSerializerHelper.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/WatermarkSerializerHelper.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.source.extractor;
+package org.apache.gobblin.source.extractor;
import com.google.gson.Gson;
import com.google.gson.JsonElement;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/BasicWorkUnitStream.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/BasicWorkUnitStream.java b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/BasicWorkUnitStream.java
index a143ace..0d07312 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/BasicWorkUnitStream.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/BasicWorkUnitStream.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.source.workunit;
+package org.apache.gobblin.source.workunit;
import java.util.Collection;
import java.util.Iterator;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/Extract.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/Extract.java b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/Extract.java
index 19a0f73..5161427 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/Extract.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/Extract.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.Locale;
@@ -28,10 +28,10 @@ import org.joda.time.format.DateTimeFormatter;
import com.google.common.base.Joiner;
import com.google.common.base.Strings;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.SourceState;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.SourceState;
+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-api/src/main/java/org/apache/gobblin/source/workunit/ExtractFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/ExtractFactory.java b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/ExtractFactory.java
index d0aae7a..53fff64 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/ExtractFactory.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/ExtractFactory.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.source.workunit;
+package org.apache.gobblin.source.workunit;
import java.util.Locale;
import java.util.Set;
@@ -28,7 +28,7 @@ import org.joda.time.format.DateTimeFormatter;
import com.google.common.base.Strings;
import com.google.common.collect.Sets;
-import gobblin.source.workunit.Extract.TableType;
+import org.apache.gobblin.source.workunit.Extract.TableType;
public class ExtractFactory {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/ImmutableExtract.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/ImmutableExtract.java b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/ImmutableExtract.java
index 480fe23..176019e 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/ImmutableExtract.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/ImmutableExtract.java
@@ -15,14 +15,14 @@
* limitations under the License.
*/
-package gobblin.source.workunit;
+package org.apache.gobblin.source.workunit;
import java.io.DataInput;
import java.io.IOException;
import java.util.Properties;
-import gobblin.configuration.SourceState;
-import gobblin.configuration.State;
+import org.apache.gobblin.configuration.SourceState;
+import org.apache.gobblin.configuration.State;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/ImmutableWorkUnit.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/ImmutableWorkUnit.java b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/ImmutableWorkUnit.java
index 1d80e8e..134d638 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/ImmutableWorkUnit.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/ImmutableWorkUnit.java
@@ -15,13 +15,13 @@
* limitations under the License.
*/
-package gobblin.source.workunit;
+package org.apache.gobblin.source.workunit;
import java.io.DataInput;
import java.io.IOException;
import java.util.Properties;
-import gobblin.configuration.State;
+import org.apache.gobblin.configuration.State;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/MissingExtractAttributeException.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/MissingExtractAttributeException.java b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/MissingExtractAttributeException.java
index 1d42f5e..664919e 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/MissingExtractAttributeException.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/MissingExtractAttributeException.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.source.workunit;
+package org.apache.gobblin.source.workunit;
public class MissingExtractAttributeException extends Exception {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/MultiWorkUnit.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/MultiWorkUnit.java b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/MultiWorkUnit.java
index abbfb71..834f4f3 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/MultiWorkUnit.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/MultiWorkUnit.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.source.workunit;
+package org.apache.gobblin.source.workunit;
import java.io.DataInput;
import java.io.DataOutput;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnit.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnit.java b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnit.java
index 55d00b3..21915a5 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnit.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnit.java
@@ -15,11 +15,11 @@
* limitations under the License.
*/
-package gobblin.source.workunit;
+package org.apache.gobblin.source.workunit;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.SourceState;
-import gobblin.configuration.State;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.SourceState;
+import org.apache.gobblin.configuration.State;
import java.io.DataInput;
import java.io.DataOutput;
@@ -29,9 +29,9 @@ import com.google.gson.Gson;
import com.google.gson.JsonElement;
import com.google.gson.JsonParser;
-import gobblin.source.extractor.Extractor;
-import gobblin.source.extractor.Watermark;
-import gobblin.source.extractor.WatermarkInterval;
+import org.apache.gobblin.source.extractor.Extractor;
+import org.apache.gobblin.source.extractor.Watermark;
+import org.apache.gobblin.source.extractor.WatermarkInterval;
import lombok.ToString;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnitBinPacker.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnitBinPacker.java b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnitBinPacker.java
index a8dcf73..daa9273 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnitBinPacker.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnitBinPacker.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.source.workunit;
+package org.apache.gobblin.source.workunit;
import java.util.List;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnitStream.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnitStream.java b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnitStream.java
index ff4b0f2..dba630c 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnitStream.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnitStream.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.source.workunit;
+package org.apache.gobblin.source.workunit;
import java.util.Collection;
import java.util.Iterator;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnitWeighter.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnitWeighter.java b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnitWeighter.java
index ed191f0..a9db38c 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnitWeighter.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnitWeighter.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.source.workunit;
+package org.apache.gobblin.source.workunit;
/**
* Provides weights for {@link WorkUnit}s to use by a {@link WorkUnitBinPacker}.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/stream/ControlMessage.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/stream/ControlMessage.java b/gobblin-api/src/main/java/org/apache/gobblin/stream/ControlMessage.java
index b556dff..242cb8d 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/stream/ControlMessage.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/stream/ControlMessage.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.stream;
+package org.apache.gobblin.stream;
/**
* A {@link StreamEntity} used to send control messages through the ingestion pipeline. Most constructs will just
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/stream/FlushControlMessage.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/stream/FlushControlMessage.java b/gobblin-api/src/main/java/org/apache/gobblin/stream/FlushControlMessage.java
index a44188a..8760754 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/stream/FlushControlMessage.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/stream/FlushControlMessage.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.stream;
+package org.apache.gobblin.stream;
import lombok.AllArgsConstructor;
import lombok.EqualsAndHashCode;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/stream/RecordEnvelope.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/stream/RecordEnvelope.java b/gobblin-api/src/main/java/org/apache/gobblin/stream/RecordEnvelope.java
index 338b4bf..edfa1f0 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/stream/RecordEnvelope.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/stream/RecordEnvelope.java
@@ -15,12 +15,12 @@
* limitations under the License.
*/
-package gobblin.stream;
+package org.apache.gobblin.stream;
-import gobblin.annotation.Alpha;
-import gobblin.fork.CopyHelper;
-import gobblin.fork.CopyNotSupportedException;
-import gobblin.source.extractor.CheckpointableWatermark;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.fork.CopyHelper;
+import org.apache.gobblin.fork.CopyNotSupportedException;
+import org.apache.gobblin.source.extractor.CheckpointableWatermark;
import javax.annotation.Nullable;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/stream/StreamEntity.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/stream/StreamEntity.java b/gobblin-api/src/main/java/org/apache/gobblin/stream/StreamEntity.java
index 45c43d3..6168968 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/stream/StreamEntity.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/stream/StreamEntity.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.stream;
+package org.apache.gobblin.stream;
import java.io.Closeable;
import java.util.List;
@@ -23,8 +23,8 @@ import java.util.List;
import com.google.common.base.Preconditions;
import com.google.common.collect.Lists;
-import gobblin.ack.Ackable;
-import gobblin.ack.HierarchicalAckable;
+import org.apache.gobblin.ack.Ackable;
+import org.apache.gobblin.ack.HierarchicalAckable;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/testing/AssertWithBackoff.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/testing/AssertWithBackoff.java b/gobblin-api/src/main/java/org/apache/gobblin/testing/AssertWithBackoff.java
index 06a261e..84504df 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/testing/AssertWithBackoff.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/testing/AssertWithBackoff.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.testing;
+package org.apache.gobblin.testing;
import java.util.concurrent.TimeoutException;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/util/ClassAliasResolver.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/util/ClassAliasResolver.java b/gobblin-api/src/main/java/org/apache/gobblin/util/ClassAliasResolver.java
index d76d32d..c7663d2 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/util/ClassAliasResolver.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/util/ClassAliasResolver.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import java.util.List;
import java.util.Map;
@@ -29,7 +29,7 @@ import com.google.common.collect.ImmutableMap;
import com.google.common.collect.Lists;
import com.google.common.collect.Maps;
-import gobblin.annotation.Alias;
+import org.apache.gobblin.annotation.Alias;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/util/CompletedFuture.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/util/CompletedFuture.java b/gobblin-api/src/main/java/org/apache/gobblin/util/CompletedFuture.java
index 9a42c25..3639cc7 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/util/CompletedFuture.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/util/CompletedFuture.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/util/Decorator.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/util/Decorator.java b/gobblin-api/src/main/java/org/apache/gobblin/util/Decorator.java
index 5a57a2e..2d5170e 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/util/Decorator.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/util/Decorator.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/util/DecoratorUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/util/DecoratorUtils.java b/gobblin-api/src/main/java/org/apache/gobblin/util/DecoratorUtils.java
index 419527b..9b67347 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/util/DecoratorUtils.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/util/DecoratorUtils.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import java.util.List;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/util/FinalState.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/util/FinalState.java b/gobblin-api/src/main/java/org/apache/gobblin/util/FinalState.java
index f27e19a..2abff3f 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/util/FinalState.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/util/FinalState.java
@@ -15,9 +15,9 @@
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
-import gobblin.configuration.State;
+import org.apache.gobblin.configuration.State;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/util/RecordCountProvider.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/util/RecordCountProvider.java b/gobblin-api/src/main/java/org/apache/gobblin/util/RecordCountProvider.java
index 0e83c94..cb912b7 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/util/RecordCountProvider.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/util/RecordCountProvider.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import java.util.Collection;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/writer/DataWriter.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/writer/DataWriter.java b/gobblin-api/src/main/java/org/apache/gobblin/writer/DataWriter.java
index 613cd2b..0dcc888 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/writer/DataWriter.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/writer/DataWriter.java
@@ -15,15 +15,15 @@
* limitations under the License.
*/
-package gobblin.writer;
+package org.apache.gobblin.writer;
import java.io.Closeable;
import java.io.Flushable;
import java.io.IOException;
-import gobblin.records.ControlMessageHandler;
-import gobblin.records.FlushControlMessageHandler;
-import gobblin.stream.RecordEnvelope;
+import org.apache.gobblin.records.ControlMessageHandler;
+import org.apache.gobblin.records.FlushControlMessageHandler;
+import org.apache.gobblin.stream.RecordEnvelope;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/writer/DataWriterBuilder.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/writer/DataWriterBuilder.java b/gobblin-api/src/main/java/org/apache/gobblin/writer/DataWriterBuilder.java
index 9376f14..52ea5b1 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/writer/DataWriterBuilder.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/writer/DataWriterBuilder.java
@@ -15,17 +15,17 @@
* limitations under the License.
*/
-package gobblin.writer;
+package org.apache.gobblin.writer;
import java.io.IOException;
import lombok.Getter;
import lombok.extern.slf4j.Slf4j;
-import gobblin.configuration.State;
-import gobblin.source.workunit.WorkUnitStream;
-import gobblin.writer.initializer.NoopWriterInitializer;
-import gobblin.writer.initializer.WriterInitializer;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.source.workunit.WorkUnitStream;
+import org.apache.gobblin.writer.initializer.NoopWriterInitializer;
+import org.apache.gobblin.writer.initializer.WriterInitializer;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/writer/Destination.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/writer/Destination.java b/gobblin-api/src/main/java/org/apache/gobblin/writer/Destination.java
index 563908c..506d4ee 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/writer/Destination.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/writer/Destination.java
@@ -15,9 +15,9 @@
* limitations under the License.
*/
-package gobblin.writer;
+package org.apache.gobblin.writer;
-import gobblin.configuration.State;
+import org.apache.gobblin.configuration.State;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/writer/FluentDataWriterBuilder.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/writer/FluentDataWriterBuilder.java b/gobblin-api/src/main/java/org/apache/gobblin/writer/FluentDataWriterBuilder.java
index 8836359..7953017 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/writer/FluentDataWriterBuilder.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/writer/FluentDataWriterBuilder.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;
/**
* A helper class to help create fluent {@link DataWriterBuilder}s. To make the Java generics magic
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/writer/FsWriterMetrics.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/writer/FsWriterMetrics.java b/gobblin-api/src/main/java/org/apache/gobblin/writer/FsWriterMetrics.java
index c1419bb..374c557 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/writer/FsWriterMetrics.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/writer/FsWriterMetrics.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.Collection;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/writer/PartitionIdentifier.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/writer/PartitionIdentifier.java b/gobblin-api/src/main/java/org/apache/gobblin/writer/PartitionIdentifier.java
index 0e1efc5..332ceef 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/writer/PartitionIdentifier.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/writer/PartitionIdentifier.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 lombok.AllArgsConstructor;
import lombok.Data;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/writer/WatermarkStorage.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/writer/WatermarkStorage.java b/gobblin-api/src/main/java/org/apache/gobblin/writer/WatermarkStorage.java
index cda1b3c..eab115a 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/writer/WatermarkStorage.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/writer/WatermarkStorage.java
@@ -17,13 +17,13 @@
* under the License.
*/
-package gobblin.writer;
+package org.apache.gobblin.writer;
import java.io.IOException;
import java.util.Map;
-import gobblin.annotation.Alpha;
-import gobblin.source.extractor.CheckpointableWatermark;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.source.extractor.CheckpointableWatermark;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/writer/WriterOutputFormat.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/writer/WriterOutputFormat.java b/gobblin-api/src/main/java/org/apache/gobblin/writer/WriterOutputFormat.java
index c2c297d..64714d4 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/writer/WriterOutputFormat.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/writer/WriterOutputFormat.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.writer;
+package org.apache.gobblin.writer;
import org.apache.commons.lang3.StringUtils;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/writer/WriterWrapper.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/writer/WriterWrapper.java b/gobblin-api/src/main/java/org/apache/gobblin/writer/WriterWrapper.java
index 77b195f..edf1473 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/writer/WriterWrapper.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/writer/WriterWrapper.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-api/src/main/java/org/apache/gobblin/writer/initializer/NoopWriterInitializer.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/writer/initializer/NoopWriterInitializer.java b/gobblin-api/src/main/java/org/apache/gobblin/writer/initializer/NoopWriterInitializer.java
index 059a062..60dd419 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/writer/initializer/NoopWriterInitializer.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/writer/initializer/NoopWriterInitializer.java
@@ -15,11 +15,11 @@
* limitations under the License.
*/
-package gobblin.writer.initializer;
+package org.apache.gobblin.writer.initializer;
import lombok.ToString;
-import gobblin.initializer.Initializer;
-import gobblin.initializer.NoopInitializer;
+import org.apache.gobblin.initializer.Initializer;
+import org.apache.gobblin.initializer.NoopInitializer;
@ToString
public class NoopWriterInitializer implements WriterInitializer {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/writer/initializer/WriterInitializer.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/writer/initializer/WriterInitializer.java b/gobblin-api/src/main/java/org/apache/gobblin/writer/initializer/WriterInitializer.java
index 083c658..d05aae1 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/writer/initializer/WriterInitializer.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/writer/initializer/WriterInitializer.java
@@ -15,9 +15,9 @@
* limitations under the License.
*/
-package gobblin.writer.initializer;
+package org.apache.gobblin.writer.initializer;
-import gobblin.initializer.Initializer;
+import org.apache.gobblin.initializer.Initializer;
public interface WriterInitializer extends Initializer {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/test/java/com/linkedin/gobblin/TestAlias.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/test/java/com/linkedin/gobblin/TestAlias.java b/gobblin-api/src/test/java/com/linkedin/gobblin/TestAlias.java
index 4e54d2e..51b92d6 100644
--- a/gobblin-api/src/test/java/com/linkedin/gobblin/TestAlias.java
+++ b/gobblin-api/src/test/java/com/linkedin/gobblin/TestAlias.java
@@ -11,7 +11,7 @@
*/
package com.linkedin.gobblin;
-import gobblin.annotation.Alias;
+import org.apache.gobblin.annotation.Alias;
/**
* Dummy test class to test alias resolution for com.linkedin.gobblin package
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/test/java/org/apache/gobblin/ack/HierarchicalAckableTest.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/test/java/org/apache/gobblin/ack/HierarchicalAckableTest.java b/gobblin-api/src/test/java/org/apache/gobblin/ack/HierarchicalAckableTest.java
index 54c918a..589e6aa 100644
--- a/gobblin-api/src/test/java/org/apache/gobblin/ack/HierarchicalAckableTest.java
+++ b/gobblin-api/src/test/java/org/apache/gobblin/ack/HierarchicalAckableTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.ack;
+package org.apache.gobblin.ack;
import org.testng.Assert;
import org.testng.TestException;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/test/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopesTest.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/test/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopesTest.java b/gobblin-api/src/test/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopesTest.java
index 559978d..78b11f0 100644
--- a/gobblin-api/src/test/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopesTest.java
+++ b/gobblin-api/src/test/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopesTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.broker.gobblin_scopes;
+package org.apache.gobblin.broker.gobblin_scopes;
import org.testng.Assert;
import org.testng.annotations.Test;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/test/java/org/apache/gobblin/compat/TextSerializerTest.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/test/java/org/apache/gobblin/compat/TextSerializerTest.java b/gobblin-api/src/test/java/org/apache/gobblin/compat/TextSerializerTest.java
index 32773cb..04ba79f 100644
--- a/gobblin-api/src/test/java/org/apache/gobblin/compat/TextSerializerTest.java
+++ b/gobblin-api/src/test/java/org/apache/gobblin/compat/TextSerializerTest.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.compat;
+package org.apache.gobblin.compat;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
@@ -28,7 +28,7 @@ import org.testng.annotations.Test;
import com.google.common.base.Strings;
-import gobblin.compat.hadoop.TextSerializer;
+import org.apache.gobblin.compat.hadoop.TextSerializer;
public class TextSerializerTest {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/test/java/org/apache/gobblin/configuration/StateTest.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/test/java/org/apache/gobblin/configuration/StateTest.java b/gobblin-api/src/test/java/org/apache/gobblin/configuration/StateTest.java
index 5dcd8d7..bcfa9a7 100644
--- a/gobblin-api/src/test/java/org/apache/gobblin/configuration/StateTest.java
+++ b/gobblin-api/src/test/java/org/apache/gobblin/configuration/StateTest.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.configuration;
+package org.apache.gobblin.configuration;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/test/java/org/apache/gobblin/converter/ConverterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/test/java/org/apache/gobblin/converter/ConverterTest.java b/gobblin-api/src/test/java/org/apache/gobblin/converter/ConverterTest.java
index 20b47c6..f5f0ed5 100644
--- a/gobblin-api/src/test/java/org/apache/gobblin/converter/ConverterTest.java
+++ b/gobblin-api/src/test/java/org/apache/gobblin/converter/ConverterTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.converter;
+package org.apache.gobblin.converter;
import java.util.List;
@@ -24,12 +24,12 @@ import org.testng.annotations.Test;
import com.google.common.collect.Lists;
-import gobblin.ack.BasicAckableForTesting;
-import gobblin.configuration.WorkUnitState;
-import gobblin.records.RecordStreamWithMetadata;
-import gobblin.stream.ControlMessage;
-import gobblin.stream.RecordEnvelope;
-import gobblin.stream.StreamEntity;
+import org.apache.gobblin.ack.BasicAckableForTesting;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.records.RecordStreamWithMetadata;
+import org.apache.gobblin.stream.ControlMessage;
+import org.apache.gobblin.stream.RecordEnvelope;
+import org.apache.gobblin.stream.StreamEntity;
import io.reactivex.Flowable;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/test/java/org/apache/gobblin/fork/CopyHelperTest.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/test/java/org/apache/gobblin/fork/CopyHelperTest.java b/gobblin-api/src/test/java/org/apache/gobblin/fork/CopyHelperTest.java
index 6463f2a..58e9fae 100644
--- a/gobblin-api/src/test/java/org/apache/gobblin/fork/CopyHelperTest.java
+++ b/gobblin-api/src/test/java/org/apache/gobblin/fork/CopyHelperTest.java
@@ -17,7 +17,7 @@
* under the License.
*/
-package gobblin.fork;
+package org.apache.gobblin.fork;
import java.io.ByteArrayInputStream;
import java.util.Random;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/test/java/org/apache/gobblin/fork/ForkerTest.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/test/java/org/apache/gobblin/fork/ForkerTest.java b/gobblin-api/src/test/java/org/apache/gobblin/fork/ForkerTest.java
index 07dbd01..1c8beb1 100644
--- a/gobblin-api/src/test/java/org/apache/gobblin/fork/ForkerTest.java
+++ b/gobblin-api/src/test/java/org/apache/gobblin/fork/ForkerTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.fork;
+package org.apache.gobblin.fork;
import java.io.IOException;
import java.util.Collections;
@@ -30,12 +30,12 @@ import org.testng.annotations.Test;
import com.google.common.collect.Lists;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.records.RecordStreamWithMetadata;
-import gobblin.runtime.BasicTestControlMessage;
-import gobblin.stream.RecordEnvelope;
-import gobblin.stream.StreamEntity;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.records.RecordStreamWithMetadata;
+import org.apache.gobblin.runtime.BasicTestControlMessage;
+import org.apache.gobblin.stream.RecordEnvelope;
+import org.apache.gobblin.stream.StreamEntity;
import io.reactivex.Flowable;
import lombok.Getter;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/test/java/org/apache/gobblin/password/PasswordManagerTest.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/test/java/org/apache/gobblin/password/PasswordManagerTest.java b/gobblin-api/src/test/java/org/apache/gobblin/password/PasswordManagerTest.java
index bd025f2..6ca0a8a 100644
--- a/gobblin-api/src/test/java/org/apache/gobblin/password/PasswordManagerTest.java
+++ b/gobblin-api/src/test/java/org/apache/gobblin/password/PasswordManagerTest.java
@@ -15,10 +15,10 @@
* limitations under the License.
*/
-package gobblin.password;
+package org.apache.gobblin.password;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
import java.io.File;
import java.io.IOException;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/test/java/org/apache/gobblin/source/extractor/TestWatermark.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/test/java/org/apache/gobblin/source/extractor/TestWatermark.java b/gobblin-api/src/test/java/org/apache/gobblin/source/extractor/TestWatermark.java
index 56ccf87..0552d45 100644
--- a/gobblin-api/src/test/java/org/apache/gobblin/source/extractor/TestWatermark.java
+++ b/gobblin-api/src/test/java/org/apache/gobblin/source/extractor/TestWatermark.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.source.extractor;
+package org.apache.gobblin.source.extractor;
import com.google.gson.Gson;
import com.google.gson.JsonElement;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/test/java/org/apache/gobblin/source/extractor/WatermarkTest.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/test/java/org/apache/gobblin/source/extractor/WatermarkTest.java b/gobblin-api/src/test/java/org/apache/gobblin/source/extractor/WatermarkTest.java
index 499a1a1..9f1dab4 100644
--- a/gobblin-api/src/test/java/org/apache/gobblin/source/extractor/WatermarkTest.java
+++ b/gobblin-api/src/test/java/org/apache/gobblin/source/extractor/WatermarkTest.java
@@ -15,10 +15,10 @@
* limitations under the License.
*/
-package gobblin.source.extractor;
+package org.apache.gobblin.source.extractor;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.workunit.WorkUnit;
import org.testng.Assert;
import org.testng.annotations.Test;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/test/java/org/apache/gobblin/source/workunit/ExtractFactoryTest.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/test/java/org/apache/gobblin/source/workunit/ExtractFactoryTest.java b/gobblin-api/src/test/java/org/apache/gobblin/source/workunit/ExtractFactoryTest.java
index d286324..3dd16e5 100644
--- a/gobblin-api/src/test/java/org/apache/gobblin/source/workunit/ExtractFactoryTest.java
+++ b/gobblin-api/src/test/java/org/apache/gobblin/source/workunit/ExtractFactoryTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.source.workunit;
+package org.apache.gobblin.source.workunit;
import java.util.Set;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/test/java/org/apache/gobblin/stream/RecordEnvelopeTest.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/test/java/org/apache/gobblin/stream/RecordEnvelopeTest.java b/gobblin-api/src/test/java/org/apache/gobblin/stream/RecordEnvelopeTest.java
index ae07f60..2e276fb 100644
--- a/gobblin-api/src/test/java/org/apache/gobblin/stream/RecordEnvelopeTest.java
+++ b/gobblin-api/src/test/java/org/apache/gobblin/stream/RecordEnvelopeTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.stream;
+package org.apache.gobblin.stream;
import java.util.Random;
@@ -24,12 +24,12 @@ import org.testng.annotations.Test;
import com.google.gson.JsonElement;
-import gobblin.ack.BasicAckableForTesting;
-import gobblin.fork.CopyNotSupportedException;
-import gobblin.fork.Copyable;
-import gobblin.source.extractor.CheckpointableWatermark;
-import gobblin.source.extractor.ComparableWatermark;
-import gobblin.source.extractor.Watermark;
+import org.apache.gobblin.ack.BasicAckableForTesting;
+import org.apache.gobblin.fork.CopyNotSupportedException;
+import org.apache.gobblin.fork.Copyable;
+import org.apache.gobblin.source.extractor.CheckpointableWatermark;
+import org.apache.gobblin.source.extractor.ComparableWatermark;
+import org.apache.gobblin.source.extractor.Watermark;
import lombok.AllArgsConstructor;
import lombok.Getter;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/test/java/org/apache/gobblin/stream/StreamEntityTest.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/test/java/org/apache/gobblin/stream/StreamEntityTest.java b/gobblin-api/src/test/java/org/apache/gobblin/stream/StreamEntityTest.java
index e3a5704..b2c2d87 100644
--- a/gobblin-api/src/test/java/org/apache/gobblin/stream/StreamEntityTest.java
+++ b/gobblin-api/src/test/java/org/apache/gobblin/stream/StreamEntityTest.java
@@ -15,14 +15,14 @@
* limitations under the License.
*/
-package gobblin.stream;
+package org.apache.gobblin.stream;
import java.util.Random;
import org.testng.Assert;
import org.testng.annotations.Test;
-import gobblin.ack.BasicAckableForTesting;
+import org.apache.gobblin.ack.BasicAckableForTesting;
public class StreamEntityTest {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/test/java/org/apache/gobblin/testing/AssertWithBackoffTest.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/test/java/org/apache/gobblin/testing/AssertWithBackoffTest.java b/gobblin-api/src/test/java/org/apache/gobblin/testing/AssertWithBackoffTest.java
index 4026c33..7f1fae8 100644
--- a/gobblin-api/src/test/java/org/apache/gobblin/testing/AssertWithBackoffTest.java
+++ b/gobblin-api/src/test/java/org/apache/gobblin/testing/AssertWithBackoffTest.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.testing;
+package org.apache.gobblin.testing;
import java.util.concurrent.TimeoutException;
import java.util.concurrent.atomic.AtomicInteger;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/test/java/org/apache/gobblin/util/ClassAliasResolverTest.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/test/java/org/apache/gobblin/util/ClassAliasResolverTest.java b/gobblin-api/src/test/java/org/apache/gobblin/util/ClassAliasResolverTest.java
index d5e0c59..e4a5cf6 100644
--- a/gobblin-api/src/test/java/org/apache/gobblin/util/ClassAliasResolverTest.java
+++ b/gobblin-api/src/test/java/org/apache/gobblin/util/ClassAliasResolverTest.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.util;
+package org.apache.gobblin.util;
import org.testng.Assert;
import org.testng.annotations.Test;
@@ -22,7 +22,7 @@ import org.testng.annotations.Test;
import com.linkedin.gobblin.TestAlias.DummyAliasCom;
import com.linkedin.gobblin.TestAlias.IDummyAliasCom;
-import gobblin.annotation.Alias;
+import org.apache.gobblin.annotation.Alias;
@Test(groups = { "gobblin.api.util"})
public class ClassAliasResolverTest {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/test/java/org/apache/gobblin/writer/FsWriterMetricsTest.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/test/java/org/apache/gobblin/writer/FsWriterMetricsTest.java b/gobblin-api/src/test/java/org/apache/gobblin/writer/FsWriterMetricsTest.java
index 7f86312..1873862 100644
--- a/gobblin-api/src/test/java/org/apache/gobblin/writer/FsWriterMetricsTest.java
+++ b/gobblin-api/src/test/java/org/apache/gobblin/writer/FsWriterMetricsTest.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.Set;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/auditor/ValueAuditGenerator.java
----------------------------------------------------------------------
diff --git a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/auditor/ValueAuditGenerator.java b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/auditor/ValueAuditGenerator.java
index c408eb0..a658bad 100644
--- a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/auditor/ValueAuditGenerator.java
+++ b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/auditor/ValueAuditGenerator.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.audit.values.auditor;
+package org.apache.gobblin.audit.values.auditor;
import java.io.Closeable;
import java.io.IOException;
@@ -26,12 +26,12 @@ import org.apache.avro.generic.GenericRecord;
import com.typesafe.config.Config;
-import gobblin.audit.values.policy.column.ColumnProjectionPolicy;
-import gobblin.audit.values.policy.column.DefaultColumnProjectionPolicyFactory;
-import gobblin.audit.values.policy.row.DefaultRowSelectionPolicyFactory;
-import gobblin.audit.values.policy.row.RowSelectionPolicy;
-import gobblin.audit.values.sink.AuditSink;
-import gobblin.audit.values.sink.DefaultAuditSinkFactory;
+import org.apache.gobblin.audit.values.policy.column.ColumnProjectionPolicy;
+import org.apache.gobblin.audit.values.policy.column.DefaultColumnProjectionPolicyFactory;
+import org.apache.gobblin.audit.values.policy.row.DefaultRowSelectionPolicyFactory;
+import org.apache.gobblin.audit.values.policy.row.RowSelectionPolicy;
+import org.apache.gobblin.audit.values.sink.AuditSink;
+import org.apache.gobblin.audit.values.sink.DefaultAuditSinkFactory;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/auditor/ValueAuditRuntimeMetadata.java
----------------------------------------------------------------------
diff --git a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/auditor/ValueAuditRuntimeMetadata.java b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/auditor/ValueAuditRuntimeMetadata.java
index 533f22b..d1f5bf2 100644
--- a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/auditor/ValueAuditRuntimeMetadata.java
+++ b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/auditor/ValueAuditRuntimeMetadata.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.audit.values.auditor;
+package org.apache.gobblin.audit.values.auditor;
import java.util.List;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/AbstractColumnProjectionPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/AbstractColumnProjectionPolicy.java b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/AbstractColumnProjectionPolicy.java
index 753d862..59f4e54 100644
--- a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/AbstractColumnProjectionPolicy.java
+++ b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/AbstractColumnProjectionPolicy.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.audit.values.policy.column;
+package org.apache.gobblin.audit.values.policy.column;
import java.util.List;
@@ -23,7 +23,7 @@ import org.apache.avro.Schema;
import com.google.common.collect.ImmutableList;
import com.typesafe.config.Config;
-import gobblin.audit.values.auditor.ValueAuditRuntimeMetadata;
+import org.apache.gobblin.audit.values.auditor.ValueAuditRuntimeMetadata;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/ColumnProjectionPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/ColumnProjectionPolicy.java b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/ColumnProjectionPolicy.java
index 00aff0c..5f08717 100644
--- a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/ColumnProjectionPolicy.java
+++ b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/ColumnProjectionPolicy.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.audit.values.policy.column;
+package org.apache.gobblin.audit.values.policy.column;
import java.util.List;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/DefaultColumnProjectionPolicyFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/DefaultColumnProjectionPolicyFactory.java b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/DefaultColumnProjectionPolicyFactory.java
index 00eb963..b3713f3 100644
--- a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/DefaultColumnProjectionPolicyFactory.java
+++ b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/DefaultColumnProjectionPolicyFactory.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.audit.values.policy.column;
+package org.apache.gobblin.audit.values.policy.column;
import java.lang.reflect.InvocationTargetException;
@@ -25,8 +25,8 @@ import org.apache.commons.lang3.reflect.ConstructorUtils;
import com.google.common.base.Preconditions;
import com.typesafe.config.Config;
-import gobblin.audit.values.auditor.ValueAuditRuntimeMetadata;
-import gobblin.util.ClassAliasResolver;
+import org.apache.gobblin.audit.values.auditor.ValueAuditRuntimeMetadata;
+import org.apache.gobblin.util.ClassAliasResolver;
/**
* Default factory class to create new {@link ColumnProjectionPolicy}s
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/ProjectAllColumnProjectionPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/ProjectAllColumnProjectionPolicy.java b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/ProjectAllColumnProjectionPolicy.java
index 0e0452f..a57e513 100644
--- a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/ProjectAllColumnProjectionPolicy.java
+++ b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/ProjectAllColumnProjectionPolicy.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.audit.values.policy.column;
+package org.apache.gobblin.audit.values.policy.column;
import java.util.List;
@@ -22,8 +22,8 @@ import org.apache.avro.generic.GenericRecord;
import com.typesafe.config.Config;
-import gobblin.annotation.Alias;
-import gobblin.audit.values.auditor.ValueAuditRuntimeMetadata;
+import org.apache.gobblin.annotation.Alias;
+import org.apache.gobblin.audit.values.auditor.ValueAuditRuntimeMetadata;
/**
* An {@link AbstractColumnProjectionPolicy} that projects all columns/fields of the <code>inputRecord</code>
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/AbstractRowSelectionPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/AbstractRowSelectionPolicy.java b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/AbstractRowSelectionPolicy.java
index f9e2358..721bd43 100644
--- a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/AbstractRowSelectionPolicy.java
+++ b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/AbstractRowSelectionPolicy.java
@@ -14,13 +14,13 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.audit.values.policy.row;
+package org.apache.gobblin.audit.values.policy.row;
import com.typesafe.config.Config;
-import gobblin.audit.values.auditor.ValueAuditGenerator;
-import gobblin.audit.values.auditor.ValueAuditRuntimeMetadata;
-import gobblin.audit.values.policy.column.ColumnProjectionPolicy;
+import org.apache.gobblin.audit.values.auditor.ValueAuditGenerator;
+import org.apache.gobblin.audit.values.auditor.ValueAuditRuntimeMetadata;
+import org.apache.gobblin.audit.values.policy.column.ColumnProjectionPolicy;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/DefaultRowSelectionPolicyFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/DefaultRowSelectionPolicyFactory.java b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/DefaultRowSelectionPolicyFactory.java
index dd5b0d7..70a1ec4 100644
--- a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/DefaultRowSelectionPolicyFactory.java
+++ b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/DefaultRowSelectionPolicyFactory.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.audit.values.policy.row;
+package org.apache.gobblin.audit.values.policy.row;
import java.lang.reflect.InvocationTargetException;
@@ -25,10 +25,10 @@ import org.apache.commons.lang3.reflect.ConstructorUtils;
import com.google.common.base.Preconditions;
import com.typesafe.config.Config;
-import gobblin.audit.values.auditor.ValueAuditGenerator;
-import gobblin.audit.values.auditor.ValueAuditRuntimeMetadata;
-import gobblin.audit.values.policy.column.ColumnProjectionPolicy;
-import gobblin.util.ClassAliasResolver;
+import org.apache.gobblin.audit.values.auditor.ValueAuditGenerator;
+import org.apache.gobblin.audit.values.auditor.ValueAuditRuntimeMetadata;
+import org.apache.gobblin.audit.values.policy.column.ColumnProjectionPolicy;
+import org.apache.gobblin.util.ClassAliasResolver;
/**
* Default factory class to create new {@link RowSelectionPolicy}s
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/RowSelectionPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/RowSelectionPolicy.java b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/RowSelectionPolicy.java
index ae520d3..8a0406e 100644
--- a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/RowSelectionPolicy.java
+++ b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/RowSelectionPolicy.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.audit.values.policy.row;
+package org.apache.gobblin.audit.values.policy.row;
import org.apache.avro.generic.GenericRecord;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/SelectAllRowSelectionPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/SelectAllRowSelectionPolicy.java b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/SelectAllRowSelectionPolicy.java
index a794f70..84ba0b9 100644
--- a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/SelectAllRowSelectionPolicy.java
+++ b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/SelectAllRowSelectionPolicy.java
@@ -14,15 +14,15 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.audit.values.policy.row;
+package org.apache.gobblin.audit.values.policy.row;
import org.apache.avro.generic.GenericRecord;
import com.typesafe.config.Config;
-import gobblin.annotation.Alias;
-import gobblin.audit.values.auditor.ValueAuditRuntimeMetadata;
-import gobblin.audit.values.policy.column.ColumnProjectionPolicy;
+import org.apache.gobblin.annotation.Alias;
+import org.apache.gobblin.audit.values.auditor.ValueAuditRuntimeMetadata;
+import org.apache.gobblin.audit.values.policy.column.ColumnProjectionPolicy;
/**
* A {@link RowSelectionPolicy} that selects all rows for auditing
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/sink/AuditSink.java
----------------------------------------------------------------------
diff --git a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/sink/AuditSink.java b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/sink/AuditSink.java
index 8ccabcb..b35a427 100644
--- a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/sink/AuditSink.java
+++ b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/sink/AuditSink.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.audit.values.sink;
+package org.apache.gobblin.audit.values.sink;
import java.io.Closeable;
import java.io.IOException;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/sink/DefaultAuditSinkFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/sink/DefaultAuditSinkFactory.java b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/sink/DefaultAuditSinkFactory.java
index ba3e425..443fbde 100644
--- a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/sink/DefaultAuditSinkFactory.java
+++ b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/sink/DefaultAuditSinkFactory.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.audit.values.sink;
+package org.apache.gobblin.audit.values.sink;
import java.lang.reflect.InvocationTargetException;
@@ -24,8 +24,8 @@ import org.apache.commons.lang3.reflect.ConstructorUtils;
import com.typesafe.config.Config;
-import gobblin.audit.values.auditor.ValueAuditRuntimeMetadata;
-import gobblin.util.ClassAliasResolver;
+import org.apache.gobblin.audit.values.auditor.ValueAuditRuntimeMetadata;
+import org.apache.gobblin.util.ClassAliasResolver;
/**
* Default factory class to create new {@link AuditSink}s
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/sink/FsAuditSink.java
----------------------------------------------------------------------
diff --git a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/sink/FsAuditSink.java b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/sink/FsAuditSink.java
index 2952afc..78d21d6 100644
--- a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/sink/FsAuditSink.java
+++ b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/sink/FsAuditSink.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.audit.values.sink;
+package org.apache.gobblin.audit.values.sink;
import java.io.IOException;
import java.io.OutputStream;
@@ -32,11 +32,11 @@ import org.apache.hadoop.fs.Path;
import com.google.common.io.Closer;
import com.typesafe.config.Config;
-import gobblin.annotation.Alias;
-import gobblin.audit.values.auditor.ValueAuditRuntimeMetadata;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.util.ConfigUtils;
-import gobblin.util.PathUtils;
+import org.apache.gobblin.annotation.Alias;
+import org.apache.gobblin.audit.values.auditor.ValueAuditRuntimeMetadata;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.util.ConfigUtils;
+import org.apache.gobblin.util.PathUtils;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/FsAuditSinkTest.java
----------------------------------------------------------------------
diff --git a/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/FsAuditSinkTest.java b/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/FsAuditSinkTest.java
index c259c15..2085ec7 100644
--- a/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/FsAuditSinkTest.java
+++ b/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/FsAuditSinkTest.java
@@ -14,10 +14,10 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.audit.values;
+package org.apache.gobblin.audit.values;
-import gobblin.audit.values.auditor.ValueAuditRuntimeMetadata;
-import gobblin.audit.values.sink.FsAuditSink;
+import org.apache.gobblin.audit.values.auditor.ValueAuditRuntimeMetadata;
+import org.apache.gobblin.audit.values.sink.FsAuditSink;
import java.io.File;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/MockSink.java
----------------------------------------------------------------------
diff --git a/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/MockSink.java b/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/MockSink.java
index 907e20c..02ed6b1 100644
--- a/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/MockSink.java
+++ b/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/MockSink.java
@@ -14,11 +14,11 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.audit.values;
+package org.apache.gobblin.audit.values;
-import gobblin.annotation.Alias;
-import gobblin.audit.values.auditor.ValueAuditRuntimeMetadata;
-import gobblin.audit.values.sink.AuditSink;
+import org.apache.gobblin.annotation.Alias;
+import org.apache.gobblin.audit.values.auditor.ValueAuditRuntimeMetadata;
+import org.apache.gobblin.audit.values.sink.AuditSink;
import java.io.IOException;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/ValueAuditGeneratorTest.java
----------------------------------------------------------------------
diff --git a/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/ValueAuditGeneratorTest.java b/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/ValueAuditGeneratorTest.java
index b3db7b0..7618720 100644
--- a/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/ValueAuditGeneratorTest.java
+++ b/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/ValueAuditGeneratorTest.java
@@ -14,13 +14,13 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.audit.values;
+package org.apache.gobblin.audit.values;
import static org.mockito.Mockito.mock;
-import gobblin.audit.values.auditor.ValueAuditGenerator;
-import gobblin.audit.values.auditor.ValueAuditRuntimeMetadata;
-import gobblin.audit.values.policy.column.ProjectAllColumnProjectionPolicy;
-import gobblin.audit.values.policy.row.SelectAllRowSelectionPolicy;
+import org.apache.gobblin.audit.values.auditor.ValueAuditGenerator;
+import org.apache.gobblin.audit.values.auditor.ValueAuditRuntimeMetadata;
+import org.apache.gobblin.audit.values.policy.column.ProjectAllColumnProjectionPolicy;
+import org.apache.gobblin.audit.values.policy.row.SelectAllRowSelectionPolicy;
import org.apache.avro.generic.GenericRecord;
import org.mockito.Mockito;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/ValueAuditRuntimeMetadataTest.java
----------------------------------------------------------------------
diff --git a/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/ValueAuditRuntimeMetadataTest.java b/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/ValueAuditRuntimeMetadataTest.java
index 68d7fdf..b51dd42 100644
--- a/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/ValueAuditRuntimeMetadataTest.java
+++ b/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/ValueAuditRuntimeMetadataTest.java
@@ -14,11 +14,11 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.audit.values;
+package org.apache.gobblin.audit.values;
import static org.mockito.Mockito.mock;
-import gobblin.audit.values.auditor.ValueAuditRuntimeMetadata;
-import gobblin.audit.values.auditor.ValueAuditRuntimeMetadata.Phase;
+import org.apache.gobblin.audit.values.auditor.ValueAuditRuntimeMetadata;
+import org.apache.gobblin.audit.values.auditor.ValueAuditRuntimeMetadata.Phase;
import org.apache.avro.Schema;
import org.mockito.Mockito;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSClusterSecurityManager.java
----------------------------------------------------------------------
diff --git a/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSClusterSecurityManager.java b/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSClusterSecurityManager.java
index 9217720..ecd50af 100644
--- a/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSClusterSecurityManager.java
+++ b/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSClusterSecurityManager.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.aws;
+package org.apache.gobblin.aws;
import java.util.concurrent.TimeUnit;
@@ -33,9 +33,9 @@ import com.amazonaws.auth.profile.ProfileCredentialsProvider;
import com.amazonaws.util.StringUtils;
import com.typesafe.config.Config;
-import gobblin.annotation.Alpha;
-import gobblin.password.PasswordManager;
-import gobblin.util.ConfigUtils;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.password.PasswordManager;
+import org.apache.gobblin.util.ConfigUtils;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSJobConfigurationManager.java
----------------------------------------------------------------------
diff --git a/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSJobConfigurationManager.java b/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSJobConfigurationManager.java
index 524d1b9..58f4c9f 100644
--- a/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSJobConfigurationManager.java
+++ b/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSJobConfigurationManager.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.aws;
+package org.apache.gobblin.aws;
import java.io.File;
import java.io.FileOutputStream;
@@ -44,16 +44,16 @@ import com.google.common.collect.Maps;
import com.google.common.eventbus.EventBus;
import com.typesafe.config.Config;
-import gobblin.annotation.Alpha;
-import gobblin.cluster.GobblinClusterConfigurationKeys;
-import gobblin.cluster.GobblinHelixJobScheduler;
-import gobblin.cluster.JobConfigurationManager;
-import gobblin.cluster.event.NewJobConfigArrivalEvent;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.util.ExecutorsUtils;
-import gobblin.util.SchedulerUtils;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.cluster.GobblinClusterConfigurationKeys;
+import org.apache.gobblin.cluster.GobblinHelixJobScheduler;
+import org.apache.gobblin.cluster.JobConfigurationManager;
+import org.apache.gobblin.cluster.event.NewJobConfigArrivalEvent;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.util.ExecutorsUtils;
+import org.apache.gobblin.util.SchedulerUtils;
-import static gobblin.aws.GobblinAWSUtils.appendSlash;
+import static org.apache.gobblin.aws.GobblinAWSUtils.appendSlash;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSSdkClient.java
----------------------------------------------------------------------
diff --git a/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSSdkClient.java b/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSSdkClient.java
index 89d93dc..5066e63 100644
--- a/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSSdkClient.java
+++ b/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSSdkClient.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.aws;
+package org.apache.gobblin.aws;
import java.io.File;
import java.io.IOException;
@@ -68,7 +68,7 @@ import com.google.common.base.Supplier;
import com.google.common.base.Suppliers;
import com.google.common.collect.Lists;
-import gobblin.annotation.Alpha;
+import org.apache.gobblin.annotation.Alpha;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSShutdownHandler.java
----------------------------------------------------------------------
diff --git a/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSShutdownHandler.java b/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSShutdownHandler.java
index c57e804..3afe94a 100644
--- a/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSShutdownHandler.java
+++ b/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSShutdownHandler.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.aws;
+package org.apache.gobblin.aws;
import java.util.List;
@@ -25,7 +25,7 @@ import org.slf4j.LoggerFactory;
import com.google.common.base.Optional;
-import gobblin.annotation.Alpha;
+import org.apache.gobblin.annotation.Alpha;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-aws/src/main/java/org/apache/gobblin/aws/CloudInitScriptBuilder.java
----------------------------------------------------------------------
diff --git a/gobblin-aws/src/main/java/org/apache/gobblin/aws/CloudInitScriptBuilder.java b/gobblin-aws/src/main/java/org/apache/gobblin/aws/CloudInitScriptBuilder.java
index aad4930..fa65f5b 100644
--- a/gobblin-aws/src/main/java/org/apache/gobblin/aws/CloudInitScriptBuilder.java
+++ b/gobblin-aws/src/main/java/org/apache/gobblin/aws/CloudInitScriptBuilder.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.aws;
+package org.apache.gobblin.aws;
import java.io.File;
import java.util.List;
@@ -26,10 +26,10 @@ import org.slf4j.LoggerFactory;
import com.google.common.base.Optional;
import com.google.common.base.Splitter;
-import gobblin.annotation.Alpha;
-import gobblin.cluster.GobblinClusterConfigurationKeys;
-import gobblin.util.JvmUtils;
-import static gobblin.aws.GobblinAWSUtils.encodeBase64;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.cluster.GobblinClusterConfigurationKeys;
+import org.apache.gobblin.util.JvmUtils;
+import static org.apache.gobblin.aws.GobblinAWSUtils.encodeBase64;
/**