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;
