gobblin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a...@apache.org
Subject [36/77] [abbrv] incubator-gobblin git commit: Updated package names, imports and shell scripts
Date Mon, 31 Jul 2017 07:52:54 GMT
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;
 
 
 /**


Mime
View raw message