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