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:27 UTC
[09/77] [abbrv] incubator-gobblin git commit: Updated package names,
imports and shell scripts
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/GobblinInstanceDriver.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/GobblinInstanceDriver.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/GobblinInstanceDriver.java
index 05b0eea..f210b5f 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/GobblinInstanceDriver.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/GobblinInstanceDriver.java
@@ -14,16 +14,16 @@
* 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.util.concurrent.Executor;
import com.codahale.metrics.Gauge;
import com.google.common.util.concurrent.Service;
-import gobblin.annotation.Alpha;
-import gobblin.metrics.ContextAwareCounter;
-import gobblin.metrics.ContextAwareGauge;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.metrics.ContextAwareCounter;
+import org.apache.gobblin.metrics.ContextAwareGauge;
import lombok.Getter;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/GobblinInstanceEnvironment.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/GobblinInstanceEnvironment.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/GobblinInstanceEnvironment.java
index c4b938d..71f328f 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/GobblinInstanceEnvironment.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/GobblinInstanceEnvironment.java
@@ -14,13 +14,13 @@
* 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 org.slf4j.Logger;
-import gobblin.broker.gobblin_scopes.GobblinScopeTypes;
-import gobblin.broker.iface.SharedResourcesBroker;
-import gobblin.instrumented.Instrumentable;
+import org.apache.gobblin.broker.gobblin_scopes.GobblinScopeTypes;
+import org.apache.gobblin.broker.iface.SharedResourcesBroker;
+import org.apache.gobblin.instrumented.Instrumentable;
/**
* Defines Gobblin a set of standard configuration features for a gobblin instance. Passing an
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/GobblinInstanceLauncher.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/GobblinInstanceLauncher.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/GobblinInstanceLauncher.java
index dea121f..4887810 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/GobblinInstanceLauncher.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/GobblinInstanceLauncher.java
@@ -14,13 +14,13 @@
* 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 com.google.common.util.concurrent.Service;
import com.typesafe.config.Config;
import com.typesafe.config.ConfigFactory;
-import gobblin.annotation.Alpha;
+import org.apache.gobblin.annotation.Alpha;
import lombok.Getter;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/GobblinInstancePlugin.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/GobblinInstancePlugin.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/GobblinInstancePlugin.java
index 3fb721e..2a94d96 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/GobblinInstancePlugin.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/GobblinInstancePlugin.java
@@ -14,7 +14,7 @@
* 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 com.google.common.util.concurrent.Service;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/GobblinInstancePluginFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/GobblinInstancePluginFactory.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/GobblinInstancePluginFactory.java
index b009c2c..eb7bdda 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/GobblinInstancePluginFactory.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/GobblinInstancePluginFactory.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.runtime.api;
+package org.apache.gobblin.runtime.api;
/**
* Creates a {@link GobblinInstancePlugin} for a specific {@link GobblinInstanceDriver} .
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobCatalog.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobCatalog.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobCatalog.java
index 82bd26e..e0264d9 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobCatalog.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobCatalog.java
@@ -14,7 +14,7 @@
* 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.Collection;
@@ -23,12 +23,12 @@ import com.codahale.metrics.Gauge;
import com.google.common.collect.ImmutableMap;
import com.google.common.util.concurrent.Service;
-import gobblin.annotation.Alpha;
-import gobblin.instrumented.GobblinMetricsKeys;
-import gobblin.instrumented.Instrumentable;
-import gobblin.metrics.ContextAwareCounter;
-import gobblin.metrics.ContextAwareGauge;
-import gobblin.metrics.GobblinTrackingEvent;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.instrumented.GobblinMetricsKeys;
+import org.apache.gobblin.instrumented.Instrumentable;
+import org.apache.gobblin.metrics.ContextAwareCounter;
+import org.apache.gobblin.metrics.ContextAwareGauge;
+import org.apache.gobblin.metrics.GobblinTrackingEvent;
import lombok.Getter;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobCatalogListener.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobCatalogListener.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobCatalogListener.java
index aa05312..c670573 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobCatalogListener.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobCatalogListener.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 com.google.common.base.Objects;
-import gobblin.annotation.Alpha;
-import gobblin.util.callbacks.Callback;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.util.callbacks.Callback;
/**
* A listener for changes to the {@link JobSpec}s of a {@link JobCatalog}.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobCatalogListenersContainer.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobCatalogListenersContainer.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobCatalogListenersContainer.java
index 3d548f7..66c5fc7 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobCatalogListenersContainer.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobCatalogListenersContainer.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.runtime.api;
+package org.apache.gobblin.runtime.api;
/**
* Manages a collection of {@link JobCatalogListener}s .
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobCatalogWithTemplates.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobCatalogWithTemplates.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobCatalogWithTemplates.java
index d4e5cf6..623071a 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobCatalogWithTemplates.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobCatalogWithTemplates.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.api;
+package org.apache.gobblin.runtime.api;
import java.net.URI;
import java.util.Collection;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecution.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecution.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecution.java
index 98aa1fb..22c2fbc 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecution.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecution.java
@@ -14,11 +14,11 @@
* 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 gobblin.annotation.Alpha;
+import org.apache.gobblin.annotation.Alpha;
/**
* Identifies a specific execution of a {@link JobSpec}
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionDriver.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionDriver.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionDriver.java
index 6528311..09962be 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionDriver.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionDriver.java
@@ -14,7 +14,7 @@
* 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.util.concurrent.ExecutionException;
import java.util.concurrent.Future;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionLauncher.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionLauncher.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionLauncher.java
index 4dc6725..0e9e114 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionLauncher.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionLauncher.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 com.codahale.metrics.Gauge;
-import gobblin.annotation.Alpha;
-import gobblin.instrumented.Instrumentable;
-import gobblin.metrics.ContextAwareCounter;
-import gobblin.metrics.ContextAwareGauge;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.instrumented.Instrumentable;
+import org.apache.gobblin.metrics.ContextAwareCounter;
+import org.apache.gobblin.metrics.ContextAwareGauge;
import lombok.Getter;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionResult.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionResult.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionResult.java
index 558bd1b..66493a6 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionResult.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionResult.java
@@ -14,11 +14,11 @@
* 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 com.google.common.base.Preconditions;
-import gobblin.runtime.JobState.RunningState;
+import org.apache.gobblin.runtime.JobState.RunningState;
import lombok.AccessLevel;
import lombok.AllArgsConstructor;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionState.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionState.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionState.java
index 9e8fe7e..03f2d4e 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionState.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionState.java
@@ -14,7 +14,7 @@
* 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.util.Collections;
import java.util.HashMap;
@@ -33,9 +33,9 @@ import com.google.common.base.Predicate;
import com.google.common.collect.ImmutableMap;
import com.google.common.collect.ImmutableSet;
-import gobblin.annotation.Alpha;
-import gobblin.runtime.JobState;
-import gobblin.runtime.JobState.RunningState;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.runtime.JobState;
+import org.apache.gobblin.runtime.JobState.RunningState;
import javax.annotation.Nonnull;
import lombok.Getter;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionStateListener.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionStateListener.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionStateListener.java
index f2e988b..5147db0 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionStateListener.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionStateListener.java
@@ -14,13 +14,13 @@
* 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 com.google.common.base.Objects;
-import gobblin.runtime.JobState;
-import gobblin.runtime.JobState.RunningState;
-import gobblin.util.callbacks.Callback;
+import org.apache.gobblin.runtime.JobState;
+import org.apache.gobblin.runtime.JobState.RunningState;
+import org.apache.gobblin.util.callbacks.Callback;
/**
* Notification for changes in the execution state
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionStateListenerContainer.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionStateListenerContainer.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionStateListenerContainer.java
index a60d1ee..00fb404 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionStateListenerContainer.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionStateListenerContainer.java
@@ -14,9 +14,9 @@
* 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 gobblin.annotation.Alpha;
+import org.apache.gobblin.annotation.Alpha;
/**
* Defines an interface for managing a collection of {@JobExecutionStateListener}s
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionStatus.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionStatus.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionStatus.java
index 83ee931..9b96e7f 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionStatus.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionStatus.java
@@ -14,9 +14,9 @@
* 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 gobblin.runtime.JobState;
+import org.apache.gobblin.runtime.JobState;
public interface JobExecutionStatus {
public static final String UKNOWN_STAGE = "unkown";
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobLifecycleListener.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobLifecycleListener.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobLifecycleListener.java
index 666b1e3..0ff70db 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobLifecycleListener.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobLifecycleListener.java
@@ -14,13 +14,13 @@
* 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 com.google.common.base.Objects;
import com.google.common.base.Preconditions;
-import gobblin.annotation.Alpha;
-import gobblin.util.callbacks.Callback;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.util.callbacks.Callback;
/**
* A listener that can track the full lifecycle of a job: from the registering of the jobspec to
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobLifecycleListenersContainer.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobLifecycleListenersContainer.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobLifecycleListenersContainer.java
index 3745b57..5f549dd 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobLifecycleListenersContainer.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobLifecycleListenersContainer.java
@@ -14,7 +14,7 @@
* 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.util.List;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpec.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpec.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpec.java
index feba14d..5c1158f 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpec.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpec.java
@@ -14,7 +14,7 @@
* 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.io.IOException;
import java.net.URI;
@@ -27,10 +27,10 @@ import com.google.common.base.Preconditions;
import com.typesafe.config.Config;
import com.typesafe.config.ConfigFactory;
-import gobblin.annotation.Alpha;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.JobState;
-import gobblin.util.ConfigUtils;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.JobState;
+import org.apache.gobblin.util.ConfigUtils;
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/api/JobSpecMonitor.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpecMonitor.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpecMonitor.java
index 2502676..8d67df1 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpecMonitor.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpecMonitor.java
@@ -14,7 +14,7 @@
* 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 com.google.common.util.concurrent.Service;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpecMonitorFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpecMonitorFactory.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpecMonitorFactory.java
index c6864fc..32b3aa4 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpecMonitorFactory.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpecMonitorFactory.java
@@ -14,7 +14,7 @@
* 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.io.IOException;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpecNotFoundException.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpecNotFoundException.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpecNotFoundException.java
index 77e4355..188484d 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpecNotFoundException.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpecNotFoundException.java
@@ -14,7 +14,7 @@
* 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;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpecSchedule.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpecSchedule.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpecSchedule.java
index bff6d62..cac8e5f 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpecSchedule.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpecSchedule.java
@@ -14,7 +14,7 @@
* 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 com.google.common.base.Optional;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpecScheduler.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpecScheduler.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpecScheduler.java
index a498b3c..98d08a8 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpecScheduler.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpecScheduler.java
@@ -14,12 +14,12 @@
* 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.Map;
-import gobblin.annotation.Alpha;
+import org.apache.gobblin.annotation.Alpha;
/**
* Early alpha of the scheduler interface which is responsible of deciding when to run next the
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpecSchedulerListener.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpecSchedulerListener.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpecSchedulerListener.java
index 9253a7b..719adf6 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpecSchedulerListener.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpecSchedulerListener.java
@@ -14,11 +14,11 @@
* 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 com.google.common.base.Objects;
-import gobblin.util.callbacks.Callback;
+import org.apache.gobblin.util.callbacks.Callback;
/**
* {@link JobSpecScheduler} callbacks.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpecSchedulerListenersContainer.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpecSchedulerListenersContainer.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpecSchedulerListenersContainer.java
index 198fa69..02a8a77 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpecSchedulerListenersContainer.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpecSchedulerListenersContainer.java
@@ -14,7 +14,7 @@
* 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.util.List;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobTemplate.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobTemplate.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobTemplate.java
index 21b59d5..1269bc4 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobTemplate.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobTemplate.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.api;
+package org.apache.gobblin.runtime.api;
import com.typesafe.config.Config;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/MutableJobCatalog.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/MutableJobCatalog.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/MutableJobCatalog.java
index d8d54fe..b5c82b7 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/MutableJobCatalog.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/MutableJobCatalog.java
@@ -14,11 +14,11 @@
* 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 gobblin.annotation.Alpha;
+import org.apache.gobblin.annotation.Alpha;
/**
* A {@link JobCatalog} that can have its {@link Collection} of {@link JobSpec}s modified
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/MutableSpecCatalog.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/MutableSpecCatalog.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/MutableSpecCatalog.java
index 3237f0a..1751a56 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/MutableSpecCatalog.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/MutableSpecCatalog.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.api;
+package org.apache.gobblin.runtime.api;
import java.net.URI;
import java.util.Collection;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecCatalog.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecCatalog.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecCatalog.java
index 967ea01..d2af9b8 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecCatalog.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecCatalog.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.api;
+package org.apache.gobblin.runtime.api;
import java.net.URI;
import java.util.Collection;
@@ -23,11 +23,11 @@ import java.util.Collection;
import com.codahale.metrics.Gauge;
import com.google.common.collect.ImmutableMap;
-import gobblin.instrumented.GobblinMetricsKeys;
-import gobblin.instrumented.Instrumentable;
-import gobblin.metrics.ContextAwareCounter;
-import gobblin.metrics.ContextAwareGauge;
-import gobblin.metrics.GobblinTrackingEvent;
+import org.apache.gobblin.instrumented.GobblinMetricsKeys;
+import org.apache.gobblin.instrumented.Instrumentable;
+import org.apache.gobblin.metrics.ContextAwareCounter;
+import org.apache.gobblin.metrics.ContextAwareGauge;
+import org.apache.gobblin.metrics.GobblinTrackingEvent;
import lombok.Getter;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecCatalogListener.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecCatalogListener.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecCatalogListener.java
index 99967d5..2b0aa40 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecCatalogListener.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecCatalogListener.java
@@ -15,13 +15,13 @@
* limitations under the License.
*/
-package gobblin.runtime.api;
+package org.apache.gobblin.runtime.api;
import java.net.URI;
import com.google.common.base.Objects;
-import gobblin.util.callbacks.Callback;
+import org.apache.gobblin.util.callbacks.Callback;
public interface SpecCatalogListener {
/** Invoked when a new {@link Spec} is added to the catalog and for all pre-existing specs on registration
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecCatalogListenersContainer.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecCatalogListenersContainer.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecCatalogListenersContainer.java
index 276fa52..dbda11d 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecCatalogListenersContainer.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecCatalogListenersContainer.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.api;
+package org.apache.gobblin.runtime.api;
public interface SpecCatalogListenersContainer {
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecCompiler.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecCompiler.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecCompiler.java
index 0fe0de3..bb617a7 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecCompiler.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecCompiler.java
@@ -15,12 +15,12 @@
* limitations under the License.
*/
-package gobblin.runtime.api;
+package org.apache.gobblin.runtime.api;
import java.net.URI;
import java.util.Map;
-import gobblin.instrumented.Instrumentable;
+import org.apache.gobblin.instrumented.Instrumentable;
/***
* Take in a logical {@link Spec} and compile corresponding materialized {@link Spec}s
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecNotFoundException.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecNotFoundException.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecNotFoundException.java
index 5f700c7..2a6c575 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecNotFoundException.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecNotFoundException.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.api;
+package org.apache.gobblin.runtime.api;
import java.net.URI;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecSerDe.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecSerDe.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecSerDe.java
index 0d41cdb..85f38cc 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecSerDe.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecSerDe.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.api;
+package org.apache.gobblin.runtime.api;
/**
* A Serializer / Deserializer for {@link Spec}.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecStore.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecStore.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecStore.java
index 6097d9f..dff8321 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecStore.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecStore.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.api;
+package org.apache.gobblin.runtime.api;
import java.io.IOException;
import java.net.URI;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/TopologySpec.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/TopologySpec.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/TopologySpec.java
index 4d167d4..da89b9e 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/TopologySpec.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/TopologySpec.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.api;
+package org.apache.gobblin.runtime.api;
import java.lang.reflect.InvocationTargetException;
import java.net.URI;
@@ -36,11 +36,11 @@ import com.google.common.base.Preconditions;
import com.typesafe.config.Config;
import com.typesafe.config.ConfigFactory;
-import gobblin.annotation.Alpha;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.spec_executorInstance.InMemorySpecExecutorInstanceProducer;
-import gobblin.util.ClassAliasResolver;
-import gobblin.util.ConfigUtils;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.spec_executorInstance.InMemorySpecExecutorInstanceProducer;
+import org.apache.gobblin.util.ClassAliasResolver;
+import org.apache.gobblin.util.ConfigUtils;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/package-info.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/package-info.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/package-info.java
index c24c2ff..755c5b5 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/package-info.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/package-info.java
@@ -72,4 +72,4 @@
* levels in the hierarchy, there is a Driver which is responsible of running the children
* components and a Launcher which is responsible for instantiating and invoking the Driver.
*/
-package gobblin.runtime.api;
\ No newline at end of file
+package org.apache.gobblin.runtime.api;
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/app/ApplicationException.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/app/ApplicationException.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/app/ApplicationException.java
index 665d568..daaaed4 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/app/ApplicationException.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/app/ApplicationException.java
@@ -15,9 +15,9 @@
* limitations under the License.
*/
-package gobblin.runtime.app;
+package org.apache.gobblin.runtime.app;
-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/runtime/app/ApplicationLauncher.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/app/ApplicationLauncher.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/app/ApplicationLauncher.java
index 6e9767d..31a2f55 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/app/ApplicationLauncher.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/app/ApplicationLauncher.java
@@ -15,12 +15,12 @@
* limitations under the License.
*/
-package gobblin.runtime.app;
+package org.apache.gobblin.runtime.app;
import java.io.Closeable;
-import gobblin.annotation.Alpha;
-import gobblin.runtime.JobLauncher;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.runtime.JobLauncher;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/app/ServiceBasedAppLauncher.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/app/ServiceBasedAppLauncher.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/app/ServiceBasedAppLauncher.java
index 6a07cf2..06f8113 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/app/ServiceBasedAppLauncher.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/app/ServiceBasedAppLauncher.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.app;
+package org.apache.gobblin.runtime.app;
import java.io.IOException;
import java.lang.reflect.Constructor;
@@ -34,16 +34,16 @@ import org.slf4j.LoggerFactory;
import com.google.common.util.concurrent.Service;
import com.google.common.util.concurrent.ServiceManager;
-import gobblin.annotation.Alpha;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.metrics.GobblinMetrics;
-import gobblin.rest.JobExecutionInfoServer;
-import gobblin.runtime.api.AdminWebServerFactory;
-import gobblin.runtime.services.JMXReportingService;
-import gobblin.runtime.services.MetricsReportingService;
-import gobblin.util.ApplicationLauncherUtils;
-import gobblin.util.ClassAliasResolver;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.metrics.GobblinMetrics;
+import org.apache.gobblin.rest.JobExecutionInfoServer;
+import org.apache.gobblin.runtime.api.AdminWebServerFactory;
+import org.apache.gobblin.runtime.services.JMXReportingService;
+import org.apache.gobblin.runtime.services.MetricsReportingService;
+import org.apache.gobblin.util.ApplicationLauncherUtils;
+import org.apache.gobblin.util.ClassAliasResolver;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/cli/CliEmbeddedGobblin.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/cli/CliEmbeddedGobblin.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/cli/CliEmbeddedGobblin.java
index 6679de0..a49562f 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/cli/CliEmbeddedGobblin.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/cli/CliEmbeddedGobblin.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.cli;
+package org.apache.gobblin.runtime.cli;
import java.io.IOException;
import java.util.List;
@@ -26,9 +26,9 @@ import org.apache.commons.cli.CommandLine;
import com.google.common.base.Strings;
-import gobblin.annotation.Alias;
-import gobblin.runtime.embedded.EmbeddedGobblin;
-import gobblin.util.ClassAliasResolver;
+import org.apache.gobblin.annotation.Alias;
+import org.apache.gobblin.runtime.embedded.EmbeddedGobblin;
+import org.apache.gobblin.util.ClassAliasResolver;
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/cli/CliOptions.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/cli/CliOptions.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/cli/CliOptions.java
index b334c94..408f023 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/cli/CliOptions.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/cli/CliOptions.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.cli;
+package org.apache.gobblin.runtime.cli;
import java.io.IOException;
import java.util.Properties;
@@ -28,7 +28,7 @@ import org.apache.commons.cli.Options;
import org.apache.commons.cli.ParseException;
import org.apache.commons.configuration.ConfigurationException;
-import gobblin.util.JobConfigurationUtils;
+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/cli/ConstructorAndPublicMethodsGobblinCliFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/cli/ConstructorAndPublicMethodsGobblinCliFactory.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/cli/ConstructorAndPublicMethodsGobblinCliFactory.java
index 8ee95c8..be7ef35 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/cli/ConstructorAndPublicMethodsGobblinCliFactory.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/cli/ConstructorAndPublicMethodsGobblinCliFactory.java
@@ -15,11 +15,11 @@
* limitations under the License.
*/
-package gobblin.runtime.cli;
+package org.apache.gobblin.runtime.cli;
import org.apache.commons.cli.Option;
-import gobblin.runtime.embedded.EmbeddedGobblin;
+import org.apache.gobblin.runtime.embedded.EmbeddedGobblin;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/cli/EmbeddedGobblinCliFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/cli/EmbeddedGobblinCliFactory.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/cli/EmbeddedGobblinCliFactory.java
index fc96697..39bb1ff 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/cli/EmbeddedGobblinCliFactory.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/cli/EmbeddedGobblinCliFactory.java
@@ -15,9 +15,9 @@
* limitations under the License.
*/
-package gobblin.runtime.cli;
+package org.apache.gobblin.runtime.cli;
-import gobblin.runtime.embedded.EmbeddedGobblin;
+import org.apache.gobblin.runtime.embedded.EmbeddedGobblin;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/cli/PasswordManagerCLI.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/cli/PasswordManagerCLI.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/cli/PasswordManagerCLI.java
index 12288b0..d9d0412 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/cli/PasswordManagerCLI.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/cli/PasswordManagerCLI.java
@@ -15,10 +15,10 @@
* limitations under the License.
*/
-package gobblin.runtime.cli;
+package org.apache.gobblin.runtime.cli;
-import gobblin.annotation.Alias;
-import gobblin.util.CLIPasswordEncryptor;
+import org.apache.gobblin.annotation.Alias;
+import org.apache.gobblin.util.CLIPasswordEncryptor;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/cli/PublicMethodsGobblinCliFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/cli/PublicMethodsGobblinCliFactory.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/cli/PublicMethodsGobblinCliFactory.java
index 9aadec5..563d1f4 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/cli/PublicMethodsGobblinCliFactory.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/cli/PublicMethodsGobblinCliFactory.java
@@ -15,15 +15,15 @@
* limitations under the License.
*/
-package gobblin.runtime.cli;
+package org.apache.gobblin.runtime.cli;
import java.io.IOException;
import org.apache.commons.cli.CommandLine;
import org.apache.commons.cli.Option;
-import gobblin.runtime.api.JobTemplate;
-import gobblin.runtime.embedded.EmbeddedGobblin;
+import org.apache.gobblin.runtime.api.JobTemplate;
+import org.apache.gobblin.runtime.embedded.EmbeddedGobblin;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/commit/DatasetStateCommitStep.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/commit/DatasetStateCommitStep.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/commit/DatasetStateCommitStep.java
index f289f32..a59c497 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/commit/DatasetStateCommitStep.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/commit/DatasetStateCommitStep.java
@@ -15,21 +15,21 @@
* limitations under the License.
*/
-package gobblin.runtime.commit;
+package org.apache.gobblin.runtime.commit;
import com.typesafe.config.ConfigFactory;
-import gobblin.metastore.DatasetStateStore;
-import gobblin.util.ClassAliasResolver;
+import org.apache.gobblin.metastore.DatasetStateStore;
+import org.apache.gobblin.util.ClassAliasResolver;
import java.io.IOException;
import com.google.common.base.Preconditions;
-import gobblin.annotation.Alpha;
-import gobblin.commit.CommitSequence;
-import gobblin.commit.CommitStep;
-import gobblin.commit.CommitStepBase;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.JobState.DatasetState;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.commit.CommitSequence;
+import org.apache.gobblin.commit.CommitStep;
+import org.apache.gobblin.commit.CommitStepBase;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.JobState.DatasetState;
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/commit/FsCommitSequenceStore.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/commit/FsCommitSequenceStore.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/commit/FsCommitSequenceStore.java
index 198fc86..e2939a1 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/commit/FsCommitSequenceStore.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/commit/FsCommitSequenceStore.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.commit;
+package org.apache.gobblin.runtime.commit;
import java.io.DataOutputStream;
import java.io.IOException;
@@ -32,14 +32,14 @@ import com.google.common.base.Strings;
import com.google.common.collect.ImmutableList;
import com.google.gson.Gson;
-import gobblin.annotation.Alpha;
-import gobblin.commit.CommitSequence;
-import gobblin.commit.CommitSequenceStore;
-import gobblin.commit.CommitStep;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.util.HadoopUtils;
-import gobblin.util.filters.HiddenFilter;
-import gobblin.util.io.GsonInterfaceAdapter;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.commit.CommitSequence;
+import org.apache.gobblin.commit.CommitSequenceStore;
+import org.apache.gobblin.commit.CommitStep;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.util.HadoopUtils;
+import org.apache.gobblin.util.filters.HiddenFilter;
+import org.apache.gobblin.util.io.GsonInterfaceAdapter;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/crypto/DecryptCli.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/crypto/DecryptCli.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/crypto/DecryptCli.java
index 2746668..96bc1b0 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/crypto/DecryptCli.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/crypto/DecryptCli.java
@@ -1,4 +1,4 @@
-package gobblin.runtime.crypto;
+package org.apache.gobblin.runtime.crypto;
import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
@@ -22,10 +22,10 @@ import org.apache.commons.io.IOUtils;
import com.google.common.collect.ImmutableMap;
-import gobblin.annotation.Alias;
-import gobblin.crypto.EncryptionConfigParser;
-import gobblin.crypto.EncryptionFactory;
-import gobblin.runtime.cli.CliApplication;
+import org.apache.gobblin.annotation.Alias;
+import org.apache.gobblin.crypto.EncryptionConfigParser;
+import org.apache.gobblin.crypto.EncryptionFactory;
+import org.apache.gobblin.runtime.cli.CliApplication;
@Alias(value = "decrypt", description = "Decryption utilities")
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblin.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblin.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblin.java
index 8c12367..aef1626 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblin.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblin.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.embedded;
+package org.apache.gobblin.runtime.embedded;
import java.io.IOException;
import java.net.URI;
@@ -58,43 +58,43 @@ import com.linkedin.data.template.DataTemplate;
import com.typesafe.config.Config;
import com.typesafe.config.ConfigFactory;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.instrumented.extractor.InstrumentedExtractorBase;
-import gobblin.metastore.FsStateStore;
-import gobblin.metrics.GobblinMetrics;
-import gobblin.metrics.MetricContext;
-import gobblin.runtime.JobLauncherFactory;
-import gobblin.runtime.Task;
-import gobblin.runtime.api.Configurable;
-import gobblin.runtime.api.GobblinInstanceDriver;
-import gobblin.runtime.api.GobblinInstanceEnvironment;
-import gobblin.runtime.api.GobblinInstancePluginFactory;
-import gobblin.runtime.api.JobCatalog;
-import gobblin.runtime.api.JobExecutionDriver;
-import gobblin.runtime.api.JobExecutionResult;
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.api.JobTemplate;
-import gobblin.runtime.api.SpecNotFoundException;
-import gobblin.runtime.cli.ConstructorAndPublicMethodsGobblinCliFactory;
-import gobblin.runtime.cli.CliObjectOption;
-import gobblin.runtime.cli.CliObjectSupport;
-import gobblin.runtime.cli.NotOnCli;
-import gobblin.runtime.instance.SimpleGobblinInstanceEnvironment;
-import gobblin.runtime.instance.StandardGobblinInstanceDriver;
-import gobblin.runtime.job_catalog.ImmutableFSJobCatalog;
-import gobblin.runtime.job_catalog.PackagedTemplatesJobCatalogDecorator;
-import gobblin.runtime.job_catalog.StaticJobCatalog;
-import gobblin.runtime.job_spec.ResolvedJobSpec;
-import gobblin.runtime.plugins.GobblinInstancePluginUtils;
-import gobblin.runtime.plugins.PluginStaticKeys;
-import gobblin.runtime.plugins.metrics.GobblinMetricsPlugin;
-import gobblin.runtime.std.DefaultConfigurableImpl;
-import gobblin.runtime.std.DefaultJobLifecycleListenerImpl;
-import gobblin.state.ConstructState;
-import gobblin.util.HadoopUtils;
-import gobblin.util.PathUtils;
-import gobblin.util.PullFileLoader;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.instrumented.extractor.InstrumentedExtractorBase;
+import org.apache.gobblin.metastore.FsStateStore;
+import org.apache.gobblin.metrics.GobblinMetrics;
+import org.apache.gobblin.metrics.MetricContext;
+import org.apache.gobblin.runtime.JobLauncherFactory;
+import org.apache.gobblin.runtime.Task;
+import org.apache.gobblin.runtime.api.Configurable;
+import org.apache.gobblin.runtime.api.GobblinInstanceDriver;
+import org.apache.gobblin.runtime.api.GobblinInstanceEnvironment;
+import org.apache.gobblin.runtime.api.GobblinInstancePluginFactory;
+import org.apache.gobblin.runtime.api.JobCatalog;
+import org.apache.gobblin.runtime.api.JobExecutionDriver;
+import org.apache.gobblin.runtime.api.JobExecutionResult;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.api.JobTemplate;
+import org.apache.gobblin.runtime.api.SpecNotFoundException;
+import org.apache.gobblin.runtime.cli.ConstructorAndPublicMethodsGobblinCliFactory;
+import org.apache.gobblin.runtime.cli.CliObjectOption;
+import org.apache.gobblin.runtime.cli.CliObjectSupport;
+import org.apache.gobblin.runtime.cli.NotOnCli;
+import org.apache.gobblin.runtime.instance.SimpleGobblinInstanceEnvironment;
+import org.apache.gobblin.runtime.instance.StandardGobblinInstanceDriver;
+import org.apache.gobblin.runtime.job_catalog.ImmutableFSJobCatalog;
+import org.apache.gobblin.runtime.job_catalog.PackagedTemplatesJobCatalogDecorator;
+import org.apache.gobblin.runtime.job_catalog.StaticJobCatalog;
+import org.apache.gobblin.runtime.job_spec.ResolvedJobSpec;
+import org.apache.gobblin.runtime.plugins.GobblinInstancePluginUtils;
+import org.apache.gobblin.runtime.plugins.PluginStaticKeys;
+import org.apache.gobblin.runtime.plugins.metrics.GobblinMetricsPlugin;
+import org.apache.gobblin.runtime.std.DefaultConfigurableImpl;
+import org.apache.gobblin.runtime.std.DefaultJobLifecycleListenerImpl;
+import org.apache.gobblin.state.ConstructState;
+import org.apache.gobblin.util.HadoopUtils;
+import org.apache.gobblin.util.PathUtils;
+import org.apache.gobblin.util.PullFileLoader;
import javassist.bytecode.ClassFile;
import javax.annotation.Nullable;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/fork/AsynchronousFork.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/fork/AsynchronousFork.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/fork/AsynchronousFork.java
index d2578e0..18ff548 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/fork/AsynchronousFork.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/fork/AsynchronousFork.java
@@ -10,24 +10,24 @@
* CONDITIONS OF ANY KIND, either express or implied.
*/
-package gobblin.runtime.fork;
+package org.apache.gobblin.runtime.fork;
import java.io.IOException;
import java.util.concurrent.TimeUnit;
-import gobblin.runtime.BoundedBlockingRecordQueue;
-import gobblin.runtime.ExecutionModel;
-import gobblin.runtime.Task;
-import gobblin.runtime.TaskContext;
-import gobblin.runtime.TaskExecutor;
-import gobblin.runtime.TaskState;
+import org.apache.gobblin.runtime.BoundedBlockingRecordQueue;
+import org.apache.gobblin.runtime.ExecutionModel;
+import org.apache.gobblin.runtime.Task;
+import org.apache.gobblin.runtime.TaskContext;
+import org.apache.gobblin.runtime.TaskExecutor;
+import org.apache.gobblin.runtime.TaskState;
import lombok.extern.slf4j.Slf4j;
import com.google.common.base.Optional;
import com.google.common.base.Throwables;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.converter.DataConversionException;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.converter.DataConversionException;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/fork/Fork.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/fork/Fork.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/fork/Fork.java
index 805a949..e38689f 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/fork/Fork.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/fork/Fork.java
@@ -10,7 +10,7 @@
* CONDITIONS OF ANY KIND, either express or implied.
*/
-package gobblin.runtime.fork;
+package org.apache.gobblin.runtime.fork;
import java.io.Closeable;
import java.io.IOException;
@@ -26,41 +26,41 @@ import com.google.common.base.Throwables;
import com.google.common.collect.ImmutableList;
import com.google.common.io.Closer;
-import gobblin.Constructs;
-import gobblin.commit.SpeculativeAttemptAwareConstruct;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.converter.Converter;
-import gobblin.converter.DataConversionException;
-import gobblin.instrumented.Instrumented;
-import gobblin.metrics.GobblinMetrics;
-import gobblin.metrics.Tag;
-import gobblin.publisher.TaskPublisher;
-import gobblin.qualitychecker.row.RowLevelPolicyCheckResults;
-import gobblin.qualitychecker.row.RowLevelPolicyChecker;
-import gobblin.qualitychecker.task.TaskLevelPolicyCheckResults;
-import gobblin.records.RecordStreamConsumer;
-import gobblin.records.RecordStreamProcessor;
-import gobblin.records.RecordStreamWithMetadata;
-import gobblin.runtime.BoundedBlockingRecordQueue;
-import gobblin.runtime.ExecutionModel;
-import gobblin.runtime.MultiConverter;
-import gobblin.runtime.Task;
-import gobblin.runtime.TaskContext;
-import gobblin.runtime.TaskExecutor;
-import gobblin.runtime.TaskState;
-import gobblin.runtime.util.TaskMetrics;
-import gobblin.stream.ControlMessage;
-import gobblin.stream.RecordEnvelope;
-import gobblin.state.ConstructState;
-import gobblin.util.FinalState;
-import gobblin.util.ForkOperatorUtils;
-import gobblin.writer.DataWriter;
-import gobblin.writer.DataWriterBuilder;
-import gobblin.writer.DataWriterWrapperBuilder;
-import gobblin.writer.Destination;
-import gobblin.writer.PartitionedDataWriter;
-import gobblin.writer.WatermarkAwareWriter;
+import org.apache.gobblin.Constructs;
+import org.apache.gobblin.commit.SpeculativeAttemptAwareConstruct;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.converter.Converter;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.instrumented.Instrumented;
+import org.apache.gobblin.metrics.GobblinMetrics;
+import org.apache.gobblin.metrics.Tag;
+import org.apache.gobblin.publisher.TaskPublisher;
+import org.apache.gobblin.qualitychecker.row.RowLevelPolicyCheckResults;
+import org.apache.gobblin.qualitychecker.row.RowLevelPolicyChecker;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicyCheckResults;
+import org.apache.gobblin.records.RecordStreamConsumer;
+import org.apache.gobblin.records.RecordStreamProcessor;
+import org.apache.gobblin.records.RecordStreamWithMetadata;
+import org.apache.gobblin.runtime.BoundedBlockingRecordQueue;
+import org.apache.gobblin.runtime.ExecutionModel;
+import org.apache.gobblin.runtime.MultiConverter;
+import org.apache.gobblin.runtime.Task;
+import org.apache.gobblin.runtime.TaskContext;
+import org.apache.gobblin.runtime.TaskExecutor;
+import org.apache.gobblin.runtime.TaskState;
+import org.apache.gobblin.runtime.util.TaskMetrics;
+import org.apache.gobblin.stream.ControlMessage;
+import org.apache.gobblin.stream.RecordEnvelope;
+import org.apache.gobblin.state.ConstructState;
+import org.apache.gobblin.util.FinalState;
+import org.apache.gobblin.util.ForkOperatorUtils;
+import org.apache.gobblin.writer.DataWriter;
+import org.apache.gobblin.writer.DataWriterBuilder;
+import org.apache.gobblin.writer.DataWriterWrapperBuilder;
+import org.apache.gobblin.writer.Destination;
+import org.apache.gobblin.writer.PartitionedDataWriter;
+import org.apache.gobblin.writer.WatermarkAwareWriter;
import edu.umd.cs.findbugs.annotations.SuppressWarnings;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/fork/SynchronousFork.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/fork/SynchronousFork.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/fork/SynchronousFork.java
index 507dbe6..798473d 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/fork/SynchronousFork.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/fork/SynchronousFork.java
@@ -10,15 +10,15 @@
* CONDITIONS OF ANY KIND, either express or implied.
*/
-package gobblin.runtime.fork;
+package org.apache.gobblin.runtime.fork;
import com.google.common.base.Optional;
import com.google.common.base.Throwables;
-import gobblin.converter.DataConversionException;
-import gobblin.runtime.BoundedBlockingRecordQueue;
-import gobblin.runtime.ExecutionModel;
-import gobblin.runtime.TaskContext;
-import gobblin.util.concurrent.AutoResetEvent;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.runtime.BoundedBlockingRecordQueue;
+import org.apache.gobblin.runtime.ExecutionModel;
+import org.apache.gobblin.runtime.TaskContext;
+import org.apache.gobblin.util.concurrent.AutoResetEvent;
import java.io.IOException;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/DefaultGobblinInstanceDriverImpl.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/DefaultGobblinInstanceDriverImpl.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/DefaultGobblinInstanceDriverImpl.java
index 7b12658..d508e16 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/DefaultGobblinInstanceDriverImpl.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/DefaultGobblinInstanceDriverImpl.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.runtime.instance;
+package org.apache.gobblin.runtime.instance;
import java.net.URI;
import java.util.Collections;
@@ -28,30 +28,30 @@ import com.google.common.base.Optional;
import com.google.common.base.Preconditions;
import com.google.common.util.concurrent.AbstractIdleService;
-import gobblin.broker.gobblin_scopes.GobblinScopeTypes;
-import gobblin.broker.iface.SharedResourcesBroker;
-import gobblin.instrumented.Instrumented;
-import gobblin.metrics.GobblinMetrics;
-import gobblin.metrics.MetricContext;
-import gobblin.metrics.Tag;
-import gobblin.runtime.JobState.RunningState;
-import gobblin.runtime.api.Configurable;
-import gobblin.runtime.api.GobblinInstanceDriver;
-import gobblin.runtime.api.GobblinInstanceLauncher.ConfigAccessor;
-import gobblin.runtime.api.JobCatalog;
-import gobblin.runtime.api.JobExecutionDriver;
-import gobblin.runtime.api.JobExecutionLauncher;
-import gobblin.runtime.api.JobExecutionState;
-import gobblin.runtime.api.JobLifecycleListener;
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.api.JobSpecMonitorFactory;
-import gobblin.runtime.api.JobSpecScheduler;
-import gobblin.runtime.api.MutableJobCatalog;
-import gobblin.runtime.job_spec.ResolvedJobSpec;
-import gobblin.runtime.std.DefaultJobCatalogListenerImpl;
-import gobblin.runtime.std.DefaultJobExecutionStateListenerImpl;
-import gobblin.runtime.std.JobLifecycleListenersList;
-import gobblin.util.ExecutorsUtils;
+import org.apache.gobblin.broker.gobblin_scopes.GobblinScopeTypes;
+import org.apache.gobblin.broker.iface.SharedResourcesBroker;
+import org.apache.gobblin.instrumented.Instrumented;
+import org.apache.gobblin.metrics.GobblinMetrics;
+import org.apache.gobblin.metrics.MetricContext;
+import org.apache.gobblin.metrics.Tag;
+import org.apache.gobblin.runtime.JobState.RunningState;
+import org.apache.gobblin.runtime.api.Configurable;
+import org.apache.gobblin.runtime.api.GobblinInstanceDriver;
+import org.apache.gobblin.runtime.api.GobblinInstanceLauncher.ConfigAccessor;
+import org.apache.gobblin.runtime.api.JobCatalog;
+import org.apache.gobblin.runtime.api.JobExecutionDriver;
+import org.apache.gobblin.runtime.api.JobExecutionLauncher;
+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.JobSpecMonitorFactory;
+import org.apache.gobblin.runtime.api.JobSpecScheduler;
+import org.apache.gobblin.runtime.api.MutableJobCatalog;
+import org.apache.gobblin.runtime.job_spec.ResolvedJobSpec;
+import org.apache.gobblin.runtime.std.DefaultJobCatalogListenerImpl;
+import org.apache.gobblin.runtime.std.DefaultJobExecutionStateListenerImpl;
+import org.apache.gobblin.runtime.std.JobLifecycleListenersList;
+import org.apache.gobblin.util.ExecutorsUtils;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/SimpleGobblinInstanceEnvironment.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/SimpleGobblinInstanceEnvironment.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/SimpleGobblinInstanceEnvironment.java
index 010634e..dad11db 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/SimpleGobblinInstanceEnvironment.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/SimpleGobblinInstanceEnvironment.java
@@ -15,19 +15,19 @@
* limitations under the License.
*/
-package gobblin.runtime.instance;
+package org.apache.gobblin.runtime.instance;
import java.util.List;
import org.slf4j.Logger;
-import gobblin.broker.gobblin_scopes.GobblinScopeTypes;
-import gobblin.broker.iface.SharedResourcesBroker;
-import gobblin.configuration.State;
-import gobblin.metrics.MetricContext;
-import gobblin.metrics.Tag;
-import gobblin.runtime.api.Configurable;
-import gobblin.runtime.api.GobblinInstanceEnvironment;
+import org.apache.gobblin.broker.gobblin_scopes.GobblinScopeTypes;
+import org.apache.gobblin.broker.iface.SharedResourcesBroker;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.metrics.MetricContext;
+import org.apache.gobblin.metrics.Tag;
+import org.apache.gobblin.runtime.api.Configurable;
+import org.apache.gobblin.runtime.api.GobblinInstanceEnvironment;
import javax.annotation.Nonnull;
import lombok.Data;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/StandardGobblinInstanceDriver.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/StandardGobblinInstanceDriver.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/StandardGobblinInstanceDriver.java
index 9ed2cb2..dc9df98 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/StandardGobblinInstanceDriver.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/StandardGobblinInstanceDriver.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.runtime.instance;
+package org.apache.gobblin.runtime.instance;
import java.io.IOException;
import java.util.ArrayList;
@@ -34,33 +34,33 @@ import com.google.common.util.concurrent.Service;
import com.google.common.util.concurrent.ServiceManager;
import com.typesafe.config.ConfigFactory;
-import gobblin.broker.SharedResourcesBrokerFactory;
-import gobblin.broker.SharedResourcesBrokerImpl;
-import gobblin.broker.SimpleScope;
-import gobblin.broker.gobblin_scopes.GobblinScopeTypes;
-import gobblin.broker.iface.SharedResourcesBroker;
-import gobblin.instrumented.Instrumented;
-import gobblin.metrics.GobblinMetrics;
-import gobblin.metrics.MetricContext;
-import gobblin.metrics.Tag;
-import gobblin.runtime.api.Configurable;
-import gobblin.runtime.api.GobblinInstanceEnvironment;
-import gobblin.runtime.api.GobblinInstanceLauncher;
-import gobblin.runtime.api.GobblinInstancePlugin;
-import gobblin.runtime.api.GobblinInstancePluginFactory;
-import gobblin.runtime.api.JobCatalog;
-import gobblin.runtime.api.JobExecutionLauncher;
-import gobblin.runtime.api.JobSpecScheduler;
-import gobblin.runtime.job_catalog.FSJobCatalog;
-import gobblin.runtime.job_catalog.ImmutableFSJobCatalog;
-import gobblin.runtime.job_catalog.InMemoryJobCatalog;
-import gobblin.runtime.job_exec.JobLauncherExecutionDriver;
-import gobblin.runtime.plugins.email.EmailNotificationPlugin;
-import gobblin.runtime.scheduler.ImmediateJobSpecScheduler;
-import gobblin.runtime.scheduler.QuartzJobSpecScheduler;
-import gobblin.runtime.std.DefaultConfigurableImpl;
-import gobblin.util.ClassAliasResolver;
-import gobblin.util.ConfigUtils;
+import org.apache.gobblin.broker.SharedResourcesBrokerFactory;
+import org.apache.gobblin.broker.SharedResourcesBrokerImpl;
+import org.apache.gobblin.broker.SimpleScope;
+import org.apache.gobblin.broker.gobblin_scopes.GobblinScopeTypes;
+import org.apache.gobblin.broker.iface.SharedResourcesBroker;
+import org.apache.gobblin.instrumented.Instrumented;
+import org.apache.gobblin.metrics.GobblinMetrics;
+import org.apache.gobblin.metrics.MetricContext;
+import org.apache.gobblin.metrics.Tag;
+import org.apache.gobblin.runtime.api.Configurable;
+import org.apache.gobblin.runtime.api.GobblinInstanceEnvironment;
+import org.apache.gobblin.runtime.api.GobblinInstanceLauncher;
+import org.apache.gobblin.runtime.api.GobblinInstancePlugin;
+import org.apache.gobblin.runtime.api.GobblinInstancePluginFactory;
+import org.apache.gobblin.runtime.api.JobCatalog;
+import org.apache.gobblin.runtime.api.JobExecutionLauncher;
+import org.apache.gobblin.runtime.api.JobSpecScheduler;
+import org.apache.gobblin.runtime.job_catalog.FSJobCatalog;
+import org.apache.gobblin.runtime.job_catalog.ImmutableFSJobCatalog;
+import org.apache.gobblin.runtime.job_catalog.InMemoryJobCatalog;
+import org.apache.gobblin.runtime.job_exec.JobLauncherExecutionDriver;
+import org.apache.gobblin.runtime.plugins.email.EmailNotificationPlugin;
+import org.apache.gobblin.runtime.scheduler.ImmediateJobSpecScheduler;
+import org.apache.gobblin.runtime.scheduler.QuartzJobSpecScheduler;
+import org.apache.gobblin.runtime.std.DefaultConfigurableImpl;
+import org.apache.gobblin.util.ClassAliasResolver;
+import org.apache.gobblin.util.ConfigUtils;
/** A simple wrapper {@link DefaultGobblinInstanceDriverImpl} that will instantiate necessary
* sub-components (e.g. {@link JobCatalog}, {@link JobSpecScheduler}, {@link JobExecutionLauncher}
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/StandardGobblinInstanceLauncher.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/StandardGobblinInstanceLauncher.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/StandardGobblinInstanceLauncher.java
index a3ea11c..69889dd 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/StandardGobblinInstanceLauncher.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/StandardGobblinInstanceLauncher.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.runtime.instance;
+package org.apache.gobblin.runtime.instance;
import java.util.Collections;
import java.util.List;
@@ -29,20 +29,20 @@ import com.google.common.util.concurrent.AbstractIdleService;
import com.typesafe.config.Config;
import com.typesafe.config.ConfigFactory;
-import gobblin.broker.gobblin_scopes.GobblinScopeTypes;
-import gobblin.broker.SimpleScope;
-import gobblin.broker.SharedResourcesBrokerFactory;
-import gobblin.broker.SharedResourcesBrokerImpl;
-import gobblin.broker.iface.SharedResourcesBroker;
-import gobblin.instrumented.Instrumented;
-import gobblin.metrics.GobblinMetrics;
-import gobblin.metrics.MetricContext;
-import gobblin.metrics.Tag;
-import gobblin.runtime.api.Configurable;
-import gobblin.runtime.api.GobblinInstanceDriver;
-import gobblin.runtime.api.GobblinInstanceEnvironment;
-import gobblin.runtime.api.GobblinInstanceLauncher;
-import gobblin.runtime.std.DefaultConfigurableImpl;
+import org.apache.gobblin.broker.gobblin_scopes.GobblinScopeTypes;
+import org.apache.gobblin.broker.SimpleScope;
+import org.apache.gobblin.broker.SharedResourcesBrokerFactory;
+import org.apache.gobblin.broker.SharedResourcesBrokerImpl;
+import org.apache.gobblin.broker.iface.SharedResourcesBroker;
+import org.apache.gobblin.instrumented.Instrumented;
+import org.apache.gobblin.metrics.GobblinMetrics;
+import org.apache.gobblin.metrics.MetricContext;
+import org.apache.gobblin.metrics.Tag;
+import org.apache.gobblin.runtime.api.Configurable;
+import org.apache.gobblin.runtime.api.GobblinInstanceDriver;
+import org.apache.gobblin.runtime.api.GobblinInstanceEnvironment;
+import org.apache.gobblin.runtime.api.GobblinInstanceLauncher;
+import org.apache.gobblin.runtime.std.DefaultConfigurableImpl;
/**
* A standard implementation that expects the instance configuration to be passed from the outside.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/hadoop/HadoopConfigLoader.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/hadoop/HadoopConfigLoader.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/hadoop/HadoopConfigLoader.java
index 749e6c4..6979c30 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/hadoop/HadoopConfigLoader.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/hadoop/HadoopConfigLoader.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.instance.hadoop;
+package org.apache.gobblin.runtime.instance.hadoop;
import java.util.Map;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/plugin/BaseIdlePluginImpl.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/plugin/BaseIdlePluginImpl.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/plugin/BaseIdlePluginImpl.java
index a965492..684339c 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/plugin/BaseIdlePluginImpl.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/plugin/BaseIdlePluginImpl.java
@@ -14,13 +14,13 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.runtime.instance.plugin;
+package org.apache.gobblin.runtime.instance.plugin;
import com.google.common.util.concurrent.AbstractIdleService;
-import gobblin.annotation.Alias;
-import gobblin.runtime.api.GobblinInstanceDriver;
-import gobblin.runtime.api.GobblinInstancePlugin;
+import org.apache.gobblin.annotation.Alias;
+import org.apache.gobblin.runtime.api.GobblinInstanceDriver;
+import org.apache.gobblin.runtime.api.GobblinInstancePlugin;
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/job_catalog/CachingJobCatalog.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/CachingJobCatalog.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/CachingJobCatalog.java
index f5c35fd..cef10b7 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/CachingJobCatalog.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/CachingJobCatalog.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.runtime.job_catalog;
+package org.apache.gobblin.runtime.job_catalog;
import java.net.URI;
import java.util.Collection;
@@ -28,12 +28,12 @@ import org.slf4j.LoggerFactory;
import com.google.common.base.Optional;
import com.google.common.util.concurrent.AbstractIdleService;
-import gobblin.metrics.MetricContext;
-import gobblin.metrics.Tag;
-import gobblin.runtime.api.JobCatalog;
-import gobblin.runtime.api.JobCatalogListener;
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.api.JobSpecNotFoundException;
+import org.apache.gobblin.metrics.MetricContext;
+import org.apache.gobblin.metrics.Tag;
+import org.apache.gobblin.runtime.api.JobCatalog;
+import org.apache.gobblin.runtime.api.JobCatalogListener;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.api.JobSpecNotFoundException;
/**
* A JobCatalog decorator that caches all JobSpecs in memory.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/FSJobCatalog.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/FSJobCatalog.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/FSJobCatalog.java
index bd39231..be06b1e 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/FSJobCatalog.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/FSJobCatalog.java
@@ -14,14 +14,14 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.runtime.job_catalog;
-
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.api.JobCatalogWithTemplates;
-import gobblin.runtime.api.JobTemplate;
-import gobblin.runtime.api.SpecNotFoundException;
-import gobblin.runtime.template.HOCONInputStreamJobTemplate;
-import gobblin.util.PathUtils;
+package org.apache.gobblin.runtime.job_catalog;
+
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.api.JobCatalogWithTemplates;
+import org.apache.gobblin.runtime.api.JobTemplate;
+import org.apache.gobblin.runtime.api.SpecNotFoundException;
+import org.apache.gobblin.runtime.template.HOCONInputStreamJobTemplate;
+import org.apache.gobblin.util.PathUtils;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
@@ -46,12 +46,12 @@ import com.typesafe.config.Config;
import com.typesafe.config.ConfigFactory;
import com.typesafe.config.ConfigRenderOptions;
-import gobblin.metrics.MetricContext;
-import gobblin.runtime.api.GobblinInstanceEnvironment;
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.api.JobSpecNotFoundException;
-import gobblin.runtime.api.MutableJobCatalog;
-import gobblin.util.filesystem.PathAlterationObserver;
+import org.apache.gobblin.metrics.MetricContext;
+import org.apache.gobblin.runtime.api.GobblinInstanceEnvironment;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.api.JobSpecNotFoundException;
+import org.apache.gobblin.runtime.api.MutableJobCatalog;
+import org.apache.gobblin.util.filesystem.PathAlterationObserver;
/**
* The job Catalog for file system to persist the job configuration information.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/FSPathAlterationListenerAdaptor.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/FSPathAlterationListenerAdaptor.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/FSPathAlterationListenerAdaptor.java
index df088e2..74963ab 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/FSPathAlterationListenerAdaptor.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/FSPathAlterationListenerAdaptor.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.job_catalog;
+package org.apache.gobblin.runtime.job_catalog;
import java.io.IOException;
import java.net.URI;
@@ -24,10 +24,10 @@ import org.apache.hadoop.fs.Path;
import com.typesafe.config.Config;
-import gobblin.runtime.api.JobSpec;
-import gobblin.util.PathUtils;
-import gobblin.util.PullFileLoader;
-import gobblin.util.filesystem.PathAlterationListenerAdaptor;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.util.PathUtils;
+import org.apache.gobblin.util.PullFileLoader;
+import org.apache.gobblin.util.filesystem.PathAlterationListenerAdaptor;
public class FSPathAlterationListenerAdaptor extends PathAlterationListenerAdaptor {