gobblin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a...@apache.org
Subject [07/77] [abbrv] incubator-gobblin git commit: Updated package names, imports and shell scripts
Date Mon, 31 Jul 2017 07:52:25 GMT
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/services/MetricsReportingService.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/services/MetricsReportingService.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/services/MetricsReportingService.java
index 29b52c5..43b53cd 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/services/MetricsReportingService.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/services/MetricsReportingService.java
@@ -15,13 +15,13 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.services;
+package org.apache.gobblin.runtime.services;
 
 import java.util.Properties;
 
 import com.google.common.util.concurrent.AbstractIdleService;
 
-import gobblin.metrics.GobblinMetrics;
+import org.apache.gobblin.metrics.GobblinMetrics;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/FlowCatalog.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/FlowCatalog.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/FlowCatalog.java
index 633a5af..8abfc42 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/FlowCatalog.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/FlowCatalog.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.spec_catalog;
+package org.apache.gobblin.runtime.spec_catalog;
 
 import java.io.IOException;
 import java.lang.reflect.InvocationTargetException;
@@ -35,22 +35,22 @@ import com.google.common.util.concurrent.AbstractIdleService;
 import com.google.common.base.Preconditions;
 import com.typesafe.config.Config;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.instrumented.Instrumented;
-import gobblin.runtime.api.GobblinInstanceEnvironment;
-import gobblin.annotation.Alpha;
-import gobblin.metrics.MetricContext;
-import gobblin.metrics.Tag;
-import gobblin.runtime.api.FlowSpec;
-import gobblin.runtime.api.MutableSpecCatalog;
-import gobblin.runtime.api.Spec;
-import gobblin.runtime.api.SpecCatalog;
-import gobblin.runtime.api.SpecCatalogListener;
-import gobblin.runtime.api.SpecNotFoundException;
-import gobblin.runtime.api.SpecSerDe;
-import gobblin.runtime.api.SpecStore;
-import gobblin.runtime.spec_store.FSSpecStore;
-import gobblin.util.ClassAliasResolver;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.instrumented.Instrumented;
+import org.apache.gobblin.runtime.api.GobblinInstanceEnvironment;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.metrics.MetricContext;
+import org.apache.gobblin.metrics.Tag;
+import org.apache.gobblin.runtime.api.FlowSpec;
+import org.apache.gobblin.runtime.api.MutableSpecCatalog;
+import org.apache.gobblin.runtime.api.Spec;
+import org.apache.gobblin.runtime.api.SpecCatalog;
+import org.apache.gobblin.runtime.api.SpecCatalogListener;
+import org.apache.gobblin.runtime.api.SpecNotFoundException;
+import org.apache.gobblin.runtime.api.SpecSerDe;
+import org.apache.gobblin.runtime.api.SpecStore;
+import org.apache.gobblin.runtime.spec_store.FSSpecStore;
+import org.apache.gobblin.util.ClassAliasResolver;
 
 
 @Alpha

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/SpecCatalogListenersList.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/SpecCatalogListenersList.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/SpecCatalogListenersList.java
index cbc43ee..cdb9379 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/SpecCatalogListenersList.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/SpecCatalogListenersList.java
@@ -49,7 +49,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.spec_catalog;
+package org.apache.gobblin.runtime.spec_catalog;
 
 import java.io.Closeable;
 import java.io.IOException;
@@ -63,10 +63,10 @@ import com.google.common.base.Function;
 import com.google.common.base.Optional;
 import com.google.common.base.Preconditions;
 
-import gobblin.runtime.api.SpecCatalogListener;
-import gobblin.runtime.api.SpecCatalogListenersContainer;
-import gobblin.runtime.api.Spec;
-import gobblin.util.callbacks.CallbacksDispatcher;
+import org.apache.gobblin.runtime.api.SpecCatalogListener;
+import org.apache.gobblin.runtime.api.SpecCatalogListenersContainer;
+import org.apache.gobblin.runtime.api.Spec;
+import org.apache.gobblin.util.callbacks.CallbacksDispatcher;
 
 
 public class SpecCatalogListenersList implements SpecCatalogListener, SpecCatalogListenersContainer, Closeable {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/TopologyCatalog.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/TopologyCatalog.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/TopologyCatalog.java
index 144bedc..057ef7c 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/TopologyCatalog.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/TopologyCatalog.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.spec_catalog;
+package org.apache.gobblin.runtime.spec_catalog;
 
 import java.io.IOException;
 import java.lang.reflect.InvocationTargetException;
@@ -36,22 +36,22 @@ import com.google.common.util.concurrent.AbstractIdleService;
 import com.google.common.util.concurrent.Service;
 import com.typesafe.config.Config;
 
-import gobblin.annotation.Alpha;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.instrumented.Instrumented;
-import gobblin.metrics.MetricContext;
-import gobblin.metrics.Tag;
-import gobblin.runtime.api.GobblinInstanceEnvironment;
-import gobblin.runtime.api.MutableSpecCatalog;
-import gobblin.runtime.api.Spec;
-import gobblin.runtime.api.SpecCatalog;
-import gobblin.runtime.api.SpecCatalogListener;
-import gobblin.runtime.api.SpecNotFoundException;
-import gobblin.runtime.api.SpecSerDe;
-import gobblin.runtime.api.SpecStore;
-import gobblin.runtime.api.TopologySpec;
-import gobblin.runtime.spec_store.FSSpecStore;
-import gobblin.util.ClassAliasResolver;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.instrumented.Instrumented;
+import org.apache.gobblin.metrics.MetricContext;
+import org.apache.gobblin.metrics.Tag;
+import org.apache.gobblin.runtime.api.GobblinInstanceEnvironment;
+import org.apache.gobblin.runtime.api.MutableSpecCatalog;
+import org.apache.gobblin.runtime.api.Spec;
+import org.apache.gobblin.runtime.api.SpecCatalog;
+import org.apache.gobblin.runtime.api.SpecCatalogListener;
+import org.apache.gobblin.runtime.api.SpecNotFoundException;
+import org.apache.gobblin.runtime.api.SpecSerDe;
+import org.apache.gobblin.runtime.api.SpecStore;
+import org.apache.gobblin.runtime.api.TopologySpec;
+import org.apache.gobblin.runtime.spec_store.FSSpecStore;
+import org.apache.gobblin.util.ClassAliasResolver;
 
 
 @Alpha

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_executorInstance/InMemorySpecExecutorInstanceProducer.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_executorInstance/InMemorySpecExecutorInstanceProducer.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_executorInstance/InMemorySpecExecutorInstanceProducer.java
index 91dbc89..77faaa7 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_executorInstance/InMemorySpecExecutorInstanceProducer.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_executorInstance/InMemorySpecExecutorInstanceProducer.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.spec_executorInstance;
+package org.apache.gobblin.runtime.spec_executorInstance;
 
 import java.io.Serializable;
 import java.net.URI;
@@ -36,11 +36,11 @@ import com.google.common.collect.Lists;
 import com.google.common.collect.Maps;
 import com.typesafe.config.Config;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.api.GobblinInstanceEnvironment;
-import gobblin.runtime.api.Spec;
-import gobblin.runtime.api.SpecExecutorInstanceProducer;
-import gobblin.util.CompletedFuture;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.api.GobblinInstanceEnvironment;
+import org.apache.gobblin.runtime.api.Spec;
+import org.apache.gobblin.runtime.api.SpecExecutorInstanceProducer;
+import org.apache.gobblin.util.CompletedFuture;
 
 
 public class InMemorySpecExecutorInstanceProducer implements SpecExecutorInstanceProducer<Spec>, Serializable {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_store/FSSpecStore.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_store/FSSpecStore.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_store/FSSpecStore.java
index 62bdf21..f852aea 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_store/FSSpecStore.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_store/FSSpecStore.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.spec_store;
+package org.apache.gobblin.runtime.spec_store;
 
 import java.io.IOException;
 import java.net.URI;
@@ -37,13 +37,13 @@ import com.google.common.base.Preconditions;
 import com.google.common.collect.Lists;
 import com.typesafe.config.Config;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.api.GobblinInstanceEnvironment;
-import gobblin.runtime.api.Spec;
-import gobblin.runtime.api.SpecNotFoundException;
-import gobblin.runtime.api.SpecSerDe;
-import gobblin.runtime.api.SpecStore;
-import gobblin.util.PathUtils;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.api.GobblinInstanceEnvironment;
+import org.apache.gobblin.runtime.api.Spec;
+import org.apache.gobblin.runtime.api.SpecNotFoundException;
+import org.apache.gobblin.runtime.api.SpecSerDe;
+import org.apache.gobblin.runtime.api.SpecStore;
+import org.apache.gobblin.util.PathUtils;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultConfigurableImpl.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultConfigurableImpl.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultConfigurableImpl.java
index 4e1832b..908e4d1 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultConfigurableImpl.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultConfigurableImpl.java
@@ -14,14 +14,14 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.runtime.std;
+package org.apache.gobblin.runtime.std;
 
 import java.util.Properties;
 
 import com.typesafe.config.Config;
 
-import gobblin.runtime.api.Configurable;
-import gobblin.util.ConfigUtils;
+import org.apache.gobblin.runtime.api.Configurable;
+import org.apache.gobblin.util.ConfigUtils;
 
 /**
  * Default immutable implementation for {@link Configurable} interface.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobCatalogListenerImpl.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobCatalogListenerImpl.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobCatalogListenerImpl.java
index a5bfdea..1b61c5d 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobCatalogListenerImpl.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobCatalogListenerImpl.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.runtime.std;
+package org.apache.gobblin.runtime.std;
 
 import java.net.URI;
 
@@ -22,8 +22,8 @@ import org.slf4j.Logger;
 
 import com.google.common.base.Optional;
 
-import gobblin.runtime.api.JobCatalogListener;
-import gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.api.JobCatalogListener;
+import org.apache.gobblin.runtime.api.JobSpec;
 
 /**
  * Default NOOP implementation for {@link JobCatalogListener}. It can log the callbacks. Other

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobExecutionStateListenerImpl.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobExecutionStateListenerImpl.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobExecutionStateListenerImpl.java
index 542b14d..7ebc5f4 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobExecutionStateListenerImpl.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobExecutionStateListenerImpl.java
@@ -14,15 +14,15 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.runtime.std;
+package org.apache.gobblin.runtime.std;
 
 import org.slf4j.Logger;
 
 import com.google.common.base.Optional;
 
-import gobblin.runtime.JobState.RunningState;
-import gobblin.runtime.api.JobExecutionState;
-import gobblin.runtime.api.JobExecutionStateListener;
+import org.apache.gobblin.runtime.JobState.RunningState;
+import org.apache.gobblin.runtime.api.JobExecutionState;
+import org.apache.gobblin.runtime.api.JobExecutionStateListener;
 
 /**
  * Default NOOP implementation for a {@link JobExecutionStateListener}. The implementation can

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobLifecycleListenerImpl.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobLifecycleListenerImpl.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobLifecycleListenerImpl.java
index 0519c7d..ce1a6cf 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobLifecycleListenerImpl.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobLifecycleListenerImpl.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.runtime.std;
+package org.apache.gobblin.runtime.std;
 
 import java.net.URI;
 
@@ -22,12 +22,12 @@ import org.slf4j.Logger;
 
 import com.google.common.base.Optional;
 
-import gobblin.runtime.JobState.RunningState;
-import gobblin.runtime.api.JobExecutionDriver;
-import gobblin.runtime.api.JobExecutionState;
-import gobblin.runtime.api.JobLifecycleListener;
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.api.JobSpecSchedule;
+import org.apache.gobblin.runtime.JobState.RunningState;
+import org.apache.gobblin.runtime.api.JobExecutionDriver;
+import org.apache.gobblin.runtime.api.JobExecutionState;
+import org.apache.gobblin.runtime.api.JobLifecycleListener;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.api.JobSpecSchedule;
 
 /**
  * Default NOOP implementation for {@link JobLifecycleListener}. It can log the callbacks. Other

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobSpecScheduleImpl.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobSpecScheduleImpl.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobSpecScheduleImpl.java
index d90613e..c5af6e0 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobSpecScheduleImpl.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobSpecScheduleImpl.java
@@ -14,12 +14,12 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.runtime.std;
+package org.apache.gobblin.runtime.std;
 
 import com.google.common.base.Optional;
 
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.api.JobSpecSchedule;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.api.JobSpecSchedule;
 
 import lombok.Data;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/FilteredJobLifecycleListener.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/FilteredJobLifecycleListener.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/FilteredJobLifecycleListener.java
index 4396cb1..c16425b 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/FilteredJobLifecycleListener.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/FilteredJobLifecycleListener.java
@@ -14,18 +14,18 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.runtime.std;
+package org.apache.gobblin.runtime.std;
 
 import java.net.URI;
 
 import com.google.common.base.Predicate;
 
-import gobblin.runtime.JobState.RunningState;
-import gobblin.runtime.api.JobExecutionDriver;
-import gobblin.runtime.api.JobExecutionState;
-import gobblin.runtime.api.JobLifecycleListener;
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.api.JobSpecSchedule;
+import org.apache.gobblin.runtime.JobState.RunningState;
+import org.apache.gobblin.runtime.api.JobExecutionDriver;
+import org.apache.gobblin.runtime.api.JobExecutionState;
+import org.apache.gobblin.runtime.api.JobLifecycleListener;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.api.JobSpecSchedule;
 
 import lombok.AllArgsConstructor;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobExecutionStateListeners.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobExecutionStateListeners.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobExecutionStateListeners.java
index 7e97f97..537dd6d 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobExecutionStateListeners.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobExecutionStateListeners.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.runtime.std;
+package org.apache.gobblin.runtime.std;
 
 import java.io.Closeable;
 import java.io.IOException;
@@ -24,11 +24,11 @@ import org.slf4j.Logger;
 
 import com.google.common.base.Optional;
 
-import gobblin.runtime.JobState.RunningState;
-import gobblin.runtime.api.JobExecutionState;
-import gobblin.runtime.api.JobExecutionStateListener;
-import gobblin.runtime.api.JobExecutionStateListenerContainer;
-import gobblin.util.callbacks.CallbacksDispatcher;
+import org.apache.gobblin.runtime.JobState.RunningState;
+import org.apache.gobblin.runtime.api.JobExecutionState;
+import org.apache.gobblin.runtime.api.JobExecutionStateListener;
+import org.apache.gobblin.runtime.api.JobExecutionStateListenerContainer;
+import org.apache.gobblin.util.callbacks.CallbacksDispatcher;
 
 /**
  * A helper class to maintain a list of {@link JobExecutionStateListener} instances. It itself

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobExecutionUpdatable.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobExecutionUpdatable.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobExecutionUpdatable.java
index ef1574c..5d97fa0 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobExecutionUpdatable.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobExecutionUpdatable.java
@@ -14,15 +14,15 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.runtime.std;
+package org.apache.gobblin.runtime.std;
 
 import java.net.URI;
 
-import gobblin.annotation.Alpha;
-import gobblin.runtime.JobState;
-import gobblin.runtime.api.JobExecution;
-import gobblin.runtime.api.JobSpec;
-import gobblin.util.JobLauncherUtils;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.runtime.JobState;
+import org.apache.gobblin.runtime.api.JobExecution;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.util.JobLauncherUtils;
 
 import lombok.AllArgsConstructor;
 import lombok.Data;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobLifecycleListenersList.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobLifecycleListenersList.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobLifecycleListenersList.java
index c46fc1a..8338187 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobLifecycleListenersList.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobLifecycleListenersList.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.runtime.std;
+package org.apache.gobblin.runtime.std;
 
 import java.io.Closeable;
 import java.io.IOException;
@@ -25,17 +25,17 @@ import org.slf4j.Logger;
 
 import com.google.common.base.Optional;
 
-import gobblin.runtime.JobState.RunningState;
-import gobblin.runtime.api.JobCatalogListenersContainer;
-import gobblin.runtime.api.JobExecutionDriver;
-import gobblin.runtime.api.JobExecutionState;
-import gobblin.runtime.api.JobExecutionStateListener.MetadataChangeCallback;
-import gobblin.runtime.api.JobExecutionStateListener.StageTransitionCallback;
-import gobblin.runtime.api.JobExecutionStateListener.StatusChangeCallback;
-import gobblin.runtime.api.JobLifecycleListener;
-import gobblin.runtime.api.JobLifecycleListenersContainer;
-import gobblin.runtime.api.JobSpecSchedulerListenersContainer;
-import gobblin.util.callbacks.CallbacksDispatcher;
+import org.apache.gobblin.runtime.JobState.RunningState;
+import org.apache.gobblin.runtime.api.JobCatalogListenersContainer;
+import org.apache.gobblin.runtime.api.JobExecutionDriver;
+import org.apache.gobblin.runtime.api.JobExecutionState;
+import org.apache.gobblin.runtime.api.JobExecutionStateListener.MetadataChangeCallback;
+import org.apache.gobblin.runtime.api.JobExecutionStateListener.StageTransitionCallback;
+import org.apache.gobblin.runtime.api.JobExecutionStateListener.StatusChangeCallback;
+import org.apache.gobblin.runtime.api.JobLifecycleListener;
+import org.apache.gobblin.runtime.api.JobLifecycleListenersContainer;
+import org.apache.gobblin.runtime.api.JobSpecSchedulerListenersContainer;
+import org.apache.gobblin.util.callbacks.CallbacksDispatcher;
 
 /**
  * A default implementation to manage a list of {@link JobLifecycleListener}

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobSpecFilter.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobSpecFilter.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobSpecFilter.java
index 7c6f523..657daf5 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobSpecFilter.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobSpecFilter.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.runtime.std;
+package org.apache.gobblin.runtime.std;
 
 import java.net.URI;
 import java.net.URISyntaxException;
@@ -24,7 +24,7 @@ import com.google.common.base.Preconditions;
 import com.google.common.base.Predicate;
 import com.google.common.base.Predicates;
 
-import gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.api.JobSpec;
 
 import lombok.AllArgsConstructor;
 import lombok.Getter;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/BaseAbstractTask.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/BaseAbstractTask.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/BaseAbstractTask.java
index 4cca361..71e2b39 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/BaseAbstractTask.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/BaseAbstractTask.java
@@ -15,13 +15,13 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.task;
+package org.apache.gobblin.runtime.task;
 
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.metrics.MetricContext;
-import gobblin.runtime.TaskContext;
-import gobblin.runtime.util.TaskMetrics;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.metrics.MetricContext;
+import org.apache.gobblin.runtime.TaskContext;
+import org.apache.gobblin.runtime.util.TaskMetrics;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/FailedTask.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/FailedTask.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/FailedTask.java
index 6651db4..21dca10 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/FailedTask.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/FailedTask.java
@@ -1,11 +1,11 @@
-package gobblin.runtime.task;
-
-import gobblin.configuration.WorkUnitState;
-import gobblin.publisher.DataPublisher;
-import gobblin.publisher.NoopPublisher;
-import gobblin.runtime.JobState;
-import gobblin.runtime.TaskContext;
-import gobblin.source.workunit.WorkUnit;
+package org.apache.gobblin.runtime.task;
+
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.publisher.DataPublisher;
+import org.apache.gobblin.publisher.NoopPublisher;
+import org.apache.gobblin.runtime.JobState;
+import org.apache.gobblin.runtime.TaskContext;
+import org.apache.gobblin.source.workunit.WorkUnit;
 
 /**
  * A task which raise an exception when run

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskFactory.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskFactory.java
index e3bb83c..2166625 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskFactory.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskFactory.java
@@ -15,12 +15,12 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.task;
+package org.apache.gobblin.runtime.task;
 
-import gobblin.publisher.DataPublisher;
-import gobblin.runtime.JobState;
+import org.apache.gobblin.publisher.DataPublisher;
+import org.apache.gobblin.runtime.JobState;
 
-import gobblin.runtime.TaskContext;
+import org.apache.gobblin.runtime.TaskContext;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskIFace.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskIFace.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskIFace.java
index c98c016..ef416da 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskIFace.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskIFace.java
@@ -15,11 +15,11 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.task;
+package org.apache.gobblin.runtime.task;
 
-import gobblin.annotation.Alpha;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.annotation.Alpha;
+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-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskIFaceWrapper.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskIFaceWrapper.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskIFaceWrapper.java
index bb0f4d8..6a93f88 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskIFaceWrapper.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskIFaceWrapper.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.task;
+package org.apache.gobblin.runtime.task;
 
 import java.util.List;
 import java.util.concurrent.CountDownLatch;
@@ -23,13 +23,13 @@ import java.util.concurrent.CountDownLatch;
 import com.google.common.base.Optional;
 import com.google.common.collect.Lists;
 
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.runtime.Task;
-import gobblin.runtime.TaskContext;
-import gobblin.runtime.TaskState;
-import gobblin.runtime.TaskStateTracker;
-import gobblin.runtime.fork.Fork;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.runtime.Task;
+import org.apache.gobblin.runtime.TaskContext;
+import org.apache.gobblin.runtime.TaskState;
+import org.apache.gobblin.runtime.TaskStateTracker;
+import org.apache.gobblin.runtime.fork.Fork;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskUtils.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskUtils.java
index b7e44a1..8df7a0b 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskUtils.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskUtils.java
@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.task;
+package org.apache.gobblin.runtime.task;
 
 import com.google.common.base.Optional;
-import gobblin.configuration.State;
+import org.apache.gobblin.configuration.State;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/HOCONInputStreamJobTemplate.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/HOCONInputStreamJobTemplate.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/HOCONInputStreamJobTemplate.java
index 7a6d2b5..c792d7b 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/HOCONInputStreamJobTemplate.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/HOCONInputStreamJobTemplate.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.template;
+package org.apache.gobblin.runtime.template;
 
 import java.io.InputStream;
 import java.io.InputStreamReader;
@@ -26,10 +26,10 @@ import com.google.common.base.Charsets;
 import com.typesafe.config.Config;
 import com.typesafe.config.ConfigFactory;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.api.GobblinInstanceDriver;
-import gobblin.runtime.api.JobCatalogWithTemplates;
-import gobblin.runtime.api.SpecNotFoundException;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.api.GobblinInstanceDriver;
+import org.apache.gobblin.runtime.api.JobCatalogWithTemplates;
+import org.apache.gobblin.runtime.api.SpecNotFoundException;
 
 import lombok.extern.slf4j.Slf4j;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/InheritingJobTemplate.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/InheritingJobTemplate.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/InheritingJobTemplate.java
index c91bcab..d542ed5 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/InheritingJobTemplate.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/InheritingJobTemplate.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.template;
+package org.apache.gobblin.runtime.template;
 
 import java.net.URI;
 import java.util.Collection;
@@ -30,9 +30,9 @@ import com.google.common.collect.Maps;
 import com.google.common.collect.Sets;
 import com.typesafe.config.Config;
 
-import gobblin.runtime.api.JobCatalogWithTemplates;
-import gobblin.runtime.api.JobTemplate;
-import gobblin.runtime.api.SpecNotFoundException;
+import org.apache.gobblin.runtime.api.JobCatalogWithTemplates;
+import org.apache.gobblin.runtime.api.JobTemplate;
+import org.apache.gobblin.runtime.api.SpecNotFoundException;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/PullFileToConfigConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/PullFileToConfigConverter.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/PullFileToConfigConverter.java
index cc7c38e..5bba8d8 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/PullFileToConfigConverter.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/PullFileToConfigConverter.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.template;
+package org.apache.gobblin.runtime.template;
 
 import java.io.File;
 import java.io.IOException;
@@ -38,13 +38,13 @@ import com.typesafe.config.ConfigFactory;
 import com.typesafe.config.ConfigRenderOptions;
 import com.typesafe.config.ConfigResolveOptions;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.api.JobTemplate;
-import gobblin.runtime.api.SpecNotFoundException;
-import gobblin.runtime.job_catalog.PackagedTemplatesJobCatalogDecorator;
-import gobblin.util.ConfigUtils;
-import gobblin.util.PathUtils;
-import gobblin.util.PullFileLoader;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.api.JobTemplate;
+import org.apache.gobblin.runtime.api.SpecNotFoundException;
+import org.apache.gobblin.runtime.job_catalog.PackagedTemplatesJobCatalogDecorator;
+import org.apache.gobblin.util.ConfigUtils;
+import org.apache.gobblin.util.PathUtils;
+import org.apache.gobblin.util.PullFileLoader;
 
 import lombok.Data;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/ResourceBasedJobTemplate.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/ResourceBasedJobTemplate.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/ResourceBasedJobTemplate.java
index e1bd7c7..5fab14a 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/ResourceBasedJobTemplate.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/ResourceBasedJobTemplate.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.template;
+package org.apache.gobblin.runtime.template;
 
 import java.io.IOException;
 import java.io.InputStream;
@@ -25,9 +25,9 @@ import java.net.URISyntaxException;
 import com.google.common.base.Preconditions;
 import com.google.common.base.Strings;
 
-import gobblin.runtime.api.JobCatalogWithTemplates;
-import gobblin.runtime.api.SpecNotFoundException;
-import gobblin.runtime.job_catalog.PackagedTemplatesJobCatalogDecorator;
+import org.apache.gobblin.runtime.api.JobCatalogWithTemplates;
+import org.apache.gobblin.runtime.api.SpecNotFoundException;
+import org.apache.gobblin.runtime.job_catalog.PackagedTemplatesJobCatalogDecorator;
 
 import lombok.extern.slf4j.Slf4j;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/StaticJobTemplate.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/StaticJobTemplate.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/StaticJobTemplate.java
index 683cbc8..c370c62 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/StaticJobTemplate.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/StaticJobTemplate.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.template;
+package org.apache.gobblin.runtime.template;
 
 import java.net.URI;
 import java.net.URISyntaxException;
@@ -31,12 +31,12 @@ import com.google.common.collect.Sets;
 import com.typesafe.config.Config;
 import com.typesafe.config.ConfigFactory;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.api.GobblinInstanceDriver;
-import gobblin.runtime.api.JobCatalog;
-import gobblin.runtime.api.JobCatalogWithTemplates;
-import gobblin.runtime.api.JobTemplate;
-import gobblin.runtime.api.SpecNotFoundException;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.api.GobblinInstanceDriver;
+import org.apache.gobblin.runtime.api.JobCatalog;
+import org.apache.gobblin.runtime.api.JobCatalogWithTemplates;
+import org.apache.gobblin.runtime.api.JobTemplate;
+import org.apache.gobblin.runtime.api.SpecNotFoundException;
 
 import lombok.Getter;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/ClustersNames.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/ClustersNames.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/ClustersNames.java
index 838a595..8d19028 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/ClustersNames.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/ClustersNames.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.runtime.util;
+package org.apache.gobblin.runtime.util;
 
 /**
  * Allows conversion of URLs identifying a Hadoop cluster (e.g. resource manager url or

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/JobMetrics.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/JobMetrics.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/JobMetrics.java
index 86755a3..102885c 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/JobMetrics.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/JobMetrics.java
@@ -15,20 +15,20 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.util;
+package org.apache.gobblin.runtime.util;
 
 import java.util.List;
 import java.util.concurrent.Callable;
 
 import com.google.common.collect.Lists;
 
-import gobblin.metrics.GobblinMetrics;
-import gobblin.metrics.MetricContext;
-import gobblin.metrics.Tag;
-import gobblin.metrics.event.JobEvent;
-import gobblin.runtime.JobState;
-import gobblin.runtime.TaskState;
-import gobblin.util.ClustersNames;
+import org.apache.gobblin.metrics.GobblinMetrics;
+import org.apache.gobblin.metrics.MetricContext;
+import org.apache.gobblin.metrics.Tag;
+import org.apache.gobblin.metrics.event.JobEvent;
+import org.apache.gobblin.runtime.JobState;
+import org.apache.gobblin.runtime.TaskState;
+import org.apache.gobblin.util.ClustersNames;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/JobStateToJsonConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/JobStateToJsonConverter.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/JobStateToJsonConverter.java
index 765d553..8497350 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/JobStateToJsonConverter.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/JobStateToJsonConverter.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.util;
+package org.apache.gobblin.runtime.util;
 
 import java.io.BufferedWriter;
 import java.io.FileOutputStream;
@@ -42,11 +42,11 @@ import org.slf4j.LoggerFactory;
 import com.google.common.io.Closer;
 import com.google.gson.stream.JsonWriter;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.metastore.StateStore;
-import gobblin.runtime.FsDatasetStateStore;
-import gobblin.runtime.JobState;
-import gobblin.util.JobConfigurationUtils;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.metastore.StateStore;
+import org.apache.gobblin.runtime.FsDatasetStateStore;
+import org.apache.gobblin.runtime.JobState;
+import org.apache.gobblin.util.JobConfigurationUtils;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/MetricGroup.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/MetricGroup.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/MetricGroup.java
index 6551a37..8fa817d 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/MetricGroup.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/MetricGroup.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.util;
+package org.apache.gobblin.runtime.util;
 
 /**
  * Enumeration of metric groups used internally.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/MultiWorkUnitUnpackingIterator.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/MultiWorkUnitUnpackingIterator.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/MultiWorkUnitUnpackingIterator.java
index d43b770..38e4ce7 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/MultiWorkUnitUnpackingIterator.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/MultiWorkUnitUnpackingIterator.java
@@ -15,12 +15,12 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.util;
+package org.apache.gobblin.runtime.util;
 
 import java.util.Iterator;
 
-import gobblin.source.workunit.MultiWorkUnit;
-import gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.source.workunit.MultiWorkUnit;
+import org.apache.gobblin.source.workunit.WorkUnit;
 
 import lombok.RequiredArgsConstructor;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/RuntimeConstructs.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/RuntimeConstructs.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/RuntimeConstructs.java
index 17c8d8c..5060bac 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/RuntimeConstructs.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/RuntimeConstructs.java
@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.util;
+package org.apache.gobblin.runtime.util;
 
-import gobblin.runtime.fork.Fork;
+import org.apache.gobblin.runtime.fork.Fork;
 
 
 public enum RuntimeConstructs {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/StateStores.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/StateStores.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/StateStores.java
index 6a4cf98..311a76a 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/StateStores.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/StateStores.java
@@ -14,17 +14,17 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.runtime.util;
+package org.apache.gobblin.runtime.util;
 
 import com.typesafe.config.Config;
 import com.typesafe.config.ConfigValueFactory;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.metastore.StateStore;
-import gobblin.runtime.TaskState;
-import gobblin.source.workunit.MultiWorkUnit;
-import gobblin.source.workunit.WorkUnit;
-import gobblin.util.ClassAliasResolver;
-import gobblin.util.ConfigUtils;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.metastore.StateStore;
+import org.apache.gobblin.runtime.TaskState;
+import org.apache.gobblin.source.workunit.MultiWorkUnit;
+import org.apache.gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.util.ClassAliasResolver;
+import org.apache.gobblin.util.ConfigUtils;
 import org.apache.hadoop.fs.Path;
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/TaskMetrics.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/TaskMetrics.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/TaskMetrics.java
index 60f8227..982b381 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/TaskMetrics.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/TaskMetrics.java
@@ -15,19 +15,19 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.util;
+package org.apache.gobblin.runtime.util;
 
 import java.util.List;
 import java.util.concurrent.Callable;
 
 import com.google.common.collect.Lists;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.metrics.GobblinMetrics;
-import gobblin.metrics.MetricContext;
-import gobblin.metrics.Tag;
-import gobblin.metrics.event.TaskEvent;
-import gobblin.runtime.TaskState;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.metrics.GobblinMetrics;
+import org.apache.gobblin.metrics.MetricContext;
+import org.apache.gobblin.metrics.Tag;
+import org.apache.gobblin.metrics.event.TaskEvent;
+import org.apache.gobblin.runtime.TaskState;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/BaseGobblinJob.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/BaseGobblinJob.java b/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/BaseGobblinJob.java
index 54f468d..83b17c0 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/BaseGobblinJob.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/BaseGobblinJob.java
@@ -9,7 +9,7 @@
  * under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
  * CONDITIONS OF ANY KIND, either express or implied.
  */
-package gobblin.scheduler;
+package org.apache.gobblin.scheduler;
 
 import org.quartz.*;
 import org.slf4j.MDC;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/JobScheduler.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/JobScheduler.java b/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/JobScheduler.java
index 2736637..0772d60 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/JobScheduler.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/JobScheduler.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.scheduler;
+package org.apache.gobblin.scheduler;
 
 import java.io.Closeable;
 import java.io.IOException;
@@ -61,16 +61,16 @@ import com.google.common.util.concurrent.AbstractIdleService;
 
 import lombok.extern.slf4j.Slf4j;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.JobException;
-import gobblin.runtime.JobLauncher;
-import gobblin.runtime.JobLauncherFactory;
-import gobblin.runtime.listeners.EmailNotificationJobListener;
-import gobblin.runtime.listeners.JobListener;
-import gobblin.runtime.listeners.RunOnceJobListener;
-import gobblin.util.ExecutorsUtils;
-import gobblin.util.SchedulerUtils;
-import gobblin.util.filesystem.PathAlterationObserverScheduler;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.JobException;
+import org.apache.gobblin.runtime.JobLauncher;
+import org.apache.gobblin.runtime.JobLauncherFactory;
+import org.apache.gobblin.runtime.listeners.EmailNotificationJobListener;
+import org.apache.gobblin.runtime.listeners.JobListener;
+import org.apache.gobblin.runtime.listeners.RunOnceJobListener;
+import org.apache.gobblin.util.ExecutorsUtils;
+import org.apache.gobblin.util.SchedulerUtils;
+import org.apache.gobblin.util.filesystem.PathAlterationObserverScheduler;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/PathAlterationListenerAdaptorForMonitor.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/PathAlterationListenerAdaptorForMonitor.java b/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/PathAlterationListenerAdaptorForMonitor.java
index d2124e9..0b705e0 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/PathAlterationListenerAdaptorForMonitor.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/PathAlterationListenerAdaptorForMonitor.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.scheduler;
+package org.apache.gobblin.scheduler;
 
 import java.io.IOException;
 import java.util.Map;
@@ -30,13 +30,13 @@ import org.slf4j.LoggerFactory;
 
 import com.google.common.collect.Maps;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.JobException;
-import gobblin.runtime.listeners.EmailNotificationJobListener;
-import gobblin.runtime.listeners.RunOnceJobListener;
-import gobblin.util.PathUtils;
-import gobblin.util.SchedulerUtils;
-import gobblin.util.filesystem.PathAlterationListenerAdaptor;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.JobException;
+import org.apache.gobblin.runtime.listeners.EmailNotificationJobListener;
+import org.apache.gobblin.runtime.listeners.RunOnceJobListener;
+import org.apache.gobblin.util.PathUtils;
+import org.apache.gobblin.util.SchedulerUtils;
+import org.apache.gobblin.util.filesystem.PathAlterationListenerAdaptor;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/SchedulerDaemon.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/SchedulerDaemon.java b/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/SchedulerDaemon.java
index 93dc891..83b2852 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/SchedulerDaemon.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/SchedulerDaemon.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.scheduler;
+package org.apache.gobblin.scheduler;
 
 import java.util.Properties;
 import java.util.UUID;
@@ -25,8 +25,8 @@ import org.apache.commons.configuration.PropertiesConfiguration;
 
 import lombok.extern.slf4j.Slf4j;
 
-import gobblin.runtime.app.ServiceBasedAppLauncher;
-import gobblin.util.PropertiesUtils;
+import org.apache.gobblin.runtime.app.ServiceBasedAppLauncher;
+import org.apache.gobblin.util.PropertiesUtils;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/SchedulerService.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/SchedulerService.java b/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/SchedulerService.java
index ac42e8c..2d0136f 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/SchedulerService.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/SchedulerService.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.scheduler;
+package org.apache.gobblin.scheduler;
 
 import java.util.Properties;
 
@@ -27,9 +27,9 @@ import com.google.common.base.Optional;
 import com.google.common.util.concurrent.AbstractIdleService;
 import com.typesafe.config.Config;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.util.ConfigUtils;
-import gobblin.util.PropertiesUtils;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.util.ConfigUtils;
+import org.apache.gobblin.util.PropertiesUtils;
 
 import lombok.Getter;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/FlowStatus.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/FlowStatus.java b/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/FlowStatus.java
index ae73a73..e9d4d97 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/FlowStatus.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/FlowStatus.java
@@ -15,11 +15,11 @@
  * limitations under the License.
  */
 
-package gobblin.service.monitoring;
+package org.apache.gobblin.service.monitoring;
 
 import java.util.Iterator;
 
-import gobblin.annotation.Alpha;
+import org.apache.gobblin.annotation.Alpha;
 
 import lombok.AllArgsConstructor;
 import lombok.Getter;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/FlowStatusGenerator.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/FlowStatusGenerator.java b/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/FlowStatusGenerator.java
index 547cee7..5657e42 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/FlowStatusGenerator.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/FlowStatusGenerator.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.service.monitoring;
+package org.apache.gobblin.service.monitoring;
 
 import java.util.Iterator;
 import java.util.List;
@@ -24,7 +24,7 @@ import org.apache.commons.lang.StringUtils;
 
 import com.google.common.collect.Lists;
 
-import gobblin.annotation.Alpha;
+import org.apache.gobblin.annotation.Alpha;
 
 import lombok.Builder;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/JobStatus.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/JobStatus.java b/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/JobStatus.java
index a39de8e..87e52c6 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/JobStatus.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/JobStatus.java
@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package gobblin.service.monitoring;
+package org.apache.gobblin.service.monitoring;
 
-import gobblin.annotation.Alpha;
+import org.apache.gobblin.annotation.Alpha;
 
 import lombok.Builder;
 import lombok.Getter;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/JobStatusRetriever.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/JobStatusRetriever.java b/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/JobStatusRetriever.java
index c6df8c4..fe60c4e 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/JobStatusRetriever.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/JobStatusRetriever.java
@@ -15,13 +15,13 @@
  * limitations under the License.
  */
 
-package gobblin.service.monitoring;
+package org.apache.gobblin.service.monitoring;
 
 import java.util.Iterator;
 
 import com.google.common.collect.Iterators;
 
-import gobblin.annotation.Alpha;
+import org.apache.gobblin.annotation.Alpha;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/LatestFlowExecutionIdTracker.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/LatestFlowExecutionIdTracker.java b/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/LatestFlowExecutionIdTracker.java
index e421b40..39ab0ed 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/LatestFlowExecutionIdTracker.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/LatestFlowExecutionIdTracker.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.service.monitoring;
+package org.apache.gobblin.service.monitoring;
 
 /**
  * Tracks the latest flow execution Id.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/util/SchedulerUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/util/SchedulerUtils.java b/gobblin-runtime/src/main/java/org/apache/gobblin/util/SchedulerUtils.java
index 1cb51ce..5406e0f 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/util/SchedulerUtils.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/util/SchedulerUtils.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util;
+package org.apache.gobblin.util;
 
 import java.io.IOException;
 import java.net.URISyntaxException;
@@ -37,14 +37,14 @@ import com.google.common.collect.Iterables;
 import com.google.common.collect.Lists;
 import com.typesafe.config.Config;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.api.JobTemplate;
-import gobblin.runtime.api.SpecNotFoundException;
-import gobblin.runtime.job_catalog.PackagedTemplatesJobCatalogDecorator;
-import gobblin.runtime.template.ResourceBasedJobTemplate;
-import gobblin.util.filesystem.PathAlterationObserverScheduler;
-import gobblin.util.filesystem.PathAlterationListener;
-import gobblin.util.filesystem.PathAlterationObserver;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.api.JobTemplate;
+import org.apache.gobblin.runtime.api.SpecNotFoundException;
+import org.apache.gobblin.runtime.job_catalog.PackagedTemplatesJobCatalogDecorator;
+import org.apache.gobblin.runtime.template.ResourceBasedJobTemplate;
+import org.apache.gobblin.util.filesystem.PathAlterationObserverScheduler;
+import org.apache.gobblin.util.filesystem.PathAlterationListener;
+import org.apache.gobblin.util.filesystem.PathAlterationObserver;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/performance/PerformanceTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/performance/PerformanceTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/performance/PerformanceTest.java
index c0a5a99..2c61236 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/performance/PerformanceTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/performance/PerformanceTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.performance;
+package org.apache.gobblin.performance;
 
 import java.util.List;
 import java.util.concurrent.TimeUnit;
@@ -26,10 +26,10 @@ import com.google.common.collect.Lists;
 import com.google.common.eventbus.EventBus;
 import com.google.common.eventbus.Subscribe;
 
-import gobblin.runtime.embedded.EmbeddedGobblin;
-import gobblin.util.test.FastSequentialSource;
-import gobblin.writer.test.GobblinTestEventBusWriter;
-import gobblin.writer.test.TestingEventBuses;
+import org.apache.gobblin.runtime.embedded.EmbeddedGobblin;
+import org.apache.gobblin.util.test.FastSequentialSource;
+import org.apache.gobblin.writer.test.GobblinTestEventBusWriter;
+import org.apache.gobblin.writer.test.TestingEventBuses;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/BoundedBlockingRecordQueueTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/BoundedBlockingRecordQueueTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/BoundedBlockingRecordQueueTest.java
index 741696b..93eb721 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/BoundedBlockingRecordQueueTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/BoundedBlockingRecordQueueTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime;
+package org.apache.gobblin.runtime;
 
 import java.util.List;
 import java.util.Map;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/CountUpAndDownLatchTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/CountUpAndDownLatchTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/CountUpAndDownLatchTest.java
index 36ada03..5bad68d 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/CountUpAndDownLatchTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/CountUpAndDownLatchTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime;
+package org.apache.gobblin.runtime;
 
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.ExecutorService;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/DatasetStateStoreTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/DatasetStateStoreTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/DatasetStateStoreTest.java
index 342daf4..1cc0bab 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/DatasetStateStoreTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/DatasetStateStoreTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime;
+package org.apache.gobblin.runtime;
 
 import java.io.FileReader;
 import java.io.IOException;
@@ -30,20 +30,20 @@ import org.testng.annotations.Test;
 import com.google.common.collect.Iterables;
 import com.google.common.collect.Lists;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.SourceState;
-import gobblin.configuration.WorkUnitState;
-import gobblin.metastore.FsStateStore;
-import gobblin.metastore.StateStore;
-import gobblin.runtime.local.LocalJobLauncher;
-import gobblin.source.Source;
-import gobblin.source.extractor.DataRecordException;
-import gobblin.source.extractor.Extractor;
-import gobblin.source.extractor.extract.AbstractSource;
-import gobblin.source.workunit.Extract;
-import gobblin.source.workunit.WorkUnit;
-import gobblin.writer.DataWriter;
-import gobblin.writer.DataWriterBuilder;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.SourceState;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.metastore.FsStateStore;
+import org.apache.gobblin.metastore.StateStore;
+import org.apache.gobblin.runtime.local.LocalJobLauncher;
+import org.apache.gobblin.source.Source;
+import org.apache.gobblin.source.extractor.DataRecordException;
+import org.apache.gobblin.source.extractor.Extractor;
+import org.apache.gobblin.source.extractor.extract.AbstractSource;
+import org.apache.gobblin.source.workunit.Extract;
+import org.apache.gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.writer.DataWriter;
+import org.apache.gobblin.writer.DataWriterBuilder;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/DummyJobContext.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/DummyJobContext.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/DummyJobContext.java
index ae7e775..d3374fa 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/DummyJobContext.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/DummyJobContext.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime;
+package org.apache.gobblin.runtime;
 
 import com.typesafe.config.Config;
 
@@ -31,12 +31,12 @@ import org.slf4j.Logger;
 import com.google.common.base.Optional;
 import com.typesafe.config.ConfigFactory;
 
-import gobblin.broker.gobblin_scopes.GobblinScopeTypes;
-import gobblin.broker.SharedResourcesBrokerFactory;
-import gobblin.commit.CommitSequenceStore;
-import gobblin.commit.DeliverySemantics;
-import gobblin.metastore.JobHistoryStore;
-import gobblin.source.Source;
+import org.apache.gobblin.broker.gobblin_scopes.GobblinScopeTypes;
+import org.apache.gobblin.broker.SharedResourcesBrokerFactory;
+import org.apache.gobblin.commit.CommitSequenceStore;
+import org.apache.gobblin.commit.DeliverySemantics;
+import org.apache.gobblin.metastore.JobHistoryStore;
+import org.apache.gobblin.source.Source;
 
 
 public class DummyJobContext extends JobContext {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/FsDatasetStateStoreTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/FsDatasetStateStoreTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/FsDatasetStateStoreTest.java
index f899070..8aa9ca8 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/FsDatasetStateStoreTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/FsDatasetStateStoreTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime;
+package org.apache.gobblin.runtime;
 
 import java.io.IOException;
 import java.util.Map;
@@ -28,10 +28,10 @@ import org.testng.annotations.AfterClass;
 import org.testng.annotations.BeforeClass;
 import org.testng.annotations.Test;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.metastore.FsStateStore;
-import gobblin.metastore.StateStore;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.metastore.FsStateStore;
+import org.apache.gobblin.metastore.StateStore;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobBrokerInjectionTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobBrokerInjectionTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobBrokerInjectionTest.java
index 9a2e8e4..04ce82d 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobBrokerInjectionTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobBrokerInjectionTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime;
+package org.apache.gobblin.runtime;
 
 import java.util.Queue;
 import java.util.Random;
@@ -31,33 +31,33 @@ import org.testng.annotations.Test;
 import com.google.common.collect.Sets;
 import com.typesafe.config.ConfigFactory;
 
-import gobblin.broker.gobblin_scopes.GobblinScopeTypes;
-import gobblin.broker.iface.ConfigView;
-import gobblin.broker.iface.NoSuchScopeException;
-import gobblin.broker.iface.NotConfiguredException;
-import gobblin.broker.iface.ScopedConfigView;
-import gobblin.broker.iface.SharedResourceFactory;
-import gobblin.broker.iface.SharedResourceKey;
-import gobblin.broker.iface.SharedResourcesBroker;
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.Converter;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.SchemaConversionException;
-import gobblin.converter.SingleRecordIterable;
-import gobblin.runtime.api.GobblinInstanceDriver;
-import gobblin.runtime.api.JobExecutionDriver;
-import gobblin.runtime.api.JobExecutionResult;
-import gobblin.runtime.api.JobLifecycleListener;
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.instance.StandardGobblinInstanceDriver;
-import gobblin.runtime.instance.StandardGobblinInstanceLauncher;
-import gobblin.runtime.std.DefaultJobLifecycleListenerImpl;
-import gobblin.runtime.std.FilteredJobLifecycleListener;
-import gobblin.runtime.std.JobSpecFilter;
-import gobblin.writer.test.GobblinTestEventBusWriter;
-import gobblin.writer.test.TestingEventBusAsserter;
-import gobblin.writer.test.TestingEventBuses;
-import gobblin.broker.ResourceInstance;
+import org.apache.gobblin.broker.gobblin_scopes.GobblinScopeTypes;
+import org.apache.gobblin.broker.iface.ConfigView;
+import org.apache.gobblin.broker.iface.NoSuchScopeException;
+import org.apache.gobblin.broker.iface.NotConfiguredException;
+import org.apache.gobblin.broker.iface.ScopedConfigView;
+import org.apache.gobblin.broker.iface.SharedResourceFactory;
+import org.apache.gobblin.broker.iface.SharedResourceKey;
+import org.apache.gobblin.broker.iface.SharedResourcesBroker;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.Converter;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.converter.SingleRecordIterable;
+import org.apache.gobblin.runtime.api.GobblinInstanceDriver;
+import org.apache.gobblin.runtime.api.JobExecutionDriver;
+import org.apache.gobblin.runtime.api.JobExecutionResult;
+import org.apache.gobblin.runtime.api.JobLifecycleListener;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.instance.StandardGobblinInstanceDriver;
+import org.apache.gobblin.runtime.instance.StandardGobblinInstanceLauncher;
+import org.apache.gobblin.runtime.std.DefaultJobLifecycleListenerImpl;
+import org.apache.gobblin.runtime.std.FilteredJobLifecycleListener;
+import org.apache.gobblin.runtime.std.JobSpecFilter;
+import org.apache.gobblin.writer.test.GobblinTestEventBusWriter;
+import org.apache.gobblin.writer.test.TestingEventBusAsserter;
+import org.apache.gobblin.writer.test.TestingEventBuses;
+import org.apache.gobblin.broker.ResourceInstance;
 
 import lombok.Data;
 import lombok.EqualsAndHashCode;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobContextTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobContextTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobContextTest.java
index 2c2d50d..d3dba5b 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobContextTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobContextTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime;
+package org.apache.gobblin.runtime;
 
 import java.io.IOException;
 import java.util.Map;
@@ -38,9 +38,9 @@ import com.google.common.collect.Lists;
 import com.google.common.collect.Maps;
 import com.google.common.collect.Queues;
 
-import gobblin.commit.DeliverySemantics;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.util.Either;
+import org.apache.gobblin.commit.DeliverySemantics;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.util.Either;
 
 import javax.annotation.Nullable;
 import lombok.extern.slf4j.Slf4j;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobExecutionEventSubmitterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobExecutionEventSubmitterTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobExecutionEventSubmitterTest.java
index eff6b01..a88e3a1 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobExecutionEventSubmitterTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobExecutionEventSubmitterTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime;
+package org.apache.gobblin.runtime;
 
 import static org.mockito.Mockito.any;
 import static org.mockito.Mockito.atLeastOnce;
@@ -33,9 +33,9 @@ import org.mockito.Mockito;
 import org.testng.annotations.BeforeClass;
 import org.testng.annotations.Test;
 
-import gobblin.configuration.WorkUnitState;
-import gobblin.metrics.event.EventSubmitter;
-import gobblin.rest.LauncherTypeEnum;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.metrics.event.EventSubmitter;
+import org.apache.gobblin.rest.LauncherTypeEnum;
 
 
 @Test(groups = {"gobblin.runtime"})

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobLauncherTestHelper.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobLauncherTestHelper.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobLauncherTestHelper.java
index 2bebd1d..068d357 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobLauncherTestHelper.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobLauncherTestHelper.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime;
+package org.apache.gobblin.runtime;
 
 import java.io.IOException;
 import java.util.List;
@@ -29,17 +29,17 @@ import org.testng.Assert;
 
 import com.google.common.io.Closer;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.SourceState;
-import gobblin.configuration.WorkUnitState;
-import gobblin.metastore.StateStore;
-import gobblin.runtime.JobState.DatasetState;
-import gobblin.source.extractor.Extractor;
-import gobblin.source.workunit.WorkUnit;
-import gobblin.test.TestExtractor;
-import gobblin.test.TestSource;
-import gobblin.util.ClusterNameTags;
-import gobblin.util.JobLauncherUtils;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.SourceState;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.metastore.StateStore;
+import org.apache.gobblin.runtime.JobState.DatasetState;
+import org.apache.gobblin.source.extractor.Extractor;
+import org.apache.gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.test.TestExtractor;
+import org.apache.gobblin.test.TestSource;
+import org.apache.gobblin.util.ClusterNameTags;
+import org.apache.gobblin.util.JobLauncherUtils;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobListenersTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobListenersTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobListenersTest.java
index bd9066d..264fa10 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobListenersTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobListenersTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime;
+package org.apache.gobblin.runtime;
 
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.times;
@@ -24,9 +24,9 @@ import static org.mockito.Mockito.verify;
 import com.google.common.collect.Lists;
 import org.testng.annotations.Test;
 
-import gobblin.runtime.listeners.CloseableJobListener;
-import gobblin.runtime.listeners.JobListener;
-import gobblin.runtime.listeners.JobListeners;
+import org.apache.gobblin.runtime.listeners.CloseableJobListener;
+import org.apache.gobblin.runtime.listeners.JobListener;
+import org.apache.gobblin.runtime.listeners.JobListeners;
 
 
 @Test(groups = {"gobblin.runtime"})

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobStateTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobStateTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobStateTest.java
index bd26825..8bcca84 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobStateTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobStateTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime;
+package org.apache.gobblin.runtime;
 
 import java.io.ByteArrayInputStream;
 import java.io.ByteArrayOutputStream;
@@ -36,11 +36,11 @@ import com.google.common.collect.Lists;
 import com.google.common.collect.Sets;
 import com.google.common.io.Closer;
 
-import gobblin.rest.JobExecutionInfo;
-import gobblin.rest.TaskExecutionInfo;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.rest.JobExecutionInfo;
+import org.apache.gobblin.rest.TaskExecutionInfo;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.workunit.WorkUnit;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/LimiterStopEventTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/LimiterStopEventTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/LimiterStopEventTest.java
index 0a9e8f1..68484fe 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/LimiterStopEventTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/LimiterStopEventTest.java
@@ -1,13 +1,13 @@
-package gobblin.runtime;
+package org.apache.gobblin.runtime;
 
 import com.google.common.base.Joiner;
 import com.google.common.base.Optional;
 import com.google.common.collect.ImmutableMap;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.source.extractor.limiter.LimiterConfigurationKeys;
-import gobblin.util.limiter.Limiter;
-import gobblin.source.extractor.Extractor;
-import gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.source.extractor.limiter.LimiterConfigurationKeys;
+import org.apache.gobblin.util.limiter.Limiter;
+import org.apache.gobblin.source.extractor.Extractor;
+import org.apache.gobblin.source.workunit.WorkUnit;
 import junit.framework.Assert;
 import org.mockito.Mockito;
 import org.testng.annotations.Test;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/MultiConverterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/MultiConverterTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/MultiConverterTest.java
index b8e9d51..397a133 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/MultiConverterTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/MultiConverterTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime;
+package org.apache.gobblin.runtime;
 
 import java.util.List;
 
@@ -30,13 +30,13 @@ import com.google.gson.Gson;
 import com.google.gson.JsonElement;
 import com.google.gson.JsonObject;
 
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.Converter;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.EmptyIterable;
-import gobblin.converter.SchemaConversionException;
-import gobblin.converter.SingleRecordIterable;
-import gobblin.test.TestConverter;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.Converter;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.EmptyIterable;
+import org.apache.gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.converter.SingleRecordIterable;
+import org.apache.gobblin.test.TestConverter;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/MysqlDatasetStateStoreTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/MysqlDatasetStateStoreTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/MysqlDatasetStateStoreTest.java
index 2709f7d..9c35610 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/MysqlDatasetStateStoreTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/MysqlDatasetStateStoreTest.java
@@ -15,17 +15,17 @@
  * limitations under the License.
  */
 
-package gobblin.runtime;
-
-import gobblin.config.ConfigBuilder;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.metastore.DatasetStateStore;
-import gobblin.metastore.MysqlStateStore;
-import gobblin.metastore.StateStore;
-import gobblin.metastore.testing.ITestMetastoreDatabase;
-import gobblin.metastore.testing.TestMetastoreDatabaseFactory;
-import gobblin.util.ClassAliasResolver;
+package org.apache.gobblin.runtime;
+
+import org.apache.gobblin.config.ConfigBuilder;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.metastore.DatasetStateStore;
+import org.apache.gobblin.metastore.MysqlStateStore;
+import org.apache.gobblin.metastore.StateStore;
+import org.apache.gobblin.metastore.testing.ITestMetastoreDatabase;
+import org.apache.gobblin.metastore.testing.TestMetastoreDatabaseFactory;
+import org.apache.gobblin.util.ClassAliasResolver;
 import java.io.IOException;
 import java.util.Map;
 import org.apache.commons.dbcp.BasicDataSource;


Mime
View raw message