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:55 UTC

[37/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/bin/gobblin-admin.sh
----------------------------------------------------------------------
diff --git a/bin/gobblin-admin.sh b/bin/gobblin-admin.sh
index 7c5e8fc..0a48e2d 100755
--- a/bin/gobblin-admin.sh
+++ b/bin/gobblin-admin.sh
@@ -138,5 +138,5 @@ COMMAND+="-Xloggc:$GOBBLIN_LOG_DIR/gobblin-gc.log "
 COMMAND+="-Dgobblin.logs.dir=$GOBBLIN_LOG_DIR "
 COMMAND+="-Dlog4j.configuration=file://$FWDIR_CONF/log4j-standalone.xml "
 COMMAND+="-cp $CLASSPATH "
-COMMAND+="gobblin.cli.Cli $@"
+COMMAND+="org.apache.gobblin.cli.Cli $@"
 $COMMAND
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/bin/gobblin-compaction.sh
----------------------------------------------------------------------
diff --git a/bin/gobblin-compaction.sh b/bin/gobblin-compaction.sh
index 56826e0..baa8a66 100755
--- a/bin/gobblin-compaction.sh
+++ b/bin/gobblin-compaction.sh
@@ -118,7 +118,7 @@ if [ "$TYPE" == "hive" ]; then
 
   $HADOOP_BIN_DIR/hadoop jar \
         $FWDIR_LIB/gobblin-compaction-$GOBBLIN_VERSION.jar \
-        "gobblin.compaction.hive.CompactionRunner" \
+        "org.apache.gobblin.compaction.hive.CompactionRunner" \
         --jobconfig $COMP_CONFIG_FILE
 
 else
@@ -137,7 +137,7 @@ else
 
   $HADOOP_BIN_DIR/hadoop jar \
         $FWDIR_LIB/gobblin-compaction-$GOBBLIN_VERSION.jar \
-        "gobblin.compaction.mapreduce.MRCompactionRunner" \
+        "org.apache.gobblin.compaction.mapreduce.MRCompactionRunner" \
         -D mapreduce.user.classpath.first=true \
         -D mapreduce.job.user.classpath.first=true \
         -libjars $LIBJARS \

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/bin/gobblin-standalone.sh
----------------------------------------------------------------------
diff --git a/bin/gobblin-standalone.sh b/bin/gobblin-standalone.sh
index 1a90f67..0dd66ca 100755
--- a/bin/gobblin-standalone.sh
+++ b/bin/gobblin-standalone.sh
@@ -198,7 +198,7 @@ start() {
   COMMAND+="-cp $CLASSPATH "
   COMMAND+="-Dorg.quartz.properties=$FWDIR_CONF/quartz.properties "
   COMMAND+="$GOBBLIN_JVM_FLAGS "
-  COMMAND+="gobblin.scheduler.SchedulerDaemon $DEFAULT_CONFIG_FILE $GOBBLIN_CUSTOM_CONFIG_FILE"
+  COMMAND+="org.apache.gobblin.scheduler.SchedulerDaemon $DEFAULT_CONFIG_FILE $GOBBLIN_CUSTOM_CONFIG_FILE"
   echo "Running command:"
   echo "$COMMAND"
   nohup $COMMAND & echo $! > $PID

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/buildSrc/src/main/groovy/org/apache/gobblin/gradle/BuildProperties.groovy
----------------------------------------------------------------------
diff --git a/buildSrc/src/main/groovy/org/apache/gobblin/gradle/BuildProperties.groovy b/buildSrc/src/main/groovy/org/apache/gobblin/gradle/BuildProperties.groovy
index 1c97089..e051673 100644
--- a/buildSrc/src/main/groovy/org/apache/gobblin/gradle/BuildProperties.groovy
+++ b/buildSrc/src/main/groovy/org/apache/gobblin/gradle/BuildProperties.groovy
@@ -1,4 +1,4 @@
-package gobblin.gradle;
+package org.apache.gobblin.gradle;
 
 import java.util.TreeMap
 import org.gradle.api.Project
@@ -28,22 +28,22 @@ public class BuildProperties extends TreeMap<String, BuildProperty> {
 
         // Special treatment for Boolean flags -- just specifying the property
         // is treated as setting to true.
-        if (null != defaultValue && defaultValue instanceof Boolean && 
+        if (null != defaultValue && defaultValue instanceof Boolean &&
                 !((Boolean)defaultValue).booleanValue()) {
             this.project.ext.set(propName, this.project.hasProperty(propName))
-        } 
+        }
         else if (! this.project.hasProperty(propName)) {
             this.project.ext.set(propName, defaultValue)
         }
 
         println String.format("Build property: %s=%s", propName, this.project.ext.get(propName))
-    } 
+    }
 
     public void printHelp() {
         println "\n\n"
         println "BUILD PROPERTIES"
         println ""
-        this.each { propName, propHelp -> 
+        this.each { propName, propHelp ->
             println propHelp.getHelp()
         }
     }

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/buildSrc/src/main/groovy/org/apache/gobblin/gradle/BuildProperty.groovy
----------------------------------------------------------------------
diff --git a/buildSrc/src/main/groovy/org/apache/gobblin/gradle/BuildProperty.groovy b/buildSrc/src/main/groovy/org/apache/gobblin/gradle/BuildProperty.groovy
index e49c7f1..24a8349 100644
--- a/buildSrc/src/main/groovy/org/apache/gobblin/gradle/BuildProperty.groovy
+++ b/buildSrc/src/main/groovy/org/apache/gobblin/gradle/BuildProperty.groovy
@@ -1,4 +1,4 @@
-package gobblin.gradle;
+package org.apache.gobblin.gradle;
 
 /**
  * Encapsulates various aspects of a project property that can be used to customize the build through

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-admin/src/main/java/org/apache/gobblin/admin/AdminWebServer.java
----------------------------------------------------------------------
diff --git a/gobblin-admin/src/main/java/org/apache/gobblin/admin/AdminWebServer.java b/gobblin-admin/src/main/java/org/apache/gobblin/admin/AdminWebServer.java
index 5c3a593..d3f5f7e 100644
--- a/gobblin-admin/src/main/java/org/apache/gobblin/admin/AdminWebServer.java
+++ b/gobblin-admin/src/main/java/org/apache/gobblin/admin/AdminWebServer.java
@@ -14,11 +14,11 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.admin;
+package org.apache.gobblin.admin;
 
 import com.google.common.base.Preconditions;
 import com.google.common.util.concurrent.AbstractIdleService;
-import gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.ConfigurationKeys;
 import org.eclipse.jetty.server.Handler;
 import org.eclipse.jetty.server.Request;
 import org.eclipse.jetty.server.Server;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-admin/src/main/java/org/apache/gobblin/admin/DefaultAdminWebServerFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-admin/src/main/java/org/apache/gobblin/admin/DefaultAdminWebServerFactory.java b/gobblin-admin/src/main/java/org/apache/gobblin/admin/DefaultAdminWebServerFactory.java
index 87c2112..09c2478 100644
--- a/gobblin-admin/src/main/java/org/apache/gobblin/admin/DefaultAdminWebServerFactory.java
+++ b/gobblin-admin/src/main/java/org/apache/gobblin/admin/DefaultAdminWebServerFactory.java
@@ -14,15 +14,15 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.admin;
+package org.apache.gobblin.admin;
 
 import java.net.URI;
 import java.util.Properties;
 
 import com.google.common.util.concurrent.Service;
 
-import gobblin.annotation.Alias;
-import gobblin.runtime.api.AdminWebServerFactory;
+import org.apache.gobblin.annotation.Alias;
+import org.apache.gobblin.runtime.api.AdminWebServerFactory;
 
 /**
  * A factory for the default implementation of the admin web server

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-admin/src/main/java/org/apache/gobblin/cli/AdminClient.java
----------------------------------------------------------------------
diff --git a/gobblin-admin/src/main/java/org/apache/gobblin/cli/AdminClient.java b/gobblin-admin/src/main/java/org/apache/gobblin/cli/AdminClient.java
index 31ecaa7..a8268eb 100644
--- a/gobblin-admin/src/main/java/org/apache/gobblin/cli/AdminClient.java
+++ b/gobblin-admin/src/main/java/org/apache/gobblin/cli/AdminClient.java
@@ -14,13 +14,13 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.cli;
+package org.apache.gobblin.cli;
 
 import com.google.common.base.Optional;
 import com.google.common.io.Closer;
 import com.linkedin.r2.RemoteInvocationException;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.rest.*;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.rest.*;
 
 import java.io.IOException;
 import java.net.URI;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-admin/src/main/java/org/apache/gobblin/cli/Cli.java
----------------------------------------------------------------------
diff --git a/gobblin-admin/src/main/java/org/apache/gobblin/cli/Cli.java b/gobblin-admin/src/main/java/org/apache/gobblin/cli/Cli.java
index 0d16bcb..61ca72d 100644
--- a/gobblin-admin/src/main/java/org/apache/gobblin/cli/Cli.java
+++ b/gobblin-admin/src/main/java/org/apache/gobblin/cli/Cli.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.cli;
+package org.apache.gobblin.cli;
 
 import java.util.Arrays;
 import java.util.Collection;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-admin/src/main/java/org/apache/gobblin/cli/CliTablePrinter.java
----------------------------------------------------------------------
diff --git a/gobblin-admin/src/main/java/org/apache/gobblin/cli/CliTablePrinter.java b/gobblin-admin/src/main/java/org/apache/gobblin/cli/CliTablePrinter.java
index 400391b..3c033ab 100644
--- a/gobblin-admin/src/main/java/org/apache/gobblin/cli/CliTablePrinter.java
+++ b/gobblin-admin/src/main/java/org/apache/gobblin/cli/CliTablePrinter.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.cli;
+package org.apache.gobblin.cli;
 
 import java.util.ArrayList;
 import java.util.List;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-admin/src/main/java/org/apache/gobblin/cli/Command.java
----------------------------------------------------------------------
diff --git a/gobblin-admin/src/main/java/org/apache/gobblin/cli/Command.java b/gobblin-admin/src/main/java/org/apache/gobblin/cli/Command.java
index 0da14fc..6598da4 100644
--- a/gobblin-admin/src/main/java/org/apache/gobblin/cli/Command.java
+++ b/gobblin-admin/src/main/java/org/apache/gobblin/cli/Command.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.cli;
+package org.apache.gobblin.cli;
 
 /**
  * Represents a single command for the CLI

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-admin/src/main/java/org/apache/gobblin/cli/JobCommand.java
----------------------------------------------------------------------
diff --git a/gobblin-admin/src/main/java/org/apache/gobblin/cli/JobCommand.java b/gobblin-admin/src/main/java/org/apache/gobblin/cli/JobCommand.java
index 67a9058..bb37012 100644
--- a/gobblin-admin/src/main/java/org/apache/gobblin/cli/JobCommand.java
+++ b/gobblin-admin/src/main/java/org/apache/gobblin/cli/JobCommand.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.cli;
+package org.apache.gobblin.cli;
 
 import java.util.List;
 import java.util.Map;
@@ -31,8 +31,8 @@ import com.google.common.base.Optional;
 import com.google.common.collect.ImmutableMap;
 import com.linkedin.r2.RemoteInvocationException;
 
-import gobblin.rest.JobExecutionInfo;
-import gobblin.rest.QueryListType;
+import org.apache.gobblin.rest.JobExecutionInfo;
+import org.apache.gobblin.rest.QueryListType;
 
 /**
  * Logic to print out job state

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-admin/src/main/java/org/apache/gobblin/cli/JobInfoPrintUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-admin/src/main/java/org/apache/gobblin/cli/JobInfoPrintUtils.java b/gobblin-admin/src/main/java/org/apache/gobblin/cli/JobInfoPrintUtils.java
index 207847b..3d0c08d 100644
--- a/gobblin-admin/src/main/java/org/apache/gobblin/cli/JobInfoPrintUtils.java
+++ b/gobblin-admin/src/main/java/org/apache/gobblin/cli/JobInfoPrintUtils.java
@@ -14,13 +14,13 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.cli;
+package org.apache.gobblin.cli;
 
 import com.google.common.base.Optional;
 import com.linkedin.data.template.StringMap;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.metrics.MetricNames;
-import gobblin.rest.*;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.metrics.MetricNames;
+import org.apache.gobblin.rest.*;
 import org.joda.time.Period;
 import org.joda.time.format.DateTimeFormatter;
 import org.joda.time.format.ISODateTimeFormat;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-admin/src/test/java/org/apache/gobblin/admin/AdminWebServerTest.java
----------------------------------------------------------------------
diff --git a/gobblin-admin/src/test/java/org/apache/gobblin/admin/AdminWebServerTest.java b/gobblin-admin/src/test/java/org/apache/gobblin/admin/AdminWebServerTest.java
index 9698a01..4b17fe4 100644
--- a/gobblin-admin/src/test/java/org/apache/gobblin/admin/AdminWebServerTest.java
+++ b/gobblin-admin/src/test/java/org/apache/gobblin/admin/AdminWebServerTest.java
@@ -14,9 +14,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.admin;
+package org.apache.gobblin.admin;
 
-import gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.ConfigurationKeys;
 import org.apache.http.HttpEntity;
 import org.apache.http.client.methods.CloseableHttpResponse;
 import org.apache.http.client.methods.HttpGet;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/Constructs.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/Constructs.java b/gobblin-api/src/main/java/org/apache/gobblin/Constructs.java
index 03e2418..4b80d75 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/Constructs.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/Constructs.java
@@ -17,14 +17,14 @@
 
 package gobblin;
 
-import gobblin.converter.Converter;
-import gobblin.fork.ForkOperator;
-import gobblin.publisher.DataPublisher;
-import gobblin.qualitychecker.row.RowLevelPolicy;
-import gobblin.qualitychecker.task.TaskLevelPolicy;
-import gobblin.source.Source;
-import gobblin.source.extractor.Extractor;
-import gobblin.writer.DataWriter;
+import org.apache.gobblin.converter.Converter;
+import org.apache.gobblin.fork.ForkOperator;
+import org.apache.gobblin.publisher.DataPublisher;
+import org.apache.gobblin.qualitychecker.row.RowLevelPolicy;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicy;
+import org.apache.gobblin.source.Source;
+import org.apache.gobblin.source.extractor.Extractor;
+import org.apache.gobblin.writer.DataWriter;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/ack/Ackable.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/ack/Ackable.java b/gobblin-api/src/main/java/org/apache/gobblin/ack/Ackable.java
index 35b6a49..4eb1c8e 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/ack/Ackable.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/ack/Ackable.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.ack;
+package org.apache.gobblin.ack;
 
 /**
  * An interface for entities that can be acked

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/ack/BasicAckableForTesting.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/ack/BasicAckableForTesting.java b/gobblin-api/src/main/java/org/apache/gobblin/ack/BasicAckableForTesting.java
index 4642f7f..77c8c17 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/ack/BasicAckableForTesting.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/ack/BasicAckableForTesting.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.ack;
+package org.apache.gobblin.ack;
 
 /**
  * An ackable used for testing that just counts the times it is acked and nacked.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/ack/HierarchicalAckable.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/ack/HierarchicalAckable.java b/gobblin-api/src/main/java/org/apache/gobblin/ack/HierarchicalAckable.java
index e6bb10d..fb24cba 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/ack/HierarchicalAckable.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/ack/HierarchicalAckable.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.ack;
+package org.apache.gobblin.ack;
 
 import java.io.Closeable;
 import java.util.List;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/annotation/Alias.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/annotation/Alias.java b/gobblin-api/src/main/java/org/apache/gobblin/annotation/Alias.java
index 92e4d2f..ba8866e 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/annotation/Alias.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/annotation/Alias.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.annotation;
+package org.apache.gobblin.annotation;
 
 import java.lang.annotation.Documented;
 import java.lang.annotation.ElementType;
@@ -22,7 +22,7 @@ import java.lang.annotation.Retention;
 import java.lang.annotation.RetentionPolicy;
 import java.lang.annotation.Target;
 
-import gobblin.util.ClassAliasResolver;
+import org.apache.gobblin.util.ClassAliasResolver;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/annotation/Alpha.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/annotation/Alpha.java b/gobblin-api/src/main/java/org/apache/gobblin/annotation/Alpha.java
index d0bc604..06b5406 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/annotation/Alpha.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/annotation/Alpha.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.annotation;
+package org.apache.gobblin.annotation;
 
 import java.lang.annotation.Documented;
 import java.lang.annotation.ElementType;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/annotation/Beta.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/annotation/Beta.java b/gobblin-api/src/main/java/org/apache/gobblin/annotation/Beta.java
index be60e79..551a4b1 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/annotation/Beta.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/annotation/Beta.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.annotation;
+package org.apache.gobblin.annotation;
 
 import java.lang.annotation.Documented;
 import java.lang.annotation.ElementType;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/annotation/Stable.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/annotation/Stable.java b/gobblin-api/src/main/java/org/apache/gobblin/annotation/Stable.java
index 77342ae..597c07f 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/annotation/Stable.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/annotation/Stable.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.annotation;
+package org.apache.gobblin.annotation;
 
 import java.lang.annotation.Documented;
 import java.lang.annotation.ElementType;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/BrokerConstants.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/BrokerConstants.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/BrokerConstants.java
index fbe7e36..cc1737d 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/broker/BrokerConstants.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/BrokerConstants.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.broker;
+package org.apache.gobblin.broker;
 
 /**
  * Constants used for {@link gobblin.broker.iface.SharedResourcesBroker}.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/ResourceCoordinate.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/ResourceCoordinate.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/ResourceCoordinate.java
index e9d5a77..9144a18 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/broker/ResourceCoordinate.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/ResourceCoordinate.java
@@ -15,12 +15,12 @@
  * limitations under the License.
  */
 
-package gobblin.broker;
+package org.apache.gobblin.broker;
 
-import gobblin.broker.iface.ScopeType;
-import gobblin.broker.iface.SharedResourceFactory;
-import gobblin.broker.iface.SharedResourceFactoryResponse;
-import gobblin.broker.iface.SharedResourceKey;
+import org.apache.gobblin.broker.iface.ScopeType;
+import org.apache.gobblin.broker.iface.SharedResourceFactory;
+import org.apache.gobblin.broker.iface.SharedResourceFactoryResponse;
+import org.apache.gobblin.broker.iface.SharedResourceKey;
 import lombok.Data;
 
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/ResourceEntry.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/ResourceEntry.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/ResourceEntry.java
index a801b7d..496ee25 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/broker/ResourceEntry.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/ResourceEntry.java
@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package gobblin.broker;
+package org.apache.gobblin.broker;
 
-import gobblin.broker.iface.SharedResourceFactoryResponse;
+import org.apache.gobblin.broker.iface.SharedResourceFactoryResponse;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/SimpleScope.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/SimpleScope.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/SimpleScope.java
index 0ade538..3f2bea1 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/broker/SimpleScope.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/SimpleScope.java
@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package gobblin.broker;
+package org.apache.gobblin.broker;
 
-import gobblin.broker.iface.ScopeInstance;
-import gobblin.broker.iface.ScopeType;
+import org.apache.gobblin.broker.iface.ScopeInstance;
+import org.apache.gobblin.broker.iface.ScopeType;
 
 import lombok.Data;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/SimpleScopeType.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/SimpleScopeType.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/SimpleScopeType.java
index f1a34ba..8678226 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/broker/SimpleScopeType.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/SimpleScopeType.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.broker;
+package org.apache.gobblin.broker;
 
 import java.util.Collection;
 import java.util.List;
@@ -24,8 +24,8 @@ import java.util.Set;
 import com.google.common.collect.Lists;
 import com.google.common.collect.Sets;
 
-import gobblin.broker.iface.ScopeInstance;
-import gobblin.broker.iface.ScopeType;
+import org.apache.gobblin.broker.iface.ScopeInstance;
+import org.apache.gobblin.broker.iface.ScopeType;
 
 import javax.annotation.Nullable;
 import lombok.AllArgsConstructor;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeInstance.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeInstance.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeInstance.java
index 8f966b6..3229560 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeInstance.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeInstance.java
@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package gobblin.broker.gobblin_scopes;
+package org.apache.gobblin.broker.gobblin_scopes;
 
-import gobblin.broker.SimpleScope;
+import org.apache.gobblin.broker.SimpleScope;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeTypes.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeTypes.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeTypes.java
index f307d22..4a9e010 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeTypes.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeTypes.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.broker.gobblin_scopes;
+package org.apache.gobblin.broker.gobblin_scopes;
 
 import java.util.Collection;
 import java.util.List;
@@ -24,8 +24,8 @@ import java.util.Set;
 import com.google.common.collect.Lists;
 import com.google.common.collect.Sets;
 
-import gobblin.broker.iface.ScopeInstance;
-import gobblin.broker.iface.ScopeType;
+import org.apache.gobblin.broker.iface.ScopeInstance;
+import org.apache.gobblin.broker.iface.ScopeType;
 
 import javax.annotation.Nullable;
 import lombok.AccessLevel;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/JobScopeInstance.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/JobScopeInstance.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/JobScopeInstance.java
index 3394b93..53f30cb 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/JobScopeInstance.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/JobScopeInstance.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.broker.gobblin_scopes;
+package org.apache.gobblin.broker.gobblin_scopes;
 
 import lombok.Getter;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/TaskScopeInstance.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/TaskScopeInstance.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/TaskScopeInstance.java
index f992e7f..35592f7 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/TaskScopeInstance.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/TaskScopeInstance.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.broker.gobblin_scopes;
+package org.apache.gobblin.broker.gobblin_scopes;
 
 import lombok.Getter;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ConfigView.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ConfigView.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ConfigView.java
index 94ce8ca..69237a7 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ConfigView.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ConfigView.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.broker.iface;
+package org.apache.gobblin.broker.iface;
 
 import com.typesafe.config.Config;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/NoSuchScopeException.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/NoSuchScopeException.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/NoSuchScopeException.java
index 7059eee..61dce6d 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/NoSuchScopeException.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/NoSuchScopeException.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.broker.iface;
+package org.apache.gobblin.broker.iface;
 
 /**
  * Exception thrown when trying to access a {@link ScopeInstance} that is not defined in a {@link SharedResourcesBroker}.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/NotConfiguredException.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/NotConfiguredException.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/NotConfiguredException.java
index f3dcc42..b3a8f2f 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/NotConfiguredException.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/NotConfiguredException.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.broker.iface;
+package org.apache.gobblin.broker.iface;
 
 /**
  * Exception thrown by a factory if there is not enough provided configuration to create the

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ScopeInstance.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ScopeInstance.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ScopeInstance.java
index edde3c0..d6eb47c 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ScopeInstance.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ScopeInstance.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.broker.iface;
+package org.apache.gobblin.broker.iface;
 
 /**
  * A specific scope for a {@link ScopeType}. For example, each task in a process could be a different scope.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ScopeType.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ScopeType.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ScopeType.java
index 5112f73..8e5ecfb 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ScopeType.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ScopeType.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.broker.iface;
+package org.apache.gobblin.broker.iface;
 
 import java.util.Collection;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ScopedConfigView.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ScopedConfigView.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ScopedConfigView.java
index c42b657..88062d6 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ScopedConfigView.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/ScopedConfigView.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.broker.iface;
+package org.apache.gobblin.broker.iface;
 
 import com.typesafe.config.Config;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourceFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourceFactory.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourceFactory.java
index b5dc725..fcb4661 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourceFactory.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourceFactory.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.broker.iface;
+package org.apache.gobblin.broker.iface;
 
 /**
  * A factory that creates {@link ScopeInstance} specific objects.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourceFactoryResponse.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourceFactoryResponse.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourceFactoryResponse.java
index 84ca7f0..3579f27 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourceFactoryResponse.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourceFactoryResponse.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.broker.iface;
+package org.apache.gobblin.broker.iface;
 
 /**
  * An empty interface for responses from a {@link SharedResourceFactory}.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourceKey.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourceKey.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourceKey.java
index 3edc9ff..63b6dcb 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourceKey.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourceKey.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.broker.iface;
+package org.apache.gobblin.broker.iface;
 
 /**
  * A key to differentiate objects generated by the same factory for a {@link SharedResourcesBroker}. The

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourcesBroker.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourcesBroker.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourcesBroker.java
index 266be92..e999967 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourcesBroker.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourcesBroker.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.broker.iface;
+package org.apache.gobblin.broker.iface;
 
 import java.io.Closeable;
 import java.io.IOException;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SubscopedBrokerBuilder.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SubscopedBrokerBuilder.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SubscopedBrokerBuilder.java
index 398d15a..7bb0d2f 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SubscopedBrokerBuilder.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SubscopedBrokerBuilder.java
@@ -15,11 +15,11 @@
  * limitations under the License.
  */
 
-package gobblin.broker.iface;
+package org.apache.gobblin.broker.iface;
 
 import com.typesafe.config.Config;
 
-import gobblin.broker.BrokerConstants;
+import org.apache.gobblin.broker.BrokerConstants;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/codec/StreamCodec.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/codec/StreamCodec.java b/gobblin-api/src/main/java/org/apache/gobblin/codec/StreamCodec.java
index 59c478d..a6593fa 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/codec/StreamCodec.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/codec/StreamCodec.java
@@ -15,13 +15,13 @@
  * limitations under the License.
  */
 
-package gobblin.codec;
+package org.apache.gobblin.codec;
 
 import java.io.IOException;
 import java.io.InputStream;
 import java.io.OutputStream;
 
-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/commit/CommitSequence.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitSequence.java b/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitSequence.java
index 0ce8bc6..92d2b1a 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitSequence.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitSequence.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.commit;
+package org.apache.gobblin.commit;
 
 import java.util.List;
 
@@ -25,7 +25,7 @@ import com.google.common.base.Throwables;
 import com.google.common.collect.ImmutableList;
 import com.google.common.collect.Lists;
 
-import gobblin.annotation.Alpha;
+import org.apache.gobblin.annotation.Alpha;
 import lombok.Getter;
 import lombok.extern.slf4j.Slf4j;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitSequenceStore.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitSequenceStore.java b/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitSequenceStore.java
index f32047b..5d3c254 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitSequenceStore.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitSequenceStore.java
@@ -15,14 +15,14 @@
  * limitations under the License.
  */
 
-package gobblin.commit;
+package org.apache.gobblin.commit;
 
 import java.io.IOException;
 import java.util.Collection;
 
 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-api/src/main/java/org/apache/gobblin/commit/CommitStep.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitStep.java b/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitStep.java
index 8b3b98f..74e9de7 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitStep.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitStep.java
@@ -15,11 +15,11 @@
  * limitations under the License.
  */
 
-package gobblin.commit;
+package org.apache.gobblin.commit;
 
 import java.io.IOException;
 
-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/commit/CommitStepBase.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitStepBase.java b/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitStepBase.java
index 7c2ef10..3e9fd70 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitStepBase.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/commit/CommitStepBase.java
@@ -15,15 +15,15 @@
  * limitations under the License.
  */
 
-package gobblin.commit;
+package org.apache.gobblin.commit;
 
 import java.io.IOException;
 
 import com.google.common.base.Optional;
 import com.google.common.base.Preconditions;
 
-import gobblin.annotation.Alpha;
-import gobblin.configuration.State;
+import org.apache.gobblin.annotation.Alpha;
+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/commit/DeliverySemantics.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/commit/DeliverySemantics.java b/gobblin-api/src/main/java/org/apache/gobblin/commit/DeliverySemantics.java
index a1223d6..80f00f8 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/commit/DeliverySemantics.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/commit/DeliverySemantics.java
@@ -15,14 +15,14 @@
  * limitations under the License.
  */
 
-package gobblin.commit;
+package org.apache.gobblin.commit;
 
 import com.google.common.base.Enums;
 import com.google.common.base.Optional;
 import com.google.common.base.Preconditions;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+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/compat/hadoop/TextSerializer.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/compat/hadoop/TextSerializer.java b/gobblin-api/src/main/java/org/apache/gobblin/compat/hadoop/TextSerializer.java
index 8067804..a0939d6 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/compat/hadoop/TextSerializer.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/compat/hadoop/TextSerializer.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.compat.hadoop;
+package org.apache.gobblin.compat.hadoop;
 
 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/compat/hadoop/WritableShim.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/compat/hadoop/WritableShim.java b/gobblin-api/src/main/java/org/apache/gobblin/compat/hadoop/WritableShim.java
index ffedd29..859e9d5 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/compat/hadoop/WritableShim.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/compat/hadoop/WritableShim.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.compat.hadoop;
+package org.apache.gobblin.compat.hadoop;
 
 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/configuration/ConfigurationKeys.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/configuration/ConfigurationKeys.java b/gobblin-api/src/main/java/org/apache/gobblin/configuration/ConfigurationKeys.java
index 5bb8460..c77f871 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/configuration/ConfigurationKeys.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/configuration/ConfigurationKeys.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.configuration;
+package org.apache.gobblin.configuration;
 
 import java.nio.charset.Charset;
 import java.util.concurrent.TimeUnit;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/configuration/ImmutableWorkUnitState.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/configuration/ImmutableWorkUnitState.java b/gobblin-api/src/main/java/org/apache/gobblin/configuration/ImmutableWorkUnitState.java
index 5f45030..3c1cff6 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/configuration/ImmutableWorkUnitState.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/configuration/ImmutableWorkUnitState.java
@@ -15,13 +15,13 @@
  * limitations under the License.
  */
 
-package gobblin.configuration;
+package org.apache.gobblin.configuration;
 
 import java.io.DataInput;
 import java.io.IOException;
 import java.util.Properties;
 
-import gobblin.source.extractor.Watermark;
+import org.apache.gobblin.source.extractor.Watermark;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/configuration/SourceState.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/configuration/SourceState.java b/gobblin-api/src/main/java/org/apache/gobblin/configuration/SourceState.java
index 8baa280..141386a 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/configuration/SourceState.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/configuration/SourceState.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.configuration;
+package org.apache.gobblin.configuration;
 
 import java.io.DataInput;
 import java.io.DataOutput;
@@ -37,8 +37,8 @@ import com.google.common.collect.Lists;
 import com.google.common.collect.Maps;
 import com.google.common.collect.Sets;
 
-import gobblin.source.workunit.WorkUnit;
-import gobblin.source.workunit.Extract;
+import org.apache.gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.source.workunit.Extract;
 
 import lombok.Getter;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/configuration/State.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/configuration/State.java b/gobblin-api/src/main/java/org/apache/gobblin/configuration/State.java
index f4ac748..20b6e17 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/configuration/State.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/configuration/State.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.configuration;
+package org.apache.gobblin.configuration;
 
 import java.io.DataInput;
 import java.io.DataOutput;
@@ -40,8 +40,8 @@ import com.google.gson.JsonParser;
 import lombok.EqualsAndHashCode;
 import lombok.Getter;
 
-import gobblin.compat.hadoop.TextSerializer;
-import gobblin.compat.hadoop.WritableShim;
+import org.apache.gobblin.compat.hadoop.TextSerializer;
+import org.apache.gobblin.compat.hadoop.WritableShim;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/configuration/StateUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/configuration/StateUtils.java b/gobblin-api/src/main/java/org/apache/gobblin/configuration/StateUtils.java
index 870d15e..df1dfdc 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/configuration/StateUtils.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/configuration/StateUtils.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.configuration;
+package org.apache.gobblin.configuration;
 
 import java.util.Arrays;
 import java.util.List;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/configuration/WorkUnitState.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/configuration/WorkUnitState.java b/gobblin-api/src/main/java/org/apache/gobblin/configuration/WorkUnitState.java
index 6d148fd61..1a8ea89 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/configuration/WorkUnitState.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/configuration/WorkUnitState.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.configuration;
+package org.apache.gobblin.configuration;
 
 import java.io.DataInput;
 import java.io.DataOutput;
@@ -29,13 +29,13 @@ import com.google.gson.Gson;
 import com.google.gson.JsonElement;
 import com.google.gson.JsonParser;
 
-import gobblin.broker.gobblin_scopes.GobblinScopeTypes;
-import gobblin.broker.iface.SharedResourcesBroker;
-import gobblin.broker.iface.SubscopedBrokerBuilder;
-import gobblin.source.extractor.Watermark;
-import gobblin.source.workunit.Extract;
-import gobblin.source.workunit.ImmutableWorkUnit;
-import gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.broker.gobblin_scopes.GobblinScopeTypes;
+import org.apache.gobblin.broker.iface.SharedResourcesBroker;
+import org.apache.gobblin.broker.iface.SubscopedBrokerBuilder;
+import org.apache.gobblin.source.extractor.Watermark;
+import org.apache.gobblin.source.workunit.Extract;
+import org.apache.gobblin.source.workunit.ImmutableWorkUnit;
+import org.apache.gobblin.source.workunit.WorkUnit;
 
 import javax.annotation.Nullable;
 import lombok.Getter;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/converter/Converter.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/converter/Converter.java b/gobblin-api/src/main/java/org/apache/gobblin/converter/Converter.java
index 822cb58..49544fe 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/converter/Converter.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/converter/Converter.java
@@ -15,24 +15,24 @@
  * limitations under the License.
  */
 
-package gobblin.converter;
+package org.apache.gobblin.converter;
 
 import java.io.Closeable;
 import java.io.IOException;
 import java.util.Iterator;
 
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.initializer.ConverterInitializer;
-import gobblin.converter.initializer.NoopConverterInitializer;
-import gobblin.stream.ControlMessage;
-import gobblin.records.ControlMessageHandler;
-import gobblin.records.RecordStreamProcessor;
-import gobblin.records.RecordStreamWithMetadata;
-import gobblin.stream.RecordEnvelope;
-import gobblin.source.workunit.WorkUnitStream;
-import gobblin.stream.StreamEntity;
-import gobblin.util.FinalState;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.initializer.ConverterInitializer;
+import org.apache.gobblin.converter.initializer.NoopConverterInitializer;
+import org.apache.gobblin.stream.ControlMessage;
+import org.apache.gobblin.records.ControlMessageHandler;
+import org.apache.gobblin.records.RecordStreamProcessor;
+import org.apache.gobblin.records.RecordStreamWithMetadata;
+import org.apache.gobblin.stream.RecordEnvelope;
+import org.apache.gobblin.source.workunit.WorkUnitStream;
+import org.apache.gobblin.stream.StreamEntity;
+import org.apache.gobblin.util.FinalState;
 
 import io.reactivex.Flowable;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/converter/DataConversionException.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/converter/DataConversionException.java b/gobblin-api/src/main/java/org/apache/gobblin/converter/DataConversionException.java
index f9f6af7..9167b2e 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/converter/DataConversionException.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/converter/DataConversionException.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.converter;
+package org.apache.gobblin.converter;
 
 /**
  * A type of {@link Exception} thrown when there's anything wrong

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/converter/SchemaConversionException.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/converter/SchemaConversionException.java b/gobblin-api/src/main/java/org/apache/gobblin/converter/SchemaConversionException.java
index bd2e443..801e167 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/converter/SchemaConversionException.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/converter/SchemaConversionException.java
@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package gobblin.converter;
+package org.apache.gobblin.converter;
 
-import gobblin.records.RecordStreamProcessor;
+import org.apache.gobblin.records.RecordStreamProcessor;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/converter/initializer/ConverterInitializer.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/converter/initializer/ConverterInitializer.java b/gobblin-api/src/main/java/org/apache/gobblin/converter/initializer/ConverterInitializer.java
index 26ea1ee..79dbebe 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/converter/initializer/ConverterInitializer.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/converter/initializer/ConverterInitializer.java
@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package gobblin.converter.initializer;
+package org.apache.gobblin.converter.initializer;
 
-import gobblin.initializer.Initializer;
+import org.apache.gobblin.initializer.Initializer;
 
 /**
  * ConverterInitializer is being invoked at driver which means it will only invoked once per converter.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/converter/initializer/NoopConverterInitializer.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/converter/initializer/NoopConverterInitializer.java b/gobblin-api/src/main/java/org/apache/gobblin/converter/initializer/NoopConverterInitializer.java
index b9c5b90..6410b45 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/converter/initializer/NoopConverterInitializer.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/converter/initializer/NoopConverterInitializer.java
@@ -15,11 +15,11 @@
  * limitations under the License.
  */
 
-package gobblin.converter.initializer;
+package org.apache.gobblin.converter.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

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/crypto/CredentialStore.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/crypto/CredentialStore.java b/gobblin-api/src/main/java/org/apache/gobblin/crypto/CredentialStore.java
index 1dcabd2..bc313ae 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/crypto/CredentialStore.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/crypto/CredentialStore.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.crypto;
+package org.apache.gobblin.crypto;
 
 import java.util.Map;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/crypto/CredentialStoreProvider.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/crypto/CredentialStoreProvider.java b/gobblin-api/src/main/java/org/apache/gobblin/crypto/CredentialStoreProvider.java
index 1bc14b7..ca9c28f 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/crypto/CredentialStoreProvider.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/crypto/CredentialStoreProvider.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.crypto;
+package org.apache.gobblin.crypto;
 
 import java.util.Map;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/crypto/EncryptionProvider.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/crypto/EncryptionProvider.java b/gobblin-api/src/main/java/org/apache/gobblin/crypto/EncryptionProvider.java
index aa81bbf..5ea09f8 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/crypto/EncryptionProvider.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/crypto/EncryptionProvider.java
@@ -14,11 +14,11 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.crypto;
+package org.apache.gobblin.crypto;
 
 import java.util.Map;
 
-import gobblin.codec.StreamCodec;
+import org.apache.gobblin.codec.StreamCodec;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/dataset/Dataset.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/dataset/Dataset.java b/gobblin-api/src/main/java/org/apache/gobblin/dataset/Dataset.java
index cac6a54..fb8c1fa 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/dataset/Dataset.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/dataset/Dataset.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.dataset;
+package org.apache.gobblin.dataset;
 
 /**
  * Interface representing a dataset.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/dataset/DatasetsFinder.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/dataset/DatasetsFinder.java b/gobblin-api/src/main/java/org/apache/gobblin/dataset/DatasetsFinder.java
index cc040fa..27a4dae 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/dataset/DatasetsFinder.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/dataset/DatasetsFinder.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.dataset;
+package org.apache.gobblin.dataset;
 
 import java.io.IOException;
 import java.util.List;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/dataset/FileSystemDataset.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/dataset/FileSystemDataset.java b/gobblin-api/src/main/java/org/apache/gobblin/dataset/FileSystemDataset.java
index 8532255..2c5051c 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/dataset/FileSystemDataset.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/dataset/FileSystemDataset.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.dataset;
+package org.apache.gobblin.dataset;
 
 import org.apache.hadoop.fs.Path;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/dataset/IterableDatasetFinder.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/dataset/IterableDatasetFinder.java b/gobblin-api/src/main/java/org/apache/gobblin/dataset/IterableDatasetFinder.java
index 5b5f9cc..93f9586 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/dataset/IterableDatasetFinder.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/dataset/IterableDatasetFinder.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.dataset;
+package org.apache.gobblin.dataset;
 
 import java.io.IOException;
 import java.util.Iterator;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/dataset/IterableDatasetFinderImpl.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/dataset/IterableDatasetFinderImpl.java b/gobblin-api/src/main/java/org/apache/gobblin/dataset/IterableDatasetFinderImpl.java
index f959fd8..af09996 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/dataset/IterableDatasetFinderImpl.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/dataset/IterableDatasetFinderImpl.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.dataset;
+package org.apache.gobblin.dataset;
 
 import java.io.IOException;
 import java.util.Iterator;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/fork/CopyHelper.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/fork/CopyHelper.java b/gobblin-api/src/main/java/org/apache/gobblin/fork/CopyHelper.java
index 34a07c9..e145937 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/fork/CopyHelper.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/fork/CopyHelper.java
@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package gobblin.fork;
+package org.apache.gobblin.fork;
 
 /**
  * A helper class to copy things that may or may not be {@link Copyable}.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/fork/CopyNotSupportedException.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/fork/CopyNotSupportedException.java b/gobblin-api/src/main/java/org/apache/gobblin/fork/CopyNotSupportedException.java
index b08ada7..93970ac 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/fork/CopyNotSupportedException.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/fork/CopyNotSupportedException.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.fork;
+package org.apache.gobblin.fork;
 
 /**
  * A type of {@link java.lang.Exception}s thrown when copying is not supported.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/fork/Copyable.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/fork/Copyable.java b/gobblin-api/src/main/java/org/apache/gobblin/fork/Copyable.java
index a8dc1b6..a57e627 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/fork/Copyable.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/fork/Copyable.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.fork;
+package org.apache.gobblin.fork;
 
 /**
  * An interface for classes that supports making copies of their instances.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/fork/ForkOperator.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/fork/ForkOperator.java b/gobblin-api/src/main/java/org/apache/gobblin/fork/ForkOperator.java
index 5dd535b..615852c 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/fork/ForkOperator.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/fork/ForkOperator.java
@@ -15,12 +15,12 @@
  * limitations under the License.
  */
 
-package gobblin.fork;
+package org.apache.gobblin.fork;
 
 import java.io.Closeable;
 import java.util.List;
 
-import gobblin.configuration.WorkUnitState;
+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/fork/Forker.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/fork/Forker.java b/gobblin-api/src/main/java/org/apache/gobblin/fork/Forker.java
index 69e0cb3..d70e5ba 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/fork/Forker.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/fork/Forker.java
@@ -15,19 +15,19 @@
  * limitations under the License.
  */
 
-package gobblin.fork;
+package org.apache.gobblin.fork;
 
 import java.util.List;
 
 import com.google.common.base.Preconditions;
 import com.google.common.collect.Lists;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.records.RecordStreamWithMetadata;
-import gobblin.stream.ControlMessage;
-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.stream.ControlMessage;
+import org.apache.gobblin.stream.RecordEnvelope;
+import org.apache.gobblin.stream.StreamEntity;
 
 import io.reactivex.Flowable;
 import io.reactivex.flowables.ConnectableFlowable;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/initializer/Initializer.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/initializer/Initializer.java b/gobblin-api/src/main/java/org/apache/gobblin/initializer/Initializer.java
index bb56a0b..4454c8a 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/initializer/Initializer.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/initializer/Initializer.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.initializer;
+package org.apache.gobblin.initializer;
 
 import java.io.Closeable;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/initializer/NoopInitializer.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/initializer/NoopInitializer.java b/gobblin-api/src/main/java/org/apache/gobblin/initializer/NoopInitializer.java
index 68aa2af..d98e8a0 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/initializer/NoopInitializer.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/initializer/NoopInitializer.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.initializer;
+package org.apache.gobblin.initializer;
 
 import lombok.ToString;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/metadata/MetadataMerger.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/metadata/MetadataMerger.java b/gobblin-api/src/main/java/org/apache/gobblin/metadata/MetadataMerger.java
index 048949f..4cabedc 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/metadata/MetadataMerger.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/metadata/MetadataMerger.java
@@ -14,9 +14,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.metadata;
+package org.apache.gobblin.metadata;
 
-import gobblin.writer.FsWriterMetrics;
+import org.apache.gobblin.writer.FsWriterMetrics;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/password/PasswordManager.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/password/PasswordManager.java b/gobblin-api/src/main/java/org/apache/gobblin/password/PasswordManager.java
index 50cd0b4..6df6d7e 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/password/PasswordManager.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/password/PasswordManager.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.password;
+package org.apache.gobblin.password;
 
 import java.io.IOException;
 import java.io.InputStream;
@@ -47,8 +47,8 @@ import com.google.common.cache.LoadingCache;
 import com.google.common.io.Closer;
 import com.google.common.io.LineReader;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+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/publisher/DataPublisher.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/publisher/DataPublisher.java b/gobblin-api/src/main/java/org/apache/gobblin/publisher/DataPublisher.java
index c65d935..a190d4a 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/publisher/DataPublisher.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/publisher/DataPublisher.java
@@ -15,16 +15,16 @@
  * limitations under the License.
  */
 
-package gobblin.publisher;
+package org.apache.gobblin.publisher;
 
 import java.io.Closeable;
 import java.io.IOException;
 import java.lang.reflect.Constructor;
 import java.util.Collection;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+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/publisher/SingleTaskDataPublisher.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/publisher/SingleTaskDataPublisher.java b/gobblin-api/src/main/java/org/apache/gobblin/publisher/SingleTaskDataPublisher.java
index f8213a8..9ae84de 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/publisher/SingleTaskDataPublisher.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/publisher/SingleTaskDataPublisher.java
@@ -15,14 +15,14 @@
  * limitations under the License.
  */
 
-package gobblin.publisher;
+package org.apache.gobblin.publisher;
 
 import java.io.IOException;
 
 import com.google.common.base.Preconditions;
 
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/publisher/UnpublishedHandling.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/publisher/UnpublishedHandling.java b/gobblin-api/src/main/java/org/apache/gobblin/publisher/UnpublishedHandling.java
index 103c038..fbce8cb 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/publisher/UnpublishedHandling.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/publisher/UnpublishedHandling.java
@@ -15,12 +15,12 @@
  * limitations under the License.
  */
 
-package gobblin.publisher;
+package org.apache.gobblin.publisher;
 
 import java.io.IOException;
 import java.util.Collection;
 
-import gobblin.configuration.WorkUnitState;
+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/qualitychecker/row/RowLevelPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicy.java b/gobblin-api/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicy.java
index a860325..de718eb 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicy.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicy.java
@@ -15,14 +15,14 @@
  * limitations under the License.
  */
 
-package gobblin.qualitychecker.row;
+package org.apache.gobblin.qualitychecker.row;
 
 import java.io.Closeable;
 import java.io.IOException;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.util.FinalState;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.util.FinalState;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/qualitychecker/task/TaskLevelPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/qualitychecker/task/TaskLevelPolicy.java b/gobblin-api/src/main/java/org/apache/gobblin/qualitychecker/task/TaskLevelPolicy.java
index 2531729..d016adf 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/qualitychecker/task/TaskLevelPolicy.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/qualitychecker/task/TaskLevelPolicy.java
@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package gobblin.qualitychecker.task;
+package org.apache.gobblin.qualitychecker.task;
 
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
 
 
 public abstract class TaskLevelPolicy {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/FieldDoesNotExistException.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/FieldDoesNotExistException.java b/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/FieldDoesNotExistException.java
index e58efec..05556c4 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/FieldDoesNotExistException.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/FieldDoesNotExistException.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.recordaccess;
+package org.apache.gobblin.recordaccess;
 
 public class FieldDoesNotExistException extends RecordAccessorException {
   public FieldDoesNotExistException(String msg) {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/IncorrectTypeException.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/IncorrectTypeException.java b/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/IncorrectTypeException.java
index 505bb17..adff060 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/IncorrectTypeException.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/IncorrectTypeException.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.recordaccess;
+package org.apache.gobblin.recordaccess;
 
 /**
  * Thrown when a get() or set() call on an Accessor accesses a record with an

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/RecordAccessor.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/RecordAccessor.java b/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/RecordAccessor.java
index 5139da4..5791771 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/RecordAccessor.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/RecordAccessor.java
@@ -14,11 +14,11 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.recordaccess;
+package org.apache.gobblin.recordaccess;
 
 import java.util.Map;
 
-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/recordaccess/RecordAccessorException.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/RecordAccessorException.java b/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/RecordAccessorException.java
index d0f7901..617f917 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/RecordAccessorException.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/RecordAccessorException.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.recordaccess;
+package org.apache.gobblin.recordaccess;
 
 /**
  * Base class for exceptions thrown by RecordAccessors. Exceptions are Runtime rather

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/RecordAccessorProvider.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/RecordAccessorProvider.java b/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/RecordAccessorProvider.java
index 034d5f7..d10d7af 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/RecordAccessorProvider.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/recordaccess/RecordAccessorProvider.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.recordaccess;
+package org.apache.gobblin.recordaccess;
 
 /**
  * A ServiceProvider that can construct a RecordAccessor based on an object's type.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/records/ControlMessageHandler.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/records/ControlMessageHandler.java b/gobblin-api/src/main/java/org/apache/gobblin/records/ControlMessageHandler.java
index 4364a45..51ec907 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/records/ControlMessageHandler.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/records/ControlMessageHandler.java
@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package gobblin.records;
+package org.apache.gobblin.records;
 
-import gobblin.stream.ControlMessage;
+import org.apache.gobblin.stream.ControlMessage;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/records/FlushControlMessageHandler.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/records/FlushControlMessageHandler.java b/gobblin-api/src/main/java/org/apache/gobblin/records/FlushControlMessageHandler.java
index fe8e41e..3047a2d 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/records/FlushControlMessageHandler.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/records/FlushControlMessageHandler.java
@@ -14,13 +14,13 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.records;
+package org.apache.gobblin.records;
 
 import java.io.Flushable;
 import java.io.IOException;
 
-import gobblin.stream.ControlMessage;
-import gobblin.stream.FlushControlMessage;
+import org.apache.gobblin.stream.ControlMessage;
+import org.apache.gobblin.stream.FlushControlMessage;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/records/RecordStreamConsumer.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/records/RecordStreamConsumer.java b/gobblin-api/src/main/java/org/apache/gobblin/records/RecordStreamConsumer.java
index 66a9592..3c53ff4 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/records/RecordStreamConsumer.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/records/RecordStreamConsumer.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.records;
+package org.apache.gobblin.records;
 
 /**
  * An object that a {@link RecordStreamWithMetadata}.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/records/RecordStreamProcessor.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/records/RecordStreamProcessor.java b/gobblin-api/src/main/java/org/apache/gobblin/records/RecordStreamProcessor.java
index 40791c1..62a9325 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/records/RecordStreamProcessor.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/records/RecordStreamProcessor.java
@@ -15,11 +15,11 @@
  * limitations under the License.
  */
 
-package gobblin.records;
+package org.apache.gobblin.records;
 
 import java.io.IOException;
 
-import gobblin.configuration.WorkUnitState;
+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/records/RecordStreamWithMetadata.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/records/RecordStreamWithMetadata.java b/gobblin-api/src/main/java/org/apache/gobblin/records/RecordStreamWithMetadata.java
index 5a4197a..57c1e7c 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/records/RecordStreamWithMetadata.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/records/RecordStreamWithMetadata.java
@@ -15,12 +15,12 @@
  * limitations under the License.
  */
 
-package gobblin.records;
+package org.apache.gobblin.records;
 
 import java.util.function.Function;
 
-import gobblin.stream.RecordEnvelope;
-import gobblin.stream.StreamEntity;
+import org.apache.gobblin.stream.RecordEnvelope;
+import org.apache.gobblin.stream.StreamEntity;
 
 import io.reactivex.Flowable;
 import lombok.Data;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/runtime/BasicTestControlMessage.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/runtime/BasicTestControlMessage.java b/gobblin-api/src/main/java/org/apache/gobblin/runtime/BasicTestControlMessage.java
index b434390..5796a71 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/runtime/BasicTestControlMessage.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/runtime/BasicTestControlMessage.java
@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package gobblin.runtime;
+package org.apache.gobblin.runtime;
 
-import gobblin.stream.ControlMessage;
-import gobblin.stream.StreamEntity;
+import org.apache.gobblin.stream.ControlMessage;
+import org.apache.gobblin.stream.StreamEntity;
 
 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/runtime/api/AdminWebServerFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/AdminWebServerFactory.java b/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/AdminWebServerFactory.java
index f9f998d..3a448a9 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/AdminWebServerFactory.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/AdminWebServerFactory.java
@@ -14,14 +14,14 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.runtime.api;
+package org.apache.gobblin.runtime.api;
 
 import java.net.URI;
 import java.util.Properties;
 
 import com.google.common.util.concurrent.Service;
 
-import gobblin.annotation.Alpha;
+import org.apache.gobblin.annotation.Alpha;
 
 /**
  * A factory interface for AdminWebServer.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/Spec.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/Spec.java b/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/Spec.java
index 1d9bc83..0dda7fa 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/Spec.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/Spec.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.api;
+package org.apache.gobblin.runtime.api;
 
 import java.io.Serializable;
 import java.net.URI;