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:26 UTC
[08/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/job_catalog/ImmutableFSJobCatalog.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/ImmutableFSJobCatalog.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/ImmutableFSJobCatalog.java
index dba6490..7162c81 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/ImmutableFSJobCatalog.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/ImmutableFSJobCatalog.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.job_catalog;
+package org.apache.gobblin.runtime.job_catalog;
import java.io.File;
import java.io.FileNotFoundException;
@@ -40,17 +40,17 @@ import com.google.common.collect.ImmutableSet;
import com.google.common.collect.Lists;
import com.typesafe.config.Config;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.metrics.GobblinMetrics;
-import gobblin.metrics.MetricContext;
-import gobblin.runtime.api.GobblinInstanceEnvironment;
-import gobblin.runtime.api.JobCatalog;
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.api.JobSpecNotFoundException;
-import gobblin.util.PathUtils;
-import gobblin.util.PullFileLoader;
-import gobblin.util.filesystem.PathAlterationObserverScheduler;
-import gobblin.util.filesystem.PathAlterationObserver;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.metrics.GobblinMetrics;
+import org.apache.gobblin.metrics.MetricContext;
+import org.apache.gobblin.runtime.api.GobblinInstanceEnvironment;
+import org.apache.gobblin.runtime.api.JobCatalog;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.api.JobSpecNotFoundException;
+import org.apache.gobblin.util.PathUtils;
+import org.apache.gobblin.util.PullFileLoader;
+import org.apache.gobblin.util.filesystem.PathAlterationObserverScheduler;
+import org.apache.gobblin.util.filesystem.PathAlterationObserver;
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/InMemoryJobCatalog.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/InMemoryJobCatalog.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/InMemoryJobCatalog.java
index 5011c6e..a32b371 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/InMemoryJobCatalog.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/InMemoryJobCatalog.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.ArrayList;
@@ -28,13 +28,13 @@ import org.slf4j.LoggerFactory;
import com.google.common.base.Optional;
import com.google.common.base.Preconditions;
-import gobblin.instrumented.Instrumented;
-import gobblin.metrics.MetricContext;
-import gobblin.runtime.api.GobblinInstanceEnvironment;
-import gobblin.runtime.api.JobCatalog;
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.api.JobSpecNotFoundException;
-import gobblin.runtime.api.MutableJobCatalog;
+import org.apache.gobblin.instrumented.Instrumented;
+import org.apache.gobblin.metrics.MetricContext;
+import org.apache.gobblin.runtime.api.GobblinInstanceEnvironment;
+import org.apache.gobblin.runtime.api.JobCatalog;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.api.JobSpecNotFoundException;
+import org.apache.gobblin.runtime.api.MutableJobCatalog;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/JobCatalogBase.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/JobCatalogBase.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/JobCatalogBase.java
index 7b52c8c..8abf914 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/JobCatalogBase.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/JobCatalogBase.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.util.Collections;
@@ -28,13 +28,13 @@ import com.google.common.base.Optional;
import com.google.common.base.Preconditions;
import com.google.common.util.concurrent.AbstractIdleService;
-import gobblin.instrumented.Instrumented;
-import gobblin.metrics.MetricContext;
-import gobblin.metrics.Tag;
-import gobblin.runtime.api.GobblinInstanceEnvironment;
-import gobblin.runtime.api.JobCatalog;
-import gobblin.runtime.api.JobCatalogListener;
-import gobblin.runtime.api.JobSpec;
+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.JobCatalog;
+import org.apache.gobblin.runtime.api.JobCatalogListener;
+import org.apache.gobblin.runtime.api.JobSpec;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/JobCatalogListenersList.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/JobCatalogListenersList.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/JobCatalogListenersList.java
index e9e7898..404d8f2 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/JobCatalogListenersList.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/JobCatalogListenersList.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.job_catalog;
+package org.apache.gobblin.runtime.job_catalog;
import java.io.Closeable;
import java.io.IOException;
@@ -29,11 +29,11 @@ import com.google.common.base.Function;
import com.google.common.base.Optional;
import com.google.common.base.Preconditions;
-import gobblin.runtime.api.JobCatalog;
-import gobblin.runtime.api.JobCatalogListener;
-import gobblin.runtime.api.JobCatalogListenersContainer;
-import gobblin.runtime.api.JobSpec;
-import gobblin.util.callbacks.CallbacksDispatcher;
+import org.apache.gobblin.runtime.api.JobCatalog;
+import org.apache.gobblin.runtime.api.JobCatalogListener;
+import org.apache.gobblin.runtime.api.JobCatalogListenersContainer;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.util.callbacks.CallbacksDispatcher;
/** A helper class to manage a list of {@link JobCatalogListener}s for a
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/MutableCachingJobCatalog.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/MutableCachingJobCatalog.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/MutableCachingJobCatalog.java
index 24ee57e..399ad32 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/MutableCachingJobCatalog.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/MutableCachingJobCatalog.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;
@@ -22,8 +22,8 @@ import org.slf4j.Logger;
import com.google.common.base.Optional;
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.api.MutableJobCatalog;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.api.MutableJobCatalog;
/**
* Implements a write-through cache of a decorated JobCatalog
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/MutableJobCatalogBase.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/MutableJobCatalogBase.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/MutableJobCatalogBase.java
index 8e079bd..e596c6e 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/MutableJobCatalogBase.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/MutableJobCatalogBase.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.job_catalog;
+package org.apache.gobblin.runtime.job_catalog;
import java.net.URI;
@@ -24,10 +24,10 @@ import org.slf4j.Logger;
import com.google.common.base.Optional;
import com.google.common.base.Preconditions;
-import gobblin.metrics.MetricContext;
-import gobblin.runtime.api.GobblinInstanceEnvironment;
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.api.MutableJobCatalog;
+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.MutableJobCatalog;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/NonObservingFSJobCatalog.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/NonObservingFSJobCatalog.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/NonObservingFSJobCatalog.java
index c3a9fd7..eebf6f9 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/NonObservingFSJobCatalog.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/NonObservingFSJobCatalog.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.io.IOException;
import java.net.URI;
@@ -28,12 +28,12 @@ import com.google.common.base.Preconditions;
import com.typesafe.config.Config;
import com.typesafe.config.ConfigValueFactory;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.metrics.MetricContext;
-import gobblin.runtime.api.GobblinInstanceEnvironment;
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.api.JobSpecNotFoundException;
-import gobblin.runtime.api.SpecNotFoundException;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+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.SpecNotFoundException;
/**
* 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/PackagedTemplatesJobCatalogDecorator.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/PackagedTemplatesJobCatalogDecorator.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/PackagedTemplatesJobCatalogDecorator.java
index 5c7bcb6..52af03c 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/PackagedTemplatesJobCatalogDecorator.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/PackagedTemplatesJobCatalogDecorator.java
@@ -15,19 +15,19 @@
* limitations under the License.
*/
-package gobblin.runtime.job_catalog;
+package org.apache.gobblin.runtime.job_catalog;
import java.io.IOException;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.Collection;
-import gobblin.runtime.api.JobCatalog;
-import gobblin.runtime.api.JobCatalogWithTemplates;
-import gobblin.runtime.api.JobTemplate;
-import gobblin.runtime.api.SpecNotFoundException;
-import gobblin.runtime.template.ResourceBasedJobTemplate;
-import gobblin.util.Decorator;
+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 org.apache.gobblin.runtime.template.ResourceBasedJobTemplate;
+import org.apache.gobblin.util.Decorator;
import lombok.experimental.Delegate;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/StaticJobCatalog.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/StaticJobCatalog.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/StaticJobCatalog.java
index 1256907..1f75f80 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/StaticJobCatalog.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/StaticJobCatalog.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.job_catalog;
+package org.apache.gobblin.runtime.job_catalog;
import java.net.URI;
import java.util.Collection;
@@ -26,11 +26,11 @@ import org.slf4j.Logger;
import com.google.common.base.Optional;
import com.google.common.collect.ImmutableMap;
-import gobblin.metrics.MetricContext;
-import gobblin.runtime.api.GobblinInstanceEnvironment;
-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.runtime.api.GobblinInstanceEnvironment;
+import org.apache.gobblin.runtime.api.JobCatalogListener;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.api.JobSpecNotFoundException;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_exec/JobLauncherExecutionDriver.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_exec/JobLauncherExecutionDriver.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_exec/JobLauncherExecutionDriver.java
index 8dbb5e7..864abf4 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_exec/JobLauncherExecutionDriver.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_exec/JobLauncherExecutionDriver.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.job_exec;
+package org.apache.gobblin.runtime.job_exec;
import java.io.IOException;
import java.util.ArrayList;
@@ -38,41 +38,41 @@ import com.google.common.io.Closer;
import com.google.common.util.concurrent.ExecutionList;
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.configuration.ConfigurationKeys;
-import gobblin.instrumented.Instrumented;
-import gobblin.metrics.GobblinMetrics;
-import gobblin.metrics.MetricContext;
-import gobblin.metrics.Tag;
-import gobblin.runtime.JobContext;
-import gobblin.runtime.JobException;
-import gobblin.runtime.JobLauncher;
-import gobblin.runtime.JobLauncherFactory;
-import gobblin.runtime.JobLauncherFactory.JobLauncherType;
-import gobblin.runtime.JobState.RunningState;
-import gobblin.runtime.api.Configurable;
-import gobblin.runtime.api.GobblinInstanceEnvironment;
-import gobblin.runtime.api.JobExecution;
-import gobblin.runtime.api.JobExecutionDriver;
-import gobblin.runtime.api.JobExecutionLauncher;
-import gobblin.runtime.api.JobExecutionResult;
-import gobblin.runtime.api.JobExecutionState;
-import gobblin.runtime.api.JobExecutionStateListener;
-import gobblin.runtime.api.JobExecutionStatus;
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.api.JobTemplate;
-import gobblin.runtime.api.SpecNotFoundException;
-import gobblin.runtime.instance.StandardGobblinInstanceLauncher;
-import gobblin.runtime.job_spec.ResolvedJobSpec;
-import gobblin.runtime.listeners.AbstractJobListener;
-import gobblin.runtime.std.DefaultConfigurableImpl;
-import gobblin.runtime.std.JobExecutionStateListeners;
-import gobblin.runtime.std.JobExecutionUpdatable;
-import gobblin.util.ExecutorsUtils;
+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.configuration.ConfigurationKeys;
+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.JobContext;
+import org.apache.gobblin.runtime.JobException;
+import org.apache.gobblin.runtime.JobLauncher;
+import org.apache.gobblin.runtime.JobLauncherFactory;
+import org.apache.gobblin.runtime.JobLauncherFactory.JobLauncherType;
+import org.apache.gobblin.runtime.JobState.RunningState;
+import org.apache.gobblin.runtime.api.Configurable;
+import org.apache.gobblin.runtime.api.GobblinInstanceEnvironment;
+import org.apache.gobblin.runtime.api.JobExecution;
+import org.apache.gobblin.runtime.api.JobExecutionDriver;
+import org.apache.gobblin.runtime.api.JobExecutionLauncher;
+import org.apache.gobblin.runtime.api.JobExecutionResult;
+import org.apache.gobblin.runtime.api.JobExecutionState;
+import org.apache.gobblin.runtime.api.JobExecutionStateListener;
+import org.apache.gobblin.runtime.api.JobExecutionStatus;
+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.instance.StandardGobblinInstanceLauncher;
+import org.apache.gobblin.runtime.job_spec.ResolvedJobSpec;
+import org.apache.gobblin.runtime.listeners.AbstractJobListener;
+import org.apache.gobblin.runtime.std.DefaultConfigurableImpl;
+import org.apache.gobblin.runtime.std.JobExecutionStateListeners;
+import org.apache.gobblin.runtime.std.JobExecutionUpdatable;
+import org.apache.gobblin.util.ExecutorsUtils;
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_exec/package-info.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_exec/package-info.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_exec/package-info.java
index 781fd60..d4dd507 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_exec/package-info.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_exec/package-info.java
@@ -18,4 +18,4 @@
* Standard {@link gobblin.runtime.api.JobExecutionLauncher} implementations
*
*/
-package gobblin.runtime.job_exec;
+package org.apache.gobblin.runtime.job_exec;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/AvroJobSpecKafkaJobMonitor.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/AvroJobSpecKafkaJobMonitor.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/AvroJobSpecKafkaJobMonitor.java
index 31b0c3d..1f2ce21 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/AvroJobSpecKafkaJobMonitor.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/AvroJobSpecKafkaJobMonitor.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.job_monitor;
+package org.apache.gobblin.runtime.job_monitor;
import java.io.IOException;
import java.net.URI;
@@ -38,23 +38,23 @@ import com.typesafe.config.Config;
import com.typesafe.config.ConfigFactory;
import com.typesafe.config.ConfigValue;
-import gobblin.metrics.GobblinTrackingEvent;
-import gobblin.metrics.event.sla.SlaEventKeys;
-import gobblin.metrics.reporter.util.FixedSchemaVersionWriter;
-import gobblin.metrics.reporter.util.NoopSchemaVersionWriter;
-import gobblin.metrics.reporter.util.SchemaVersionWriter;
-import gobblin.runtime.api.GobblinInstanceDriver;
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.api.JobSpecMonitor;
-import gobblin.runtime.api.JobSpecMonitorFactory;
-import gobblin.runtime.api.MutableJobCatalog;
-import gobblin.runtime.api.SpecExecutorInstance;
-import gobblin.runtime.api.SpecExecutorInstance.Verb;
-import gobblin.runtime.job_spec.AvroJobSpec;
-import gobblin.runtime.metrics.RuntimeMetrics;
-import gobblin.util.Either;
-import gobblin.util.PathUtils;
-import gobblin.util.reflection.GobblinConstructorUtils;
+import org.apache.gobblin.metrics.GobblinTrackingEvent;
+import org.apache.gobblin.metrics.event.sla.SlaEventKeys;
+import org.apache.gobblin.metrics.reporter.util.FixedSchemaVersionWriter;
+import org.apache.gobblin.metrics.reporter.util.NoopSchemaVersionWriter;
+import org.apache.gobblin.metrics.reporter.util.SchemaVersionWriter;
+import org.apache.gobblin.runtime.api.GobblinInstanceDriver;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.api.JobSpecMonitor;
+import org.apache.gobblin.runtime.api.JobSpecMonitorFactory;
+import org.apache.gobblin.runtime.api.MutableJobCatalog;
+import org.apache.gobblin.runtime.api.SpecExecutorInstance;
+import org.apache.gobblin.runtime.api.SpecExecutorInstance.Verb;
+import org.apache.gobblin.runtime.job_spec.AvroJobSpec;
+import org.apache.gobblin.runtime.metrics.RuntimeMetrics;
+import org.apache.gobblin.util.Either;
+import org.apache.gobblin.util.PathUtils;
+import org.apache.gobblin.util.reflection.GobblinConstructorUtils;
import kafka.message.MessageAndMetadata;
import lombok.Getter;
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/job_monitor/KafkaAvroJobMonitor.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/KafkaAvroJobMonitor.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/KafkaAvroJobMonitor.java
index 7fd34bb..527109d 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/KafkaAvroJobMonitor.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/KafkaAvroJobMonitor.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.job_monitor;
+package org.apache.gobblin.runtime.job_monitor;
import java.io.ByteArrayInputStream;
import java.io.DataInputStream;
@@ -37,12 +37,12 @@ import com.codahale.metrics.Meter;
import com.google.common.collect.Lists;
import com.typesafe.config.Config;
-import gobblin.metrics.Tag;
-import gobblin.metrics.reporter.util.SchemaVersionWriter;
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.api.MutableJobCatalog;
-import gobblin.runtime.metrics.RuntimeMetrics;
-import gobblin.util.Either;
+import org.apache.gobblin.metrics.Tag;
+import org.apache.gobblin.metrics.reporter.util.SchemaVersionWriter;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.api.MutableJobCatalog;
+import org.apache.gobblin.runtime.metrics.RuntimeMetrics;
+import org.apache.gobblin.util.Either;
import lombok.Getter;
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/job_monitor/KafkaJobMonitor.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/KafkaJobMonitor.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/KafkaJobMonitor.java
index a597862..8181c16 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/KafkaJobMonitor.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/KafkaJobMonitor.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.job_monitor;
+package org.apache.gobblin.runtime.job_monitor;
import java.io.IOException;
import java.net.URI;
@@ -26,13 +26,13 @@ import com.google.common.annotations.VisibleForTesting;
import com.google.common.base.Charsets;
import com.typesafe.config.Config;
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.api.JobSpecMonitor;
-import gobblin.runtime.api.MutableJobCatalog;
-import gobblin.runtime.kafka.HighLevelConsumer;
-import gobblin.runtime.metrics.RuntimeMetrics;
-import gobblin.util.ConfigUtils;
-import gobblin.util.Either;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.api.JobSpecMonitor;
+import org.apache.gobblin.runtime.api.MutableJobCatalog;
+import org.apache.gobblin.runtime.kafka.HighLevelConsumer;
+import org.apache.gobblin.runtime.metrics.RuntimeMetrics;
+import org.apache.gobblin.util.ConfigUtils;
+import org.apache.gobblin.util.Either;
import kafka.message.MessageAndMetadata;
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/job_monitor/SLAEventKafkaJobMonitor.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/SLAEventKafkaJobMonitor.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/SLAEventKafkaJobMonitor.java
index c981b6b..576b8c4 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/SLAEventKafkaJobMonitor.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/SLAEventKafkaJobMonitor.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.job_monitor;
+package org.apache.gobblin.runtime.job_monitor;
import java.io.IOException;
import java.net.URI;
@@ -36,19 +36,19 @@ import com.typesafe.config.Config;
import com.typesafe.config.ConfigFactory;
import com.typesafe.config.ConfigValue;
-import gobblin.metrics.GobblinTrackingEvent;
-import gobblin.metrics.event.sla.SlaEventKeys;
-import gobblin.metrics.reporter.util.NoopSchemaVersionWriter;
-import gobblin.metrics.reporter.util.SchemaVersionWriter;
-import gobblin.runtime.api.GobblinInstanceDriver;
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.api.JobSpecMonitor;
-import gobblin.runtime.api.JobSpecMonitorFactory;
-import gobblin.runtime.api.MutableJobCatalog;
-import gobblin.runtime.metrics.RuntimeMetrics;
-import gobblin.util.Either;
-import gobblin.util.PathUtils;
-import gobblin.util.reflection.GobblinConstructorUtils;
+import org.apache.gobblin.metrics.GobblinTrackingEvent;
+import org.apache.gobblin.metrics.event.sla.SlaEventKeys;
+import org.apache.gobblin.metrics.reporter.util.NoopSchemaVersionWriter;
+import org.apache.gobblin.metrics.reporter.util.SchemaVersionWriter;
+import org.apache.gobblin.runtime.api.GobblinInstanceDriver;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.api.JobSpecMonitor;
+import org.apache.gobblin.runtime.api.JobSpecMonitorFactory;
+import org.apache.gobblin.runtime.api.MutableJobCatalog;
+import org.apache.gobblin.runtime.metrics.RuntimeMetrics;
+import org.apache.gobblin.util.Either;
+import org.apache.gobblin.util.PathUtils;
+import org.apache.gobblin.util.reflection.GobblinConstructorUtils;
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_spec/ResolvedJobSpec.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_spec/ResolvedJobSpec.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_spec/ResolvedJobSpec.java
index e4a375c..8847467 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_spec/ResolvedJobSpec.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_spec/ResolvedJobSpec.java
@@ -15,22 +15,22 @@
* limitations under the License.
*/
-package gobblin.runtime.job_spec;
+package org.apache.gobblin.runtime.job_spec;
import java.net.URI;
import com.google.common.base.Optional;
import com.typesafe.config.Config;
-import gobblin.runtime.api.GobblinInstanceDriver;
-import gobblin.runtime.api.JobCatalog;
-import gobblin.runtime.api.JobCatalogWithTemplates;
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.api.JobTemplate;
-import gobblin.runtime.api.SpecNotFoundException;
-import gobblin.runtime.job_catalog.InMemoryJobCatalog;
-import gobblin.runtime.job_catalog.PackagedTemplatesJobCatalogDecorator;
-import gobblin.util.ConfigUtils;
+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.JobSpec;
+import org.apache.gobblin.runtime.api.JobTemplate;
+import org.apache.gobblin.runtime.api.SpecNotFoundException;
+import org.apache.gobblin.runtime.job_catalog.InMemoryJobCatalog;
+import org.apache.gobblin.runtime.job_catalog.PackagedTemplatesJobCatalogDecorator;
+import org.apache.gobblin.util.ConfigUtils;
import lombok.EqualsAndHashCode;
import lombok.Getter;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/kafka/HighLevelConsumer.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/kafka/HighLevelConsumer.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/kafka/HighLevelConsumer.java
index 3557cb2..a619582 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/kafka/HighLevelConsumer.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/kafka/HighLevelConsumer.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.kafka;
+package org.apache.gobblin.runtime.kafka;
import java.io.IOException;
import java.util.List;
@@ -33,12 +33,12 @@ import com.google.common.collect.Maps;
import com.google.common.util.concurrent.AbstractIdleService;
import com.typesafe.config.Config;
-import gobblin.instrumented.Instrumented;
-import gobblin.metrics.MetricContext;
-import gobblin.metrics.Tag;
-import gobblin.runtime.metrics.RuntimeMetrics;
-import gobblin.util.ConfigUtils;
-import gobblin.util.ExecutorsUtils;
+import org.apache.gobblin.instrumented.Instrumented;
+import org.apache.gobblin.metrics.MetricContext;
+import org.apache.gobblin.metrics.Tag;
+import org.apache.gobblin.runtime.metrics.RuntimeMetrics;
+import org.apache.gobblin.util.ConfigUtils;
+import org.apache.gobblin.util.ExecutorsUtils;
import kafka.consumer.Consumer;
import kafka.consumer.ConsumerConfig;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/AbstractCloseableJobListener.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/AbstractCloseableJobListener.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/AbstractCloseableJobListener.java
index 4f446e5..853a9a1 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/AbstractCloseableJobListener.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/AbstractCloseableJobListener.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.listeners;
+package org.apache.gobblin.runtime.listeners;
/**
* Extension of {@link AbstractJobListener} that also extends {@link CloseableJobListener}.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/AbstractJobListener.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/AbstractJobListener.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/AbstractJobListener.java
index 8cca7c4..4193175 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/AbstractJobListener.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/AbstractJobListener.java
@@ -15,13 +15,13 @@
* limitations under the License.
*/
-package gobblin.runtime.listeners;
+package org.apache.gobblin.runtime.listeners;
import org.slf4j.Logger;
import com.google.common.base.Optional;
-import gobblin.runtime.JobContext;
+import org.apache.gobblin.runtime.JobContext;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/CloseableJobListener.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/CloseableJobListener.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/CloseableJobListener.java
index ebf4180..6db0af6 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/CloseableJobListener.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/CloseableJobListener.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.listeners;
+package org.apache.gobblin.runtime.listeners;
import java.io.Closeable;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/EmailNotificationJobListener.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/EmailNotificationJobListener.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/EmailNotificationJobListener.java
index b319d4f..3106f4d 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/EmailNotificationJobListener.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/EmailNotificationJobListener.java
@@ -15,16 +15,16 @@
* limitations under the License.
*/
-package gobblin.runtime.listeners;
+package org.apache.gobblin.runtime.listeners;
import org.apache.commons.mail.EmailException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.JobContext;
-import gobblin.runtime.JobState;
-import gobblin.util.EmailUtils;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.JobContext;
+import org.apache.gobblin.runtime.JobState;
+import org.apache.gobblin.util.EmailUtils;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/JobExecutionEventSubmitterListener.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/JobExecutionEventSubmitterListener.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/JobExecutionEventSubmitterListener.java
index 1cb4352..ba3d92f 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/JobExecutionEventSubmitterListener.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/JobExecutionEventSubmitterListener.java
@@ -15,12 +15,12 @@
* limitations under the License.
*/
-package gobblin.runtime.listeners;
+package org.apache.gobblin.runtime.listeners;
import lombok.AllArgsConstructor;
-import gobblin.runtime.JobContext;
-import gobblin.runtime.JobExecutionEventSubmitter;
+import org.apache.gobblin.runtime.JobContext;
+import org.apache.gobblin.runtime.JobExecutionEventSubmitter;
@AllArgsConstructor
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/JobListener.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/JobListener.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/JobListener.java
index c08e911..6f8169d 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/JobListener.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/JobListener.java
@@ -15,10 +15,10 @@
* limitations under the License.
*/
-package gobblin.runtime.listeners;
+package org.apache.gobblin.runtime.listeners;
-import gobblin.runtime.JobContext;
-import gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.runtime.JobContext;
+import org.apache.gobblin.source.workunit.WorkUnit;
/**
* An interface for classes used for callback on job state changes.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/JobListeners.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/JobListeners.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/JobListeners.java
index 4439a1e..f47e2a2 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/JobListeners.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/JobListeners.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.listeners;
+package org.apache.gobblin.runtime.listeners;
import java.io.Closeable;
import java.io.IOException;
@@ -34,8 +34,8 @@ import com.google.common.collect.Iterables;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import gobblin.runtime.JobContext;
-import gobblin.util.ExecutorsUtils;
+import org.apache.gobblin.runtime.JobContext;
+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/listeners/RunOnceJobListener.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/RunOnceJobListener.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/RunOnceJobListener.java
index c979e18..483fee9 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/RunOnceJobListener.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners/RunOnceJobListener.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.listeners;
+package org.apache.gobblin.runtime.listeners;
import java.io.File;
import java.io.IOException;
@@ -25,9 +25,9 @@ import org.slf4j.LoggerFactory;
import com.google.common.io.Files;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.JobContext;
-import gobblin.runtime.JobState;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.JobContext;
+import org.apache.gobblin.runtime.JobState;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/local/CliLocalJobLauncher.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/local/CliLocalJobLauncher.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/local/CliLocalJobLauncher.java
index a5c680b..1f0d228 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/local/CliLocalJobLauncher.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/local/CliLocalJobLauncher.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.local;
+package org.apache.gobblin.runtime.local;
import java.io.IOException;
import java.util.Properties;
@@ -28,13 +28,13 @@ import org.slf4j.LoggerFactory;
import com.google.common.io.Closer;
-import gobblin.runtime.JobException;
-import gobblin.runtime.JobLauncher;
-import gobblin.runtime.app.ApplicationException;
-import gobblin.runtime.app.ApplicationLauncher;
-import gobblin.runtime.app.ServiceBasedAppLauncher;
-import gobblin.runtime.cli.CliOptions;
-import gobblin.runtime.listeners.JobListener;
+import org.apache.gobblin.runtime.JobException;
+import org.apache.gobblin.runtime.JobLauncher;
+import org.apache.gobblin.runtime.app.ApplicationException;
+import org.apache.gobblin.runtime.app.ApplicationLauncher;
+import org.apache.gobblin.runtime.app.ServiceBasedAppLauncher;
+import org.apache.gobblin.runtime.cli.CliOptions;
+import org.apache.gobblin.runtime.listeners.JobListener;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/local/LocalJobLauncher.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/local/LocalJobLauncher.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/local/LocalJobLauncher.java
index adfcdbc..4e782d5 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/local/LocalJobLauncher.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/local/LocalJobLauncher.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.local;
+package org.apache.gobblin.runtime.local;
import java.io.IOException;
import java.util.Iterator;
@@ -35,21 +35,21 @@ import com.google.common.util.concurrent.ServiceManager;
import lombok.extern.slf4j.Slf4j;
-import gobblin.broker.gobblin_scopes.GobblinScopeTypes;
-import gobblin.broker.iface.SharedResourcesBroker;
-import gobblin.metrics.Tag;
-import gobblin.metrics.event.TimingEvent;
-import gobblin.runtime.AbstractJobLauncher;
-import gobblin.runtime.GobblinMultiTaskAttempt;
-import gobblin.runtime.JobState;
-import gobblin.runtime.TaskExecutor;
-import gobblin.runtime.TaskStateTracker;
-import gobblin.runtime.api.Configurable;
-import gobblin.runtime.api.JobSpec;
-import gobblin.source.workunit.WorkUnit;
-import gobblin.util.JobConfigurationUtils;
-import gobblin.runtime.util.MultiWorkUnitUnpackingIterator;
-import gobblin.source.workunit.WorkUnitStream;
+import org.apache.gobblin.broker.gobblin_scopes.GobblinScopeTypes;
+import org.apache.gobblin.broker.iface.SharedResourcesBroker;
+import org.apache.gobblin.metrics.Tag;
+import org.apache.gobblin.metrics.event.TimingEvent;
+import org.apache.gobblin.runtime.AbstractJobLauncher;
+import org.apache.gobblin.runtime.GobblinMultiTaskAttempt;
+import org.apache.gobblin.runtime.JobState;
+import org.apache.gobblin.runtime.TaskExecutor;
+import org.apache.gobblin.runtime.TaskStateTracker;
+import org.apache.gobblin.runtime.api.Configurable;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.util.JobConfigurationUtils;
+import org.apache.gobblin.runtime.util.MultiWorkUnitUnpackingIterator;
+import org.apache.gobblin.source.workunit.WorkUnitStream;
/**
* An implementation of {@link gobblin.runtime.JobLauncher} for launching and running jobs
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/local/LocalTaskStateTracker.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/local/LocalTaskStateTracker.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/local/LocalTaskStateTracker.java
index 57a29d7..27b3477 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/local/LocalTaskStateTracker.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/local/LocalTaskStateTracker.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.local;
+package org.apache.gobblin.runtime.local;
import java.util.Map;
import java.util.Properties;
@@ -29,14 +29,14 @@ import com.google.common.collect.ImmutableList;
import com.google.common.collect.Maps;
import com.google.common.eventbus.EventBus;
-import gobblin.configuration.WorkUnitState;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.metrics.GobblinMetrics;
-import gobblin.runtime.AbstractTaskStateTracker;
-import gobblin.runtime.JobState;
-import gobblin.runtime.NewTaskCompletionEvent;
-import gobblin.runtime.Task;
-import gobblin.runtime.TaskExecutor;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.metrics.GobblinMetrics;
+import org.apache.gobblin.runtime.AbstractTaskStateTracker;
+import org.apache.gobblin.runtime.JobState;
+import org.apache.gobblin.runtime.NewTaskCompletionEvent;
+import org.apache.gobblin.runtime.Task;
+import org.apache.gobblin.runtime.TaskExecutor;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/AbstractJobLockFactoryManager.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/AbstractJobLockFactoryManager.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/AbstractJobLockFactoryManager.java
index cc58f73..9aa487b 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/AbstractJobLockFactoryManager.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/AbstractJobLockFactoryManager.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.locks;
+package org.apache.gobblin.runtime.locks;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/FileBasedJobLock.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/FileBasedJobLock.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/FileBasedJobLock.java
index b1ac83c..9e9c5ee 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/FileBasedJobLock.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/FileBasedJobLock.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.locks;
+package org.apache.gobblin.runtime.locks;
import java.io.IOException;
import java.util.Properties;
@@ -24,7 +24,7 @@ import org.apache.hadoop.fs.Path;
import com.google.common.annotations.VisibleForTesting;
-import gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.ConfigurationKeys;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/FileBasedJobLockFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/FileBasedJobLockFactory.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/FileBasedJobLockFactory.java
index 7932bf3..58387bf 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/FileBasedJobLockFactory.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/FileBasedJobLockFactory.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.runtime.locks;
+package org.apache.gobblin.runtime.locks;
import java.io.IOException;
import java.net.URI;
@@ -36,9 +36,9 @@ import com.google.common.collect.ImmutableMap;
import com.typesafe.config.Config;
import com.typesafe.config.ConfigFactory;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.api.JobSpec;
-import gobblin.util.HadoopUtils;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.util.HadoopUtils;
/**
* A factory for file-based job locks. All locks are presented as files under a common directory.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/FileBasedJobLockFactoryManager.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/FileBasedJobLockFactoryManager.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/FileBasedJobLockFactoryManager.java
index a3523dd..7fa8cbb 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/FileBasedJobLockFactoryManager.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/FileBasedJobLockFactoryManager.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.runtime.locks;
+package org.apache.gobblin.runtime.locks;
import java.io.IOException;
@@ -24,8 +24,8 @@ import com.google.common.base.Optional;
import com.typesafe.config.Config;
import com.typesafe.config.ConfigFactory;
-import gobblin.annotation.Alias;
-import gobblin.runtime.instance.hadoop.HadoopConfigLoader;
+import org.apache.gobblin.annotation.Alias;
+import org.apache.gobblin.runtime.instance.hadoop.HadoopConfigLoader;
/**
* Manages instances of {@link FileBasedJobLockFactory}.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/JobLock.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/JobLock.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/JobLock.java
index 9b649d2..e4ee41c 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/JobLock.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/JobLock.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.locks;
+package org.apache.gobblin.runtime.locks;
import java.io.Closeable;
import java.util.Properties;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/JobLockEventListener.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/JobLockEventListener.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/JobLockEventListener.java
index b9a83bc..9050604 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/JobLockEventListener.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/JobLockEventListener.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.locks;
+package org.apache.gobblin.runtime.locks;
/**
* The listener for lock events.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/JobLockException.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/JobLockException.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/JobLockException.java
index d2af9c8..dd967e6 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/JobLockException.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/JobLockException.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.locks;
+package org.apache.gobblin.runtime.locks;
/**
* The exception thrown when a {@link JobLock} cannot be initialized, acquired,
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/JobLockFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/JobLockFactory.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/JobLockFactory.java
index a584b50..238a809 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/JobLockFactory.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/JobLockFactory.java
@@ -14,12 +14,12 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.runtime.locks;
+package org.apache.gobblin.runtime.locks;
import java.io.Closeable;
import java.util.concurrent.TimeoutException;
-import gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.api.JobSpec;
/**
* A factory for locks keyed on {@link JobSpec} . Typical usecase is to prevent the same job being
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/JobLockFactoryManager.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/JobLockFactoryManager.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/JobLockFactoryManager.java
index 716988e..b760b01 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/JobLockFactoryManager.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/JobLockFactoryManager.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.runtime.locks;
+package org.apache.gobblin.runtime.locks;
import org.slf4j.Logger;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/LegacyJobLockFactoryManager.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/LegacyJobLockFactoryManager.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/LegacyJobLockFactoryManager.java
index a557403..7586c21 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/LegacyJobLockFactoryManager.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/LegacyJobLockFactoryManager.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.locks;
+package org.apache.gobblin.runtime.locks;
import java.lang.reflect.InvocationTargetException;
import java.util.Properties;
@@ -24,7 +24,7 @@ import org.apache.commons.lang3.reflect.ConstructorUtils;
import com.google.common.base.Preconditions;
-import gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.ConfigurationKeys;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/ListenableJobLock.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/ListenableJobLock.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/ListenableJobLock.java
index 40d15e8..347b9f2 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/ListenableJobLock.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/ListenableJobLock.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.runtime.locks;
+package org.apache.gobblin.runtime.locks;
public interface ListenableJobLock extends JobLock {
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/ZookeeperBasedJobLock.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/ZookeeperBasedJobLock.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/ZookeeperBasedJobLock.java
index fbf154e..75fcd08 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/ZookeeperBasedJobLock.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/ZookeeperBasedJobLock.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.locks;
+package org.apache.gobblin.runtime.locks;
import java.io.IOException;
import java.nio.file.Paths;
@@ -35,7 +35,7 @@ import org.apache.curator.retry.ExponentialBackoffRetry;
import com.google.common.collect.Maps;
-import gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.ConfigurationKeys;
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/mapreduce/CliMRJobLauncher.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/CliMRJobLauncher.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/CliMRJobLauncher.java
index 45d1b78..a12d4a2 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/CliMRJobLauncher.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/CliMRJobLauncher.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.mapreduce;
+package org.apache.gobblin.runtime.mapreduce;
import java.io.IOException;
import java.util.Properties;
@@ -31,13 +31,13 @@ import org.apache.hadoop.util.ToolRunner;
import com.google.common.io.Closer;
-import gobblin.runtime.JobException;
-import gobblin.runtime.JobLauncher;
-import gobblin.runtime.app.ApplicationException;
-import gobblin.runtime.app.ApplicationLauncher;
-import gobblin.runtime.app.ServiceBasedAppLauncher;
-import gobblin.runtime.cli.CliOptions;
-import gobblin.runtime.listeners.JobListener;
+import org.apache.gobblin.runtime.JobException;
+import org.apache.gobblin.runtime.JobLauncher;
+import org.apache.gobblin.runtime.app.ApplicationException;
+import org.apache.gobblin.runtime.app.ApplicationLauncher;
+import org.apache.gobblin.runtime.app.ServiceBasedAppLauncher;
+import org.apache.gobblin.runtime.cli.CliOptions;
+import org.apache.gobblin.runtime.listeners.JobListener;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/GobblinOutputCommitter.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/GobblinOutputCommitter.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/GobblinOutputCommitter.java
index 2aa4f50..9139f5b 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/GobblinOutputCommitter.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/GobblinOutputCommitter.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.mapreduce;
+package org.apache.gobblin.runtime.mapreduce;
import java.io.DataInputStream;
import java.io.IOException;
@@ -38,14 +38,14 @@ import org.slf4j.LoggerFactory;
import com.google.common.io.Closer;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.runtime.AbstractJobLauncher;
-import gobblin.runtime.GobblinMultiTaskAttempt;
-import gobblin.runtime.listeners.JobListener;
-import gobblin.source.workunit.MultiWorkUnit;
-import gobblin.source.workunit.WorkUnit;
-import gobblin.util.JobLauncherUtils;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.runtime.AbstractJobLauncher;
+import org.apache.gobblin.runtime.GobblinMultiTaskAttempt;
+import org.apache.gobblin.runtime.listeners.JobListener;
+import org.apache.gobblin.source.workunit.MultiWorkUnit;
+import org.apache.gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.util.JobLauncherUtils;
import lombok.Getter;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/GobblinOutputFormat.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/GobblinOutputFormat.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/GobblinOutputFormat.java
index 2c2c62a..a573041 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/GobblinOutputFormat.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/GobblinOutputFormat.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.mapreduce;
+package org.apache.gobblin.runtime.mapreduce;
import org.apache.hadoop.io.NullWritable;
import org.apache.hadoop.mapreduce.OutputCommitter;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/GobblinWorkUnitsInputFormat.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/GobblinWorkUnitsInputFormat.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/GobblinWorkUnitsInputFormat.java
index 47fc28f..90ad672 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/GobblinWorkUnitsInputFormat.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/GobblinWorkUnitsInputFormat.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.mapreduce;
+package org.apache.gobblin.runtime.mapreduce;
import java.io.DataInput;
import java.io.DataOutput;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncher.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncher.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncher.java
index ae06e0c..c94577c 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncher.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncher.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.mapreduce;
+package org.apache.gobblin.runtime.mapreduce;
import java.io.DataOutputStream;
import java.io.FileInputStream;
@@ -56,36 +56,36 @@ import com.google.common.io.Closer;
import com.google.common.util.concurrent.ServiceManager;
import com.typesafe.config.ConfigFactory;
-import gobblin.broker.gobblin_scopes.GobblinScopeTypes;
-import gobblin.broker.gobblin_scopes.JobScopeInstance;
-import gobblin.broker.SharedResourcesBrokerFactory;
-import gobblin.broker.iface.SharedResourcesBroker;
-import gobblin.commit.CommitStep;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.metastore.FsStateStore;
-import gobblin.metastore.StateStore;
-import gobblin.metrics.GobblinMetrics;
-import gobblin.metrics.Tag;
-import gobblin.metrics.event.TimingEvent;
-import gobblin.password.PasswordManager;
-import gobblin.runtime.AbstractJobLauncher;
-import gobblin.runtime.GobblinMultiTaskAttempt;
-import gobblin.runtime.JobLauncher;
-import gobblin.runtime.JobState;
-import gobblin.runtime.Task;
-import gobblin.runtime.TaskExecutor;
-import gobblin.runtime.TaskState;
-import gobblin.runtime.TaskStateCollectorService;
-import gobblin.runtime.TaskStateTracker;
-import gobblin.runtime.util.JobMetrics;
-import gobblin.runtime.util.MetricGroup;
-import gobblin.source.workunit.MultiWorkUnit;
-import gobblin.source.workunit.WorkUnit;
-import gobblin.util.HadoopUtils;
-import gobblin.util.JobConfigurationUtils;
-import gobblin.util.JobLauncherUtils;
-import gobblin.util.ParallelRunner;
-import gobblin.util.SerializationUtils;
+import org.apache.gobblin.broker.gobblin_scopes.GobblinScopeTypes;
+import org.apache.gobblin.broker.gobblin_scopes.JobScopeInstance;
+import org.apache.gobblin.broker.SharedResourcesBrokerFactory;
+import org.apache.gobblin.broker.iface.SharedResourcesBroker;
+import org.apache.gobblin.commit.CommitStep;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.metastore.FsStateStore;
+import org.apache.gobblin.metastore.StateStore;
+import org.apache.gobblin.metrics.GobblinMetrics;
+import org.apache.gobblin.metrics.Tag;
+import org.apache.gobblin.metrics.event.TimingEvent;
+import org.apache.gobblin.password.PasswordManager;
+import org.apache.gobblin.runtime.AbstractJobLauncher;
+import org.apache.gobblin.runtime.GobblinMultiTaskAttempt;
+import org.apache.gobblin.runtime.JobLauncher;
+import org.apache.gobblin.runtime.JobState;
+import org.apache.gobblin.runtime.Task;
+import org.apache.gobblin.runtime.TaskExecutor;
+import org.apache.gobblin.runtime.TaskState;
+import org.apache.gobblin.runtime.TaskStateCollectorService;
+import org.apache.gobblin.runtime.TaskStateTracker;
+import org.apache.gobblin.runtime.util.JobMetrics;
+import org.apache.gobblin.runtime.util.MetricGroup;
+import org.apache.gobblin.source.workunit.MultiWorkUnit;
+import org.apache.gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.util.HadoopUtils;
+import org.apache.gobblin.util.JobConfigurationUtils;
+import org.apache.gobblin.util.JobLauncherUtils;
+import org.apache.gobblin.util.ParallelRunner;
+import org.apache.gobblin.util.SerializationUtils;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRTask.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRTask.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRTask.java
index bca6d24..98256fe 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRTask.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRTask.java
@@ -15,14 +15,14 @@
* limitations under the License.
*/
-package gobblin.runtime.mapreduce;
+package org.apache.gobblin.runtime.mapreduce;
import com.google.common.collect.Maps;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.metrics.event.EventSubmitter;
-import gobblin.runtime.TaskContext;
-import gobblin.runtime.task.BaseAbstractTask;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.metrics.event.EventSubmitter;
+import org.apache.gobblin.runtime.TaskContext;
+import org.apache.gobblin.runtime.task.BaseAbstractTask;
import java.io.IOException;
import java.util.Map;
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/mapreduce/MRTaskFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRTaskFactory.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRTaskFactory.java
index eb8ba01..13670f0 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRTaskFactory.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRTaskFactory.java
@@ -15,14 +15,14 @@
* limitations under the License.
*/
-package gobblin.runtime.mapreduce;
+package org.apache.gobblin.runtime.mapreduce;
-import gobblin.publisher.DataPublisher;
-import gobblin.publisher.NoopPublisher;
-import gobblin.runtime.JobState;
-import gobblin.runtime.TaskContext;
-import gobblin.runtime.task.TaskFactory;
-import gobblin.runtime.task.TaskIFace;
+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.runtime.task.TaskFactory;
+import org.apache.gobblin.runtime.task.TaskIFace;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRTaskStateTracker.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRTaskStateTracker.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRTaskStateTracker.java
index 08b74a1..37d3dea 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRTaskStateTracker.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRTaskStateTracker.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.mapreduce;
+package org.apache.gobblin.runtime.mapreduce;
import java.util.Map;
import java.util.concurrent.RejectedExecutionException;
@@ -31,13 +31,13 @@ import com.codahale.metrics.Counter;
import com.codahale.metrics.Metric;
import com.codahale.metrics.MetricFilter;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.metrics.GobblinMetrics;
-import gobblin.runtime.AbstractTaskStateTracker;
-import gobblin.runtime.Task;
-import gobblin.runtime.util.JobMetrics;
-import gobblin.runtime.util.MetricGroup;
-import gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.metrics.GobblinMetrics;
+import org.apache.gobblin.runtime.AbstractTaskStateTracker;
+import org.apache.gobblin.runtime.Task;
+import org.apache.gobblin.runtime.util.JobMetrics;
+import org.apache.gobblin.runtime.util.MetricGroup;
+import org.apache.gobblin.source.workunit.WorkUnit;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/metrics/RuntimeMetrics.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/metrics/RuntimeMetrics.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/metrics/RuntimeMetrics.java
index 7f870c2..eca80aa 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/metrics/RuntimeMetrics.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/metrics/RuntimeMetrics.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.metrics;
+package org.apache.gobblin.runtime.metrics;
/**
* Constants used for naming {@link gobblin.metrics.Metric}s and metric metadata in gobblin-runtime.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/plugins/GobblinInstancePluginUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/plugins/GobblinInstancePluginUtils.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/plugins/GobblinInstancePluginUtils.java
index 7599122..a6ddcd8 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/plugins/GobblinInstancePluginUtils.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/plugins/GobblinInstancePluginUtils.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.plugins;
+package org.apache.gobblin.runtime.plugins;
import java.util.Collection;
import java.util.List;
@@ -24,8 +24,8 @@ import com.google.common.base.Splitter;
import com.google.common.collect.Lists;
import com.typesafe.config.Config;
-import gobblin.runtime.api.GobblinInstancePluginFactory;
-import gobblin.util.ClassAliasResolver;
+import org.apache.gobblin.runtime.api.GobblinInstancePluginFactory;
+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/plugins/PluginStaticKeys.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/plugins/PluginStaticKeys.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/plugins/PluginStaticKeys.java
index eb20046..937e195 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/plugins/PluginStaticKeys.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/plugins/PluginStaticKeys.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.plugins;
+package org.apache.gobblin.runtime.plugins;
/**
* Static keys for {@link gobblin.runtime.api.GobblinInstancePlugin}s.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/plugins/email/EmailNotificationPlugin.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/plugins/email/EmailNotificationPlugin.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/plugins/email/EmailNotificationPlugin.java
index 14278bc..3cfc67b 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/plugins/email/EmailNotificationPlugin.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/plugins/email/EmailNotificationPlugin.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.runtime.plugins.email;
+package org.apache.gobblin.runtime.plugins.email;
import java.net.URI;
@@ -22,20 +22,20 @@ import org.apache.commons.mail.EmailException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.JobState.RunningState;
-import gobblin.runtime.api.GobblinInstanceDriver;
-import gobblin.runtime.api.GobblinInstancePlugin;
-import gobblin.runtime.api.GobblinInstancePluginFactory;
-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 gobblin.runtime.instance.StandardGobblinInstanceDriver;
-import gobblin.runtime.instance.plugin.BaseIdlePluginImpl;
-import gobblin.util.ConfigUtils;
-import gobblin.util.EmailUtils;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.JobState.RunningState;
+import org.apache.gobblin.runtime.api.GobblinInstanceDriver;
+import org.apache.gobblin.runtime.api.GobblinInstancePlugin;
+import org.apache.gobblin.runtime.api.GobblinInstancePluginFactory;
+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 org.apache.gobblin.runtime.instance.StandardGobblinInstanceDriver;
+import org.apache.gobblin.runtime.instance.plugin.BaseIdlePluginImpl;
+import org.apache.gobblin.util.ConfigUtils;
+import org.apache.gobblin.util.EmailUtils;
/**
* A plugin that attaches an email notification listener to a {@link GobblinInstanceDriver}. The listener sends emails
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/plugins/metrics/GobblinMetricsPlugin.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/plugins/metrics/GobblinMetricsPlugin.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/plugins/metrics/GobblinMetricsPlugin.java
index dc9080f..1861070 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/plugins/metrics/GobblinMetricsPlugin.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/plugins/metrics/GobblinMetricsPlugin.java
@@ -15,14 +15,14 @@
* limitations under the License.
*/
-package gobblin.runtime.plugins.metrics;
-
-import gobblin.annotation.Alias;
-import gobblin.metrics.GobblinMetrics;
-import gobblin.runtime.api.GobblinInstanceDriver;
-import gobblin.runtime.api.GobblinInstancePlugin;
-import gobblin.runtime.api.GobblinInstancePluginFactory;
-import gobblin.runtime.instance.plugin.BaseIdlePluginImpl;
+package org.apache.gobblin.runtime.plugins.metrics;
+
+import org.apache.gobblin.annotation.Alias;
+import org.apache.gobblin.metrics.GobblinMetrics;
+import org.apache.gobblin.runtime.api.GobblinInstanceDriver;
+import org.apache.gobblin.runtime.api.GobblinInstancePlugin;
+import org.apache.gobblin.runtime.api.GobblinInstancePluginFactory;
+import org.apache.gobblin.runtime.instance.plugin.BaseIdlePluginImpl;
/**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/scheduler/AbstractJobSpecScheduler.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/scheduler/AbstractJobSpecScheduler.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/scheduler/AbstractJobSpecScheduler.java
index e7ece9b..d76073d 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/scheduler/AbstractJobSpecScheduler.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/scheduler/AbstractJobSpecScheduler.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.runtime.scheduler;
+package org.apache.gobblin.runtime.scheduler;
import java.io.IOException;
import java.net.URI;
@@ -31,10 +31,10 @@ import com.google.common.base.Optional;
import com.google.common.base.Preconditions;
import com.google.common.util.concurrent.AbstractIdleService;
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.api.JobSpecSchedule;
-import gobblin.runtime.api.JobSpecScheduler;
-import gobblin.runtime.api.JobSpecSchedulerListener;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.api.JobSpecSchedule;
+import org.apache.gobblin.runtime.api.JobSpecScheduler;
+import org.apache.gobblin.runtime.api.JobSpecSchedulerListener;
/**
* A base implementation of {@link JobSpecScheduler} that keeps track of {@link JobSpecSchedule}s
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/scheduler/DefaultJobSpecSchedulerListenerImpl.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/scheduler/DefaultJobSpecSchedulerListenerImpl.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/scheduler/DefaultJobSpecSchedulerListenerImpl.java
index d8606d7..529a400 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/scheduler/DefaultJobSpecSchedulerListenerImpl.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/scheduler/DefaultJobSpecSchedulerListenerImpl.java
@@ -14,15 +14,15 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.runtime.scheduler;
+package org.apache.gobblin.runtime.scheduler;
import org.slf4j.Logger;
import com.google.common.base.Optional;
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.api.JobSpecSchedule;
-import gobblin.runtime.api.JobSpecSchedulerListener;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.api.JobSpecSchedule;
+import org.apache.gobblin.runtime.api.JobSpecSchedulerListener;
/**
* Default no-op implementation for {@link JobSpecSchedulerListener}. It may optionally log
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/scheduler/ImmediateJobSpecScheduler.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/scheduler/ImmediateJobSpecScheduler.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/scheduler/ImmediateJobSpecScheduler.java
index 163864d..9ddd245 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/scheduler/ImmediateJobSpecScheduler.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/scheduler/ImmediateJobSpecScheduler.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.runtime.scheduler;
+package org.apache.gobblin.runtime.scheduler;
import java.util.concurrent.ThreadFactory;
@@ -23,11 +23,11 @@ import org.slf4j.Logger;
import com.google.common.base.Optional;
import com.google.common.util.concurrent.ThreadFactoryBuilder;
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.api.JobSpecSchedule;
-import gobblin.runtime.api.JobSpecScheduler;
-import gobblin.runtime.std.DefaultJobSpecScheduleImpl;
-import gobblin.util.LoggingUncaughtExceptionHandler;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.api.JobSpecSchedule;
+import org.apache.gobblin.runtime.api.JobSpecScheduler;
+import org.apache.gobblin.runtime.std.DefaultJobSpecScheduleImpl;
+import org.apache.gobblin.util.LoggingUncaughtExceptionHandler;
/**
* A simple implementation of a {@link JobSpecScheduler} which schedules the job immediately.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/scheduler/JobSpecSchedulerListeners.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/scheduler/JobSpecSchedulerListeners.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/scheduler/JobSpecSchedulerListeners.java
index 71a1565..a8850eb 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/scheduler/JobSpecSchedulerListeners.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/scheduler/JobSpecSchedulerListeners.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.runtime.scheduler;
+package org.apache.gobblin.runtime.scheduler;
import java.io.Closeable;
import java.io.IOException;
@@ -25,11 +25,11 @@ import org.slf4j.Logger;
import com.google.common.base.Optional;
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.api.JobSpecSchedule;
-import gobblin.runtime.api.JobSpecSchedulerListener;
-import gobblin.runtime.api.JobSpecSchedulerListenersContainer;
-import gobblin.util.callbacks.CallbacksDispatcher;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.api.JobSpecSchedule;
+import org.apache.gobblin.runtime.api.JobSpecSchedulerListener;
+import org.apache.gobblin.runtime.api.JobSpecSchedulerListenersContainer;
+import org.apache.gobblin.util.callbacks.CallbacksDispatcher;
/**
* Manages a list of {@link JobSpecSchedulerListener}s and can dispatch callbacks to them.
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/scheduler/QuartzJobSpecScheduler.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/scheduler/QuartzJobSpecScheduler.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/scheduler/QuartzJobSpecScheduler.java
index dc644a2..909a6d1 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/scheduler/QuartzJobSpecScheduler.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/scheduler/QuartzJobSpecScheduler.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package gobblin.runtime.scheduler;
+package org.apache.gobblin.runtime.scheduler;
import java.util.Date;
import java.util.concurrent.TimeUnit;
@@ -42,13 +42,13 @@ import com.google.common.collect.ImmutableMap;
import com.typesafe.config.Config;
import com.typesafe.config.ConfigFactory;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.api.GobblinInstanceEnvironment;
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.api.JobSpecSchedule;
-import gobblin.runtime.api.JobSpecScheduler;
-import gobblin.scheduler.SchedulerService;
-import gobblin.util.service.StandardServiceConfig;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.api.GobblinInstanceEnvironment;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.api.JobSpecSchedule;
+import org.apache.gobblin.runtime.api.JobSpecScheduler;
+import org.apache.gobblin.scheduler.SchedulerService;
+import org.apache.gobblin.util.service.StandardServiceConfig;
import lombok.Data;
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/services/JMXReportingService.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/services/JMXReportingService.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/services/JMXReportingService.java
index 93c765a..2f3800b 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/services/JMXReportingService.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/services/JMXReportingService.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package gobblin.runtime.services;
+package org.apache.gobblin.runtime.services;
import java.util.Map;
import java.util.concurrent.TimeUnit;