http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/services/MetricsReportingService.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/services/MetricsReportingService.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/services/MetricsReportingService.java index 29b52c5..43b53cd 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/services/MetricsReportingService.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/services/MetricsReportingService.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package gobblin.runtime.services; +package org.apache.gobblin.runtime.services; import java.util.Properties; import com.google.common.util.concurrent.AbstractIdleService; -import gobblin.metrics.GobblinMetrics; +import org.apache.gobblin.metrics.GobblinMetrics; /**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/FlowCatalog.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/FlowCatalog.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/FlowCatalog.java index 633a5af..8abfc42 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/FlowCatalog.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/FlowCatalog.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.spec_catalog; +package org.apache.gobblin.runtime.spec_catalog; import java.io.IOException; import java.lang.reflect.InvocationTargetException; @@ -35,22 +35,22 @@ import com.google.common.util.concurrent.AbstractIdleService; import com.google.common.base.Preconditions; import com.typesafe.config.Config; -import gobblin.configuration.ConfigurationKeys; -import gobblin.instrumented.Instrumented; -import gobblin.runtime.api.GobblinInstanceEnvironment; -import gobblin.annotation.Alpha; -import gobblin.metrics.MetricContext; -import gobblin.metrics.Tag; -import gobblin.runtime.api.FlowSpec; -import gobblin.runtime.api.MutableSpecCatalog; -import gobblin.runtime.api.Spec; -import gobblin.runtime.api.SpecCatalog; -import gobblin.runtime.api.SpecCatalogListener; -import gobblin.runtime.api.SpecNotFoundException; -import gobblin.runtime.api.SpecSerDe; -import gobblin.runtime.api.SpecStore; -import gobblin.runtime.spec_store.FSSpecStore; -import gobblin.util.ClassAliasResolver; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.instrumented.Instrumented; +import org.apache.gobblin.runtime.api.GobblinInstanceEnvironment; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.Tag; +import org.apache.gobblin.runtime.api.FlowSpec; +import org.apache.gobblin.runtime.api.MutableSpecCatalog; +import org.apache.gobblin.runtime.api.Spec; +import org.apache.gobblin.runtime.api.SpecCatalog; +import org.apache.gobblin.runtime.api.SpecCatalogListener; +import org.apache.gobblin.runtime.api.SpecNotFoundException; +import org.apache.gobblin.runtime.api.SpecSerDe; +import org.apache.gobblin.runtime.api.SpecStore; +import org.apache.gobblin.runtime.spec_store.FSSpecStore; +import org.apache.gobblin.util.ClassAliasResolver; @Alpha http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/SpecCatalogListenersList.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/SpecCatalogListenersList.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/SpecCatalogListenersList.java index cbc43ee..cdb9379 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/SpecCatalogListenersList.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/SpecCatalogListenersList.java @@ -49,7 +49,7 @@ * limitations under the License. */ -package gobblin.runtime.spec_catalog; +package org.apache.gobblin.runtime.spec_catalog; import java.io.Closeable; import java.io.IOException; @@ -63,10 +63,10 @@ import com.google.common.base.Function; import com.google.common.base.Optional; import com.google.common.base.Preconditions; -import gobblin.runtime.api.SpecCatalogListener; -import gobblin.runtime.api.SpecCatalogListenersContainer; -import gobblin.runtime.api.Spec; -import gobblin.util.callbacks.CallbacksDispatcher; +import org.apache.gobblin.runtime.api.SpecCatalogListener; +import org.apache.gobblin.runtime.api.SpecCatalogListenersContainer; +import org.apache.gobblin.runtime.api.Spec; +import org.apache.gobblin.util.callbacks.CallbacksDispatcher; public class SpecCatalogListenersList implements SpecCatalogListener, SpecCatalogListenersContainer, Closeable { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/TopologyCatalog.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/TopologyCatalog.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/TopologyCatalog.java index 144bedc..057ef7c 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/TopologyCatalog.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/TopologyCatalog.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.spec_catalog; +package org.apache.gobblin.runtime.spec_catalog; import java.io.IOException; import java.lang.reflect.InvocationTargetException; @@ -36,22 +36,22 @@ import com.google.common.util.concurrent.AbstractIdleService; import com.google.common.util.concurrent.Service; import com.typesafe.config.Config; -import gobblin.annotation.Alpha; -import gobblin.configuration.ConfigurationKeys; -import gobblin.instrumented.Instrumented; -import gobblin.metrics.MetricContext; -import gobblin.metrics.Tag; -import gobblin.runtime.api.GobblinInstanceEnvironment; -import gobblin.runtime.api.MutableSpecCatalog; -import gobblin.runtime.api.Spec; -import gobblin.runtime.api.SpecCatalog; -import gobblin.runtime.api.SpecCatalogListener; -import gobblin.runtime.api.SpecNotFoundException; -import gobblin.runtime.api.SpecSerDe; -import gobblin.runtime.api.SpecStore; -import gobblin.runtime.api.TopologySpec; -import gobblin.runtime.spec_store.FSSpecStore; -import gobblin.util.ClassAliasResolver; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.instrumented.Instrumented; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.Tag; +import org.apache.gobblin.runtime.api.GobblinInstanceEnvironment; +import org.apache.gobblin.runtime.api.MutableSpecCatalog; +import org.apache.gobblin.runtime.api.Spec; +import org.apache.gobblin.runtime.api.SpecCatalog; +import org.apache.gobblin.runtime.api.SpecCatalogListener; +import org.apache.gobblin.runtime.api.SpecNotFoundException; +import org.apache.gobblin.runtime.api.SpecSerDe; +import org.apache.gobblin.runtime.api.SpecStore; +import org.apache.gobblin.runtime.api.TopologySpec; +import org.apache.gobblin.runtime.spec_store.FSSpecStore; +import org.apache.gobblin.util.ClassAliasResolver; @Alpha http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_executorInstance/InMemorySpecExecutorInstanceProducer.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_executorInstance/InMemorySpecExecutorInstanceProducer.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_executorInstance/InMemorySpecExecutorInstanceProducer.java index 91dbc89..77faaa7 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_executorInstance/InMemorySpecExecutorInstanceProducer.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_executorInstance/InMemorySpecExecutorInstanceProducer.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.spec_executorInstance; +package org.apache.gobblin.runtime.spec_executorInstance; import java.io.Serializable; import java.net.URI; @@ -36,11 +36,11 @@ import com.google.common.collect.Lists; import com.google.common.collect.Maps; import com.typesafe.config.Config; -import gobblin.configuration.ConfigurationKeys; -import gobblin.runtime.api.GobblinInstanceEnvironment; -import gobblin.runtime.api.Spec; -import gobblin.runtime.api.SpecExecutorInstanceProducer; -import gobblin.util.CompletedFuture; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.runtime.api.GobblinInstanceEnvironment; +import org.apache.gobblin.runtime.api.Spec; +import org.apache.gobblin.runtime.api.SpecExecutorInstanceProducer; +import org.apache.gobblin.util.CompletedFuture; public class InMemorySpecExecutorInstanceProducer implements SpecExecutorInstanceProducer<Spec>, Serializable { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_store/FSSpecStore.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_store/FSSpecStore.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_store/FSSpecStore.java index 62bdf21..f852aea 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_store/FSSpecStore.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_store/FSSpecStore.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.spec_store; +package org.apache.gobblin.runtime.spec_store; import java.io.IOException; import java.net.URI; @@ -37,13 +37,13 @@ import com.google.common.base.Preconditions; import com.google.common.collect.Lists; import com.typesafe.config.Config; -import gobblin.configuration.ConfigurationKeys; -import gobblin.runtime.api.GobblinInstanceEnvironment; -import gobblin.runtime.api.Spec; -import gobblin.runtime.api.SpecNotFoundException; -import gobblin.runtime.api.SpecSerDe; -import gobblin.runtime.api.SpecStore; -import gobblin.util.PathUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.runtime.api.GobblinInstanceEnvironment; +import org.apache.gobblin.runtime.api.Spec; +import org.apache.gobblin.runtime.api.SpecNotFoundException; +import org.apache.gobblin.runtime.api.SpecSerDe; +import org.apache.gobblin.runtime.api.SpecStore; +import org.apache.gobblin.util.PathUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultConfigurableImpl.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultConfigurableImpl.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultConfigurableImpl.java index 4e1832b..908e4d1 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultConfigurableImpl.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultConfigurableImpl.java @@ -14,14 +14,14 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.runtime.std; +package org.apache.gobblin.runtime.std; import java.util.Properties; import com.typesafe.config.Config; -import gobblin.runtime.api.Configurable; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.runtime.api.Configurable; +import org.apache.gobblin.util.ConfigUtils; /** * Default immutable implementation for {@link Configurable} interface. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobCatalogListenerImpl.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobCatalogListenerImpl.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobCatalogListenerImpl.java index a5bfdea..1b61c5d 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobCatalogListenerImpl.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobCatalogListenerImpl.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.runtime.std; +package org.apache.gobblin.runtime.std; import java.net.URI; @@ -22,8 +22,8 @@ import org.slf4j.Logger; import com.google.common.base.Optional; -import gobblin.runtime.api.JobCatalogListener; -import gobblin.runtime.api.JobSpec; +import org.apache.gobblin.runtime.api.JobCatalogListener; +import org.apache.gobblin.runtime.api.JobSpec; /** * Default NOOP implementation for {@link JobCatalogListener}. It can log the callbacks. Other http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobExecutionStateListenerImpl.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobExecutionStateListenerImpl.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobExecutionStateListenerImpl.java index 542b14d..7ebc5f4 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobExecutionStateListenerImpl.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobExecutionStateListenerImpl.java @@ -14,15 +14,15 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.runtime.std; +package org.apache.gobblin.runtime.std; import org.slf4j.Logger; import com.google.common.base.Optional; -import gobblin.runtime.JobState.RunningState; -import gobblin.runtime.api.JobExecutionState; -import gobblin.runtime.api.JobExecutionStateListener; +import org.apache.gobblin.runtime.JobState.RunningState; +import org.apache.gobblin.runtime.api.JobExecutionState; +import org.apache.gobblin.runtime.api.JobExecutionStateListener; /** * Default NOOP implementation for a {@link JobExecutionStateListener}. The implementation can http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobLifecycleListenerImpl.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobLifecycleListenerImpl.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobLifecycleListenerImpl.java index 0519c7d..ce1a6cf 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobLifecycleListenerImpl.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobLifecycleListenerImpl.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.runtime.std; +package org.apache.gobblin.runtime.std; import java.net.URI; @@ -22,12 +22,12 @@ import org.slf4j.Logger; import com.google.common.base.Optional; -import gobblin.runtime.JobState.RunningState; -import gobblin.runtime.api.JobExecutionDriver; -import gobblin.runtime.api.JobExecutionState; -import gobblin.runtime.api.JobLifecycleListener; -import gobblin.runtime.api.JobSpec; -import gobblin.runtime.api.JobSpecSchedule; +import org.apache.gobblin.runtime.JobState.RunningState; +import org.apache.gobblin.runtime.api.JobExecutionDriver; +import org.apache.gobblin.runtime.api.JobExecutionState; +import org.apache.gobblin.runtime.api.JobLifecycleListener; +import org.apache.gobblin.runtime.api.JobSpec; +import org.apache.gobblin.runtime.api.JobSpecSchedule; /** * Default NOOP implementation for {@link JobLifecycleListener}. It can log the callbacks. Other http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobSpecScheduleImpl.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobSpecScheduleImpl.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobSpecScheduleImpl.java index d90613e..c5af6e0 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobSpecScheduleImpl.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/DefaultJobSpecScheduleImpl.java @@ -14,12 +14,12 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.runtime.std; +package org.apache.gobblin.runtime.std; import com.google.common.base.Optional; -import gobblin.runtime.api.JobSpec; -import gobblin.runtime.api.JobSpecSchedule; +import org.apache.gobblin.runtime.api.JobSpec; +import org.apache.gobblin.runtime.api.JobSpecSchedule; import lombok.Data; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/FilteredJobLifecycleListener.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/FilteredJobLifecycleListener.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/FilteredJobLifecycleListener.java index 4396cb1..c16425b 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/FilteredJobLifecycleListener.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/FilteredJobLifecycleListener.java @@ -14,18 +14,18 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.runtime.std; +package org.apache.gobblin.runtime.std; import java.net.URI; import com.google.common.base.Predicate; -import gobblin.runtime.JobState.RunningState; -import gobblin.runtime.api.JobExecutionDriver; -import gobblin.runtime.api.JobExecutionState; -import gobblin.runtime.api.JobLifecycleListener; -import gobblin.runtime.api.JobSpec; -import gobblin.runtime.api.JobSpecSchedule; +import org.apache.gobblin.runtime.JobState.RunningState; +import org.apache.gobblin.runtime.api.JobExecutionDriver; +import org.apache.gobblin.runtime.api.JobExecutionState; +import org.apache.gobblin.runtime.api.JobLifecycleListener; +import org.apache.gobblin.runtime.api.JobSpec; +import org.apache.gobblin.runtime.api.JobSpecSchedule; import lombok.AllArgsConstructor; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobExecutionStateListeners.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobExecutionStateListeners.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobExecutionStateListeners.java index 7e97f97..537dd6d 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobExecutionStateListeners.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobExecutionStateListeners.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.runtime.std; +package org.apache.gobblin.runtime.std; import java.io.Closeable; import java.io.IOException; @@ -24,11 +24,11 @@ import org.slf4j.Logger; import com.google.common.base.Optional; -import gobblin.runtime.JobState.RunningState; -import gobblin.runtime.api.JobExecutionState; -import gobblin.runtime.api.JobExecutionStateListener; -import gobblin.runtime.api.JobExecutionStateListenerContainer; -import gobblin.util.callbacks.CallbacksDispatcher; +import org.apache.gobblin.runtime.JobState.RunningState; +import org.apache.gobblin.runtime.api.JobExecutionState; +import org.apache.gobblin.runtime.api.JobExecutionStateListener; +import org.apache.gobblin.runtime.api.JobExecutionStateListenerContainer; +import org.apache.gobblin.util.callbacks.CallbacksDispatcher; /** * A helper class to maintain a list of {@link JobExecutionStateListener} instances. It itself http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobExecutionUpdatable.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobExecutionUpdatable.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobExecutionUpdatable.java index ef1574c..5d97fa0 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobExecutionUpdatable.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobExecutionUpdatable.java @@ -14,15 +14,15 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.runtime.std; +package org.apache.gobblin.runtime.std; import java.net.URI; -import gobblin.annotation.Alpha; -import gobblin.runtime.JobState; -import gobblin.runtime.api.JobExecution; -import gobblin.runtime.api.JobSpec; -import gobblin.util.JobLauncherUtils; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.runtime.JobState; +import org.apache.gobblin.runtime.api.JobExecution; +import org.apache.gobblin.runtime.api.JobSpec; +import org.apache.gobblin.util.JobLauncherUtils; import lombok.AllArgsConstructor; import lombok.Data; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobLifecycleListenersList.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobLifecycleListenersList.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobLifecycleListenersList.java index c46fc1a..8338187 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobLifecycleListenersList.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobLifecycleListenersList.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.runtime.std; +package org.apache.gobblin.runtime.std; import java.io.Closeable; import java.io.IOException; @@ -25,17 +25,17 @@ import org.slf4j.Logger; import com.google.common.base.Optional; -import gobblin.runtime.JobState.RunningState; -import gobblin.runtime.api.JobCatalogListenersContainer; -import gobblin.runtime.api.JobExecutionDriver; -import gobblin.runtime.api.JobExecutionState; -import gobblin.runtime.api.JobExecutionStateListener.MetadataChangeCallback; -import gobblin.runtime.api.JobExecutionStateListener.StageTransitionCallback; -import gobblin.runtime.api.JobExecutionStateListener.StatusChangeCallback; -import gobblin.runtime.api.JobLifecycleListener; -import gobblin.runtime.api.JobLifecycleListenersContainer; -import gobblin.runtime.api.JobSpecSchedulerListenersContainer; -import gobblin.util.callbacks.CallbacksDispatcher; +import org.apache.gobblin.runtime.JobState.RunningState; +import org.apache.gobblin.runtime.api.JobCatalogListenersContainer; +import org.apache.gobblin.runtime.api.JobExecutionDriver; +import org.apache.gobblin.runtime.api.JobExecutionState; +import org.apache.gobblin.runtime.api.JobExecutionStateListener.MetadataChangeCallback; +import org.apache.gobblin.runtime.api.JobExecutionStateListener.StageTransitionCallback; +import org.apache.gobblin.runtime.api.JobExecutionStateListener.StatusChangeCallback; +import org.apache.gobblin.runtime.api.JobLifecycleListener; +import org.apache.gobblin.runtime.api.JobLifecycleListenersContainer; +import org.apache.gobblin.runtime.api.JobSpecSchedulerListenersContainer; +import org.apache.gobblin.util.callbacks.CallbacksDispatcher; /** * A default implementation to manage a list of {@link JobLifecycleListener} http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobSpecFilter.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobSpecFilter.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobSpecFilter.java index 7c6f523..657daf5 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobSpecFilter.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobSpecFilter.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.runtime.std; +package org.apache.gobblin.runtime.std; import java.net.URI; import java.net.URISyntaxException; @@ -24,7 +24,7 @@ import com.google.common.base.Preconditions; import com.google.common.base.Predicate; import com.google.common.base.Predicates; -import gobblin.runtime.api.JobSpec; +import org.apache.gobblin.runtime.api.JobSpec; import lombok.AllArgsConstructor; import lombok.Getter; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/BaseAbstractTask.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/BaseAbstractTask.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/BaseAbstractTask.java index 4cca361..71e2b39 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/BaseAbstractTask.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/BaseAbstractTask.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package gobblin.runtime.task; +package org.apache.gobblin.runtime.task; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.metrics.MetricContext; -import gobblin.runtime.TaskContext; -import gobblin.runtime.util.TaskMetrics; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.runtime.TaskContext; +import org.apache.gobblin.runtime.util.TaskMetrics; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/FailedTask.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/FailedTask.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/FailedTask.java index 6651db4..21dca10 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/FailedTask.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/FailedTask.java @@ -1,11 +1,11 @@ -package gobblin.runtime.task; - -import gobblin.configuration.WorkUnitState; -import gobblin.publisher.DataPublisher; -import gobblin.publisher.NoopPublisher; -import gobblin.runtime.JobState; -import gobblin.runtime.TaskContext; -import gobblin.source.workunit.WorkUnit; +package org.apache.gobblin.runtime.task; + +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.publisher.DataPublisher; +import org.apache.gobblin.publisher.NoopPublisher; +import org.apache.gobblin.runtime.JobState; +import org.apache.gobblin.runtime.TaskContext; +import org.apache.gobblin.source.workunit.WorkUnit; /** * A task which raise an exception when run http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskFactory.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskFactory.java index e3bb83c..2166625 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskFactory.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskFactory.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package gobblin.runtime.task; +package org.apache.gobblin.runtime.task; -import gobblin.publisher.DataPublisher; -import gobblin.runtime.JobState; +import org.apache.gobblin.publisher.DataPublisher; +import org.apache.gobblin.runtime.JobState; -import gobblin.runtime.TaskContext; +import org.apache.gobblin.runtime.TaskContext; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskIFace.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskIFace.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskIFace.java index c98c016..ef416da 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskIFace.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskIFace.java @@ -15,11 +15,11 @@ * limitations under the License. */ -package gobblin.runtime.task; +package org.apache.gobblin.runtime.task; -import gobblin.annotation.Alpha; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskIFaceWrapper.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskIFaceWrapper.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskIFaceWrapper.java index bb0f4d8..6a93f88 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskIFaceWrapper.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskIFaceWrapper.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.task; +package org.apache.gobblin.runtime.task; import java.util.List; import java.util.concurrent.CountDownLatch; @@ -23,13 +23,13 @@ import java.util.concurrent.CountDownLatch; import com.google.common.base.Optional; import com.google.common.collect.Lists; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.runtime.Task; -import gobblin.runtime.TaskContext; -import gobblin.runtime.TaskState; -import gobblin.runtime.TaskStateTracker; -import gobblin.runtime.fork.Fork; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.runtime.Task; +import org.apache.gobblin.runtime.TaskContext; +import org.apache.gobblin.runtime.TaskState; +import org.apache.gobblin.runtime.TaskStateTracker; +import org.apache.gobblin.runtime.fork.Fork; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskUtils.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskUtils.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskUtils.java index b7e44a1..8df7a0b 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskUtils.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskUtils.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package gobblin.runtime.task; +package org.apache.gobblin.runtime.task; import com.google.common.base.Optional; -import gobblin.configuration.State; +import org.apache.gobblin.configuration.State; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/HOCONInputStreamJobTemplate.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/HOCONInputStreamJobTemplate.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/HOCONInputStreamJobTemplate.java index 7a6d2b5..c792d7b 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/HOCONInputStreamJobTemplate.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/HOCONInputStreamJobTemplate.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.template; +package org.apache.gobblin.runtime.template; import java.io.InputStream; import java.io.InputStreamReader; @@ -26,10 +26,10 @@ import com.google.common.base.Charsets; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.configuration.ConfigurationKeys; -import gobblin.runtime.api.GobblinInstanceDriver; -import gobblin.runtime.api.JobCatalogWithTemplates; -import gobblin.runtime.api.SpecNotFoundException; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.runtime.api.GobblinInstanceDriver; +import org.apache.gobblin.runtime.api.JobCatalogWithTemplates; +import org.apache.gobblin.runtime.api.SpecNotFoundException; import lombok.extern.slf4j.Slf4j; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/InheritingJobTemplate.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/InheritingJobTemplate.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/InheritingJobTemplate.java index c91bcab..d542ed5 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/InheritingJobTemplate.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/InheritingJobTemplate.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.template; +package org.apache.gobblin.runtime.template; import java.net.URI; import java.util.Collection; @@ -30,9 +30,9 @@ import com.google.common.collect.Maps; import com.google.common.collect.Sets; import com.typesafe.config.Config; -import gobblin.runtime.api.JobCatalogWithTemplates; -import gobblin.runtime.api.JobTemplate; -import gobblin.runtime.api.SpecNotFoundException; +import org.apache.gobblin.runtime.api.JobCatalogWithTemplates; +import org.apache.gobblin.runtime.api.JobTemplate; +import org.apache.gobblin.runtime.api.SpecNotFoundException; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/PullFileToConfigConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/PullFileToConfigConverter.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/PullFileToConfigConverter.java index cc7c38e..5bba8d8 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/PullFileToConfigConverter.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/PullFileToConfigConverter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.template; +package org.apache.gobblin.runtime.template; import java.io.File; import java.io.IOException; @@ -38,13 +38,13 @@ import com.typesafe.config.ConfigFactory; import com.typesafe.config.ConfigRenderOptions; import com.typesafe.config.ConfigResolveOptions; -import gobblin.configuration.ConfigurationKeys; -import gobblin.runtime.api.JobTemplate; -import gobblin.runtime.api.SpecNotFoundException; -import gobblin.runtime.job_catalog.PackagedTemplatesJobCatalogDecorator; -import gobblin.util.ConfigUtils; -import gobblin.util.PathUtils; -import gobblin.util.PullFileLoader; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.runtime.api.JobTemplate; +import org.apache.gobblin.runtime.api.SpecNotFoundException; +import org.apache.gobblin.runtime.job_catalog.PackagedTemplatesJobCatalogDecorator; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.util.PathUtils; +import org.apache.gobblin.util.PullFileLoader; import lombok.Data; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/ResourceBasedJobTemplate.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/ResourceBasedJobTemplate.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/ResourceBasedJobTemplate.java index e1bd7c7..5fab14a 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/ResourceBasedJobTemplate.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/ResourceBasedJobTemplate.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.template; +package org.apache.gobblin.runtime.template; import java.io.IOException; import java.io.InputStream; @@ -25,9 +25,9 @@ import java.net.URISyntaxException; import com.google.common.base.Preconditions; import com.google.common.base.Strings; -import gobblin.runtime.api.JobCatalogWithTemplates; -import gobblin.runtime.api.SpecNotFoundException; -import gobblin.runtime.job_catalog.PackagedTemplatesJobCatalogDecorator; +import org.apache.gobblin.runtime.api.JobCatalogWithTemplates; +import org.apache.gobblin.runtime.api.SpecNotFoundException; +import org.apache.gobblin.runtime.job_catalog.PackagedTemplatesJobCatalogDecorator; import lombok.extern.slf4j.Slf4j; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/StaticJobTemplate.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/StaticJobTemplate.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/StaticJobTemplate.java index 683cbc8..c370c62 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/StaticJobTemplate.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/StaticJobTemplate.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.template; +package org.apache.gobblin.runtime.template; import java.net.URI; import java.net.URISyntaxException; @@ -31,12 +31,12 @@ import com.google.common.collect.Sets; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.configuration.ConfigurationKeys; -import gobblin.runtime.api.GobblinInstanceDriver; -import gobblin.runtime.api.JobCatalog; -import gobblin.runtime.api.JobCatalogWithTemplates; -import gobblin.runtime.api.JobTemplate; -import gobblin.runtime.api.SpecNotFoundException; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.runtime.api.GobblinInstanceDriver; +import org.apache.gobblin.runtime.api.JobCatalog; +import org.apache.gobblin.runtime.api.JobCatalogWithTemplates; +import org.apache.gobblin.runtime.api.JobTemplate; +import org.apache.gobblin.runtime.api.SpecNotFoundException; import lombok.Getter; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/ClustersNames.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/ClustersNames.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/ClustersNames.java index 838a595..8d19028 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/ClustersNames.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/ClustersNames.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.runtime.util; +package org.apache.gobblin.runtime.util; /** * Allows conversion of URLs identifying a Hadoop cluster (e.g. resource manager url or http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/JobMetrics.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/JobMetrics.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/JobMetrics.java index 86755a3..102885c 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/JobMetrics.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/JobMetrics.java @@ -15,20 +15,20 @@ * limitations under the License. */ -package gobblin.runtime.util; +package org.apache.gobblin.runtime.util; import java.util.List; import java.util.concurrent.Callable; import com.google.common.collect.Lists; -import gobblin.metrics.GobblinMetrics; -import gobblin.metrics.MetricContext; -import gobblin.metrics.Tag; -import gobblin.metrics.event.JobEvent; -import gobblin.runtime.JobState; -import gobblin.runtime.TaskState; -import gobblin.util.ClustersNames; +import org.apache.gobblin.metrics.GobblinMetrics; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.Tag; +import org.apache.gobblin.metrics.event.JobEvent; +import org.apache.gobblin.runtime.JobState; +import org.apache.gobblin.runtime.TaskState; +import org.apache.gobblin.util.ClustersNames; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/JobStateToJsonConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/JobStateToJsonConverter.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/JobStateToJsonConverter.java index 765d553..8497350 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/JobStateToJsonConverter.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/JobStateToJsonConverter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.util; +package org.apache.gobblin.runtime.util; import java.io.BufferedWriter; import java.io.FileOutputStream; @@ -42,11 +42,11 @@ import org.slf4j.LoggerFactory; import com.google.common.io.Closer; import com.google.gson.stream.JsonWriter; -import gobblin.configuration.ConfigurationKeys; -import gobblin.metastore.StateStore; -import gobblin.runtime.FsDatasetStateStore; -import gobblin.runtime.JobState; -import gobblin.util.JobConfigurationUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.metastore.StateStore; +import org.apache.gobblin.runtime.FsDatasetStateStore; +import org.apache.gobblin.runtime.JobState; +import org.apache.gobblin.util.JobConfigurationUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/MetricGroup.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/MetricGroup.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/MetricGroup.java index 6551a37..8fa817d 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/MetricGroup.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/MetricGroup.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.util; +package org.apache.gobblin.runtime.util; /** * Enumeration of metric groups used internally. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/MultiWorkUnitUnpackingIterator.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/MultiWorkUnitUnpackingIterator.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/MultiWorkUnitUnpackingIterator.java index d43b770..38e4ce7 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/MultiWorkUnitUnpackingIterator.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/MultiWorkUnitUnpackingIterator.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package gobblin.runtime.util; +package org.apache.gobblin.runtime.util; import java.util.Iterator; -import gobblin.source.workunit.MultiWorkUnit; -import gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.source.workunit.MultiWorkUnit; +import org.apache.gobblin.source.workunit.WorkUnit; import lombok.RequiredArgsConstructor; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/RuntimeConstructs.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/RuntimeConstructs.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/RuntimeConstructs.java index 17c8d8c..5060bac 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/RuntimeConstructs.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/RuntimeConstructs.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.runtime.util; +package org.apache.gobblin.runtime.util; -import gobblin.runtime.fork.Fork; +import org.apache.gobblin.runtime.fork.Fork; public enum RuntimeConstructs { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/StateStores.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/StateStores.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/StateStores.java index 6a4cf98..311a76a 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/StateStores.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/StateStores.java @@ -14,17 +14,17 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.runtime.util; +package org.apache.gobblin.runtime.util; import com.typesafe.config.Config; import com.typesafe.config.ConfigValueFactory; -import gobblin.configuration.ConfigurationKeys; -import gobblin.metastore.StateStore; -import gobblin.runtime.TaskState; -import gobblin.source.workunit.MultiWorkUnit; -import gobblin.source.workunit.WorkUnit; -import gobblin.util.ClassAliasResolver; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.metastore.StateStore; +import org.apache.gobblin.runtime.TaskState; +import org.apache.gobblin.source.workunit.MultiWorkUnit; +import org.apache.gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.util.ClassAliasResolver; +import org.apache.gobblin.util.ConfigUtils; import org.apache.hadoop.fs.Path; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/TaskMetrics.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/TaskMetrics.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/TaskMetrics.java index 60f8227..982b381 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/TaskMetrics.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/TaskMetrics.java @@ -15,19 +15,19 @@ * limitations under the License. */ -package gobblin.runtime.util; +package org.apache.gobblin.runtime.util; import java.util.List; import java.util.concurrent.Callable; import com.google.common.collect.Lists; -import gobblin.configuration.ConfigurationKeys; -import gobblin.metrics.GobblinMetrics; -import gobblin.metrics.MetricContext; -import gobblin.metrics.Tag; -import gobblin.metrics.event.TaskEvent; -import gobblin.runtime.TaskState; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.metrics.GobblinMetrics; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.Tag; +import org.apache.gobblin.metrics.event.TaskEvent; +import org.apache.gobblin.runtime.TaskState; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/BaseGobblinJob.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/BaseGobblinJob.java b/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/BaseGobblinJob.java index 54f468d..83b17c0 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/BaseGobblinJob.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/BaseGobblinJob.java @@ -9,7 +9,7 @@ * under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR * CONDITIONS OF ANY KIND, either express or implied. */ -package gobblin.scheduler; +package org.apache.gobblin.scheduler; import org.quartz.*; import org.slf4j.MDC; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/JobScheduler.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/JobScheduler.java b/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/JobScheduler.java index 2736637..0772d60 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/JobScheduler.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/JobScheduler.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.scheduler; +package org.apache.gobblin.scheduler; import java.io.Closeable; import java.io.IOException; @@ -61,16 +61,16 @@ import com.google.common.util.concurrent.AbstractIdleService; import lombok.extern.slf4j.Slf4j; -import gobblin.configuration.ConfigurationKeys; -import gobblin.runtime.JobException; -import gobblin.runtime.JobLauncher; -import gobblin.runtime.JobLauncherFactory; -import gobblin.runtime.listeners.EmailNotificationJobListener; -import gobblin.runtime.listeners.JobListener; -import gobblin.runtime.listeners.RunOnceJobListener; -import gobblin.util.ExecutorsUtils; -import gobblin.util.SchedulerUtils; -import gobblin.util.filesystem.PathAlterationObserverScheduler; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.runtime.JobException; +import org.apache.gobblin.runtime.JobLauncher; +import org.apache.gobblin.runtime.JobLauncherFactory; +import org.apache.gobblin.runtime.listeners.EmailNotificationJobListener; +import org.apache.gobblin.runtime.listeners.JobListener; +import org.apache.gobblin.runtime.listeners.RunOnceJobListener; +import org.apache.gobblin.util.ExecutorsUtils; +import org.apache.gobblin.util.SchedulerUtils; +import org.apache.gobblin.util.filesystem.PathAlterationObserverScheduler; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/PathAlterationListenerAdaptorForMonitor.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/PathAlterationListenerAdaptorForMonitor.java b/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/PathAlterationListenerAdaptorForMonitor.java index d2124e9..0b705e0 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/PathAlterationListenerAdaptorForMonitor.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/PathAlterationListenerAdaptorForMonitor.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.scheduler; +package org.apache.gobblin.scheduler; import java.io.IOException; import java.util.Map; @@ -30,13 +30,13 @@ import org.slf4j.LoggerFactory; import com.google.common.collect.Maps; -import gobblin.configuration.ConfigurationKeys; -import gobblin.runtime.JobException; -import gobblin.runtime.listeners.EmailNotificationJobListener; -import gobblin.runtime.listeners.RunOnceJobListener; -import gobblin.util.PathUtils; -import gobblin.util.SchedulerUtils; -import gobblin.util.filesystem.PathAlterationListenerAdaptor; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.runtime.JobException; +import org.apache.gobblin.runtime.listeners.EmailNotificationJobListener; +import org.apache.gobblin.runtime.listeners.RunOnceJobListener; +import org.apache.gobblin.util.PathUtils; +import org.apache.gobblin.util.SchedulerUtils; +import org.apache.gobblin.util.filesystem.PathAlterationListenerAdaptor; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/SchedulerDaemon.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/SchedulerDaemon.java b/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/SchedulerDaemon.java index 93dc891..83b2852 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/SchedulerDaemon.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/SchedulerDaemon.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.scheduler; +package org.apache.gobblin.scheduler; import java.util.Properties; import java.util.UUID; @@ -25,8 +25,8 @@ import org.apache.commons.configuration.PropertiesConfiguration; import lombok.extern.slf4j.Slf4j; -import gobblin.runtime.app.ServiceBasedAppLauncher; -import gobblin.util.PropertiesUtils; +import org.apache.gobblin.runtime.app.ServiceBasedAppLauncher; +import org.apache.gobblin.util.PropertiesUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/SchedulerService.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/SchedulerService.java b/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/SchedulerService.java index ac42e8c..2d0136f 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/SchedulerService.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/SchedulerService.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.scheduler; +package org.apache.gobblin.scheduler; import java.util.Properties; @@ -27,9 +27,9 @@ import com.google.common.base.Optional; import com.google.common.util.concurrent.AbstractIdleService; import com.typesafe.config.Config; -import gobblin.configuration.ConfigurationKeys; -import gobblin.util.ConfigUtils; -import gobblin.util.PropertiesUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.util.PropertiesUtils; import lombok.Getter; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/FlowStatus.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/FlowStatus.java b/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/FlowStatus.java index ae73a73..e9d4d97 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/FlowStatus.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/FlowStatus.java @@ -15,11 +15,11 @@ * limitations under the License. */ -package gobblin.service.monitoring; +package org.apache.gobblin.service.monitoring; import java.util.Iterator; -import gobblin.annotation.Alpha; +import org.apache.gobblin.annotation.Alpha; import lombok.AllArgsConstructor; import lombok.Getter; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/FlowStatusGenerator.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/FlowStatusGenerator.java b/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/FlowStatusGenerator.java index 547cee7..5657e42 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/FlowStatusGenerator.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/FlowStatusGenerator.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.service.monitoring; +package org.apache.gobblin.service.monitoring; import java.util.Iterator; import java.util.List; @@ -24,7 +24,7 @@ import org.apache.commons.lang.StringUtils; import com.google.common.collect.Lists; -import gobblin.annotation.Alpha; +import org.apache.gobblin.annotation.Alpha; import lombok.Builder; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/JobStatus.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/JobStatus.java b/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/JobStatus.java index a39de8e..87e52c6 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/JobStatus.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/JobStatus.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.service.monitoring; +package org.apache.gobblin.service.monitoring; -import gobblin.annotation.Alpha; +import org.apache.gobblin.annotation.Alpha; import lombok.Builder; import lombok.Getter; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/JobStatusRetriever.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/JobStatusRetriever.java b/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/JobStatusRetriever.java index c6df8c4..fe60c4e 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/JobStatusRetriever.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/JobStatusRetriever.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package gobblin.service.monitoring; +package org.apache.gobblin.service.monitoring; import java.util.Iterator; import com.google.common.collect.Iterators; -import gobblin.annotation.Alpha; +import org.apache.gobblin.annotation.Alpha; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/LatestFlowExecutionIdTracker.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/LatestFlowExecutionIdTracker.java b/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/LatestFlowExecutionIdTracker.java index e421b40..39ab0ed 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/LatestFlowExecutionIdTracker.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/LatestFlowExecutionIdTracker.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.service.monitoring; +package org.apache.gobblin.service.monitoring; /** * Tracks the latest flow execution Id. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/main/java/org/apache/gobblin/util/SchedulerUtils.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/util/SchedulerUtils.java b/gobblin-runtime/src/main/java/org/apache/gobblin/util/SchedulerUtils.java index 1cb51ce..5406e0f 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/util/SchedulerUtils.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/util/SchedulerUtils.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util; +package org.apache.gobblin.util; import java.io.IOException; import java.net.URISyntaxException; @@ -37,14 +37,14 @@ import com.google.common.collect.Iterables; import com.google.common.collect.Lists; import com.typesafe.config.Config; -import gobblin.configuration.ConfigurationKeys; -import gobblin.runtime.api.JobTemplate; -import gobblin.runtime.api.SpecNotFoundException; -import gobblin.runtime.job_catalog.PackagedTemplatesJobCatalogDecorator; -import gobblin.runtime.template.ResourceBasedJobTemplate; -import gobblin.util.filesystem.PathAlterationObserverScheduler; -import gobblin.util.filesystem.PathAlterationListener; -import gobblin.util.filesystem.PathAlterationObserver; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.runtime.api.JobTemplate; +import org.apache.gobblin.runtime.api.SpecNotFoundException; +import org.apache.gobblin.runtime.job_catalog.PackagedTemplatesJobCatalogDecorator; +import org.apache.gobblin.runtime.template.ResourceBasedJobTemplate; +import org.apache.gobblin.util.filesystem.PathAlterationObserverScheduler; +import org.apache.gobblin.util.filesystem.PathAlterationListener; +import org.apache.gobblin.util.filesystem.PathAlterationObserver; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/performance/PerformanceTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/performance/PerformanceTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/performance/PerformanceTest.java index c0a5a99..2c61236 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/performance/PerformanceTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/performance/PerformanceTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.performance; +package org.apache.gobblin.performance; import java.util.List; import java.util.concurrent.TimeUnit; @@ -26,10 +26,10 @@ import com.google.common.collect.Lists; import com.google.common.eventbus.EventBus; import com.google.common.eventbus.Subscribe; -import gobblin.runtime.embedded.EmbeddedGobblin; -import gobblin.util.test.FastSequentialSource; -import gobblin.writer.test.GobblinTestEventBusWriter; -import gobblin.writer.test.TestingEventBuses; +import org.apache.gobblin.runtime.embedded.EmbeddedGobblin; +import org.apache.gobblin.util.test.FastSequentialSource; +import org.apache.gobblin.writer.test.GobblinTestEventBusWriter; +import org.apache.gobblin.writer.test.TestingEventBuses; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/BoundedBlockingRecordQueueTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/BoundedBlockingRecordQueueTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/BoundedBlockingRecordQueueTest.java index 741696b..93eb721 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/BoundedBlockingRecordQueueTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/BoundedBlockingRecordQueueTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime; +package org.apache.gobblin.runtime; import java.util.List; import java.util.Map; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/CountUpAndDownLatchTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/CountUpAndDownLatchTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/CountUpAndDownLatchTest.java index 36ada03..5bad68d 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/CountUpAndDownLatchTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/CountUpAndDownLatchTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime; +package org.apache.gobblin.runtime; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutorService; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/DatasetStateStoreTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/DatasetStateStoreTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/DatasetStateStoreTest.java index 342daf4..1cc0bab 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/DatasetStateStoreTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/DatasetStateStoreTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime; +package org.apache.gobblin.runtime; import java.io.FileReader; import java.io.IOException; @@ -30,20 +30,20 @@ import org.testng.annotations.Test; import com.google.common.collect.Iterables; import com.google.common.collect.Lists; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.SourceState; -import gobblin.configuration.WorkUnitState; -import gobblin.metastore.FsStateStore; -import gobblin.metastore.StateStore; -import gobblin.runtime.local.LocalJobLauncher; -import gobblin.source.Source; -import gobblin.source.extractor.DataRecordException; -import gobblin.source.extractor.Extractor; -import gobblin.source.extractor.extract.AbstractSource; -import gobblin.source.workunit.Extract; -import gobblin.source.workunit.WorkUnit; -import gobblin.writer.DataWriter; -import gobblin.writer.DataWriterBuilder; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.SourceState; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.metastore.FsStateStore; +import org.apache.gobblin.metastore.StateStore; +import org.apache.gobblin.runtime.local.LocalJobLauncher; +import org.apache.gobblin.source.Source; +import org.apache.gobblin.source.extractor.DataRecordException; +import org.apache.gobblin.source.extractor.Extractor; +import org.apache.gobblin.source.extractor.extract.AbstractSource; +import org.apache.gobblin.source.workunit.Extract; +import org.apache.gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.writer.DataWriter; +import org.apache.gobblin.writer.DataWriterBuilder; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/DummyJobContext.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/DummyJobContext.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/DummyJobContext.java index ae7e775..d3374fa 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/DummyJobContext.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/DummyJobContext.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime; +package org.apache.gobblin.runtime; import com.typesafe.config.Config; @@ -31,12 +31,12 @@ import org.slf4j.Logger; import com.google.common.base.Optional; import com.typesafe.config.ConfigFactory; -import gobblin.broker.gobblin_scopes.GobblinScopeTypes; -import gobblin.broker.SharedResourcesBrokerFactory; -import gobblin.commit.CommitSequenceStore; -import gobblin.commit.DeliverySemantics; -import gobblin.metastore.JobHistoryStore; -import gobblin.source.Source; +import org.apache.gobblin.broker.gobblin_scopes.GobblinScopeTypes; +import org.apache.gobblin.broker.SharedResourcesBrokerFactory; +import org.apache.gobblin.commit.CommitSequenceStore; +import org.apache.gobblin.commit.DeliverySemantics; +import org.apache.gobblin.metastore.JobHistoryStore; +import org.apache.gobblin.source.Source; public class DummyJobContext extends JobContext { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/FsDatasetStateStoreTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/FsDatasetStateStoreTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/FsDatasetStateStoreTest.java index f899070..8aa9ca8 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/FsDatasetStateStoreTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/FsDatasetStateStoreTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime; +package org.apache.gobblin.runtime; import java.io.IOException; import java.util.Map; @@ -28,10 +28,10 @@ import org.testng.annotations.AfterClass; import org.testng.annotations.BeforeClass; import org.testng.annotations.Test; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.metastore.FsStateStore; -import gobblin.metastore.StateStore; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.metastore.FsStateStore; +import org.apache.gobblin.metastore.StateStore; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobBrokerInjectionTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobBrokerInjectionTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobBrokerInjectionTest.java index 9a2e8e4..04ce82d 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobBrokerInjectionTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobBrokerInjectionTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime; +package org.apache.gobblin.runtime; import java.util.Queue; import java.util.Random; @@ -31,33 +31,33 @@ import org.testng.annotations.Test; import com.google.common.collect.Sets; import com.typesafe.config.ConfigFactory; -import gobblin.broker.gobblin_scopes.GobblinScopeTypes; -import gobblin.broker.iface.ConfigView; -import gobblin.broker.iface.NoSuchScopeException; -import gobblin.broker.iface.NotConfiguredException; -import gobblin.broker.iface.ScopedConfigView; -import gobblin.broker.iface.SharedResourceFactory; -import gobblin.broker.iface.SharedResourceKey; -import gobblin.broker.iface.SharedResourcesBroker; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.Converter; -import gobblin.converter.DataConversionException; -import gobblin.converter.SchemaConversionException; -import gobblin.converter.SingleRecordIterable; -import gobblin.runtime.api.GobblinInstanceDriver; -import gobblin.runtime.api.JobExecutionDriver; -import gobblin.runtime.api.JobExecutionResult; -import gobblin.runtime.api.JobLifecycleListener; -import gobblin.runtime.api.JobSpec; -import gobblin.runtime.instance.StandardGobblinInstanceDriver; -import gobblin.runtime.instance.StandardGobblinInstanceLauncher; -import gobblin.runtime.std.DefaultJobLifecycleListenerImpl; -import gobblin.runtime.std.FilteredJobLifecycleListener; -import gobblin.runtime.std.JobSpecFilter; -import gobblin.writer.test.GobblinTestEventBusWriter; -import gobblin.writer.test.TestingEventBusAsserter; -import gobblin.writer.test.TestingEventBuses; -import gobblin.broker.ResourceInstance; +import org.apache.gobblin.broker.gobblin_scopes.GobblinScopeTypes; +import org.apache.gobblin.broker.iface.ConfigView; +import org.apache.gobblin.broker.iface.NoSuchScopeException; +import org.apache.gobblin.broker.iface.NotConfiguredException; +import org.apache.gobblin.broker.iface.ScopedConfigView; +import org.apache.gobblin.broker.iface.SharedResourceFactory; +import org.apache.gobblin.broker.iface.SharedResourceKey; +import org.apache.gobblin.broker.iface.SharedResourcesBroker; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.Converter; +import org.apache.gobblin.converter.DataConversionException; +import org.apache.gobblin.converter.SchemaConversionException; +import org.apache.gobblin.converter.SingleRecordIterable; +import org.apache.gobblin.runtime.api.GobblinInstanceDriver; +import org.apache.gobblin.runtime.api.JobExecutionDriver; +import org.apache.gobblin.runtime.api.JobExecutionResult; +import org.apache.gobblin.runtime.api.JobLifecycleListener; +import org.apache.gobblin.runtime.api.JobSpec; +import org.apache.gobblin.runtime.instance.StandardGobblinInstanceDriver; +import org.apache.gobblin.runtime.instance.StandardGobblinInstanceLauncher; +import org.apache.gobblin.runtime.std.DefaultJobLifecycleListenerImpl; +import org.apache.gobblin.runtime.std.FilteredJobLifecycleListener; +import org.apache.gobblin.runtime.std.JobSpecFilter; +import org.apache.gobblin.writer.test.GobblinTestEventBusWriter; +import org.apache.gobblin.writer.test.TestingEventBusAsserter; +import org.apache.gobblin.writer.test.TestingEventBuses; +import org.apache.gobblin.broker.ResourceInstance; import lombok.Data; import lombok.EqualsAndHashCode; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobContextTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobContextTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobContextTest.java index 2c2d50d..d3dba5b 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobContextTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobContextTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime; +package org.apache.gobblin.runtime; import java.io.IOException; import java.util.Map; @@ -38,9 +38,9 @@ import com.google.common.collect.Lists; import com.google.common.collect.Maps; import com.google.common.collect.Queues; -import gobblin.commit.DeliverySemantics; -import gobblin.configuration.ConfigurationKeys; -import gobblin.util.Either; +import org.apache.gobblin.commit.DeliverySemantics; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.util.Either; import javax.annotation.Nullable; import lombok.extern.slf4j.Slf4j; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobExecutionEventSubmitterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobExecutionEventSubmitterTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobExecutionEventSubmitterTest.java index eff6b01..a88e3a1 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobExecutionEventSubmitterTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobExecutionEventSubmitterTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime; +package org.apache.gobblin.runtime; import static org.mockito.Mockito.any; import static org.mockito.Mockito.atLeastOnce; @@ -33,9 +33,9 @@ import org.mockito.Mockito; import org.testng.annotations.BeforeClass; import org.testng.annotations.Test; -import gobblin.configuration.WorkUnitState; -import gobblin.metrics.event.EventSubmitter; -import gobblin.rest.LauncherTypeEnum; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.metrics.event.EventSubmitter; +import org.apache.gobblin.rest.LauncherTypeEnum; @Test(groups = {"gobblin.runtime"}) http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobLauncherTestHelper.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobLauncherTestHelper.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobLauncherTestHelper.java index 2bebd1d..068d357 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobLauncherTestHelper.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobLauncherTestHelper.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime; +package org.apache.gobblin.runtime; import java.io.IOException; import java.util.List; @@ -29,17 +29,17 @@ import org.testng.Assert; import com.google.common.io.Closer; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.SourceState; -import gobblin.configuration.WorkUnitState; -import gobblin.metastore.StateStore; -import gobblin.runtime.JobState.DatasetState; -import gobblin.source.extractor.Extractor; -import gobblin.source.workunit.WorkUnit; -import gobblin.test.TestExtractor; -import gobblin.test.TestSource; -import gobblin.util.ClusterNameTags; -import gobblin.util.JobLauncherUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.SourceState; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.metastore.StateStore; +import org.apache.gobblin.runtime.JobState.DatasetState; +import org.apache.gobblin.source.extractor.Extractor; +import org.apache.gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.test.TestExtractor; +import org.apache.gobblin.test.TestSource; +import org.apache.gobblin.util.ClusterNameTags; +import org.apache.gobblin.util.JobLauncherUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobListenersTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobListenersTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobListenersTest.java index bd9066d..264fa10 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobListenersTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobListenersTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime; +package org.apache.gobblin.runtime; import static org.mockito.Mockito.mock; import static org.mockito.Mockito.times; @@ -24,9 +24,9 @@ import static org.mockito.Mockito.verify; import com.google.common.collect.Lists; import org.testng.annotations.Test; -import gobblin.runtime.listeners.CloseableJobListener; -import gobblin.runtime.listeners.JobListener; -import gobblin.runtime.listeners.JobListeners; +import org.apache.gobblin.runtime.listeners.CloseableJobListener; +import org.apache.gobblin.runtime.listeners.JobListener; +import org.apache.gobblin.runtime.listeners.JobListeners; @Test(groups = {"gobblin.runtime"}) http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobStateTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobStateTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobStateTest.java index bd26825..8bcca84 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobStateTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/JobStateTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime; +package org.apache.gobblin.runtime; import java.io.ByteArrayInputStream; import java.io.ByteArrayOutputStream; @@ -36,11 +36,11 @@ import com.google.common.collect.Lists; import com.google.common.collect.Sets; import com.google.common.io.Closer; -import gobblin.rest.JobExecutionInfo; -import gobblin.rest.TaskExecutionInfo; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.rest.JobExecutionInfo; +import org.apache.gobblin.rest.TaskExecutionInfo; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.source.workunit.WorkUnit; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/LimiterStopEventTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/LimiterStopEventTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/LimiterStopEventTest.java index 0a9e8f1..68484fe 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/LimiterStopEventTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/LimiterStopEventTest.java @@ -1,13 +1,13 @@ -package gobblin.runtime; +package org.apache.gobblin.runtime; import com.google.common.base.Joiner; import com.google.common.base.Optional; import com.google.common.collect.ImmutableMap; -import gobblin.configuration.ConfigurationKeys; -import gobblin.source.extractor.limiter.LimiterConfigurationKeys; -import gobblin.util.limiter.Limiter; -import gobblin.source.extractor.Extractor; -import gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.source.extractor.limiter.LimiterConfigurationKeys; +import org.apache.gobblin.util.limiter.Limiter; +import org.apache.gobblin.source.extractor.Extractor; +import org.apache.gobblin.source.workunit.WorkUnit; import junit.framework.Assert; import org.mockito.Mockito; import org.testng.annotations.Test; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/MultiConverterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/MultiConverterTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/MultiConverterTest.java index b8e9d51..397a133 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/MultiConverterTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/MultiConverterTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime; +package org.apache.gobblin.runtime; import java.util.List; @@ -30,13 +30,13 @@ import com.google.gson.Gson; import com.google.gson.JsonElement; import com.google.gson.JsonObject; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.Converter; -import gobblin.converter.DataConversionException; -import gobblin.converter.EmptyIterable; -import gobblin.converter.SchemaConversionException; -import gobblin.converter.SingleRecordIterable; -import gobblin.test.TestConverter; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.Converter; +import org.apache.gobblin.converter.DataConversionException; +import org.apache.gobblin.converter.EmptyIterable; +import org.apache.gobblin.converter.SchemaConversionException; +import org.apache.gobblin.converter.SingleRecordIterable; +import org.apache.gobblin.test.TestConverter; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/MysqlDatasetStateStoreTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/MysqlDatasetStateStoreTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/MysqlDatasetStateStoreTest.java index 2709f7d..9c35610 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/MysqlDatasetStateStoreTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/MysqlDatasetStateStoreTest.java @@ -15,17 +15,17 @@ * limitations under the License. */ -package gobblin.runtime; - -import gobblin.config.ConfigBuilder; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.metastore.DatasetStateStore; -import gobblin.metastore.MysqlStateStore; -import gobblin.metastore.StateStore; -import gobblin.metastore.testing.ITestMetastoreDatabase; -import gobblin.metastore.testing.TestMetastoreDatabaseFactory; -import gobblin.util.ClassAliasResolver; +package org.apache.gobblin.runtime; + +import org.apache.gobblin.config.ConfigBuilder; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.metastore.DatasetStateStore; +import org.apache.gobblin.metastore.MysqlStateStore; +import org.apache.gobblin.metastore.StateStore; +import org.apache.gobblin.metastore.testing.ITestMetastoreDatabase; +import org.apache.gobblin.metastore.testing.TestMetastoreDatabaseFactory; +import org.apache.gobblin.util.ClassAliasResolver; import java.io.IOException; import java.util.Map; import org.apache.commons.dbcp.BasicDataSource;
