http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSClusterLauncher.java ---------------------------------------------------------------------- diff --git a/gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSClusterLauncher.java b/gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSClusterLauncher.java index f68dd50..c2b0d5d 100644 --- a/gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSClusterLauncher.java +++ b/gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSClusterLauncher.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.aws; +package org.apache.gobblin.aws; import java.io.File; import java.io.IOException; @@ -56,18 +56,18 @@ import com.google.common.io.Closer; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.annotation.Alpha; -import gobblin.cluster.GobblinClusterConfigurationKeys; -import gobblin.cluster.GobblinClusterUtils; -import gobblin.cluster.GobblinHelixConstants; -import gobblin.cluster.HelixMessageSubTypes; -import gobblin.cluster.HelixUtils; -import gobblin.util.ConfigUtils; -import gobblin.util.EmailUtils; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.cluster.GobblinClusterConfigurationKeys; +import org.apache.gobblin.cluster.GobblinClusterUtils; +import org.apache.gobblin.cluster.GobblinHelixConstants; +import org.apache.gobblin.cluster.HelixMessageSubTypes; +import org.apache.gobblin.cluster.HelixUtils; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.util.EmailUtils; -import static gobblin.aws.GobblinAWSUtils.*; -import static gobblin.aws.GobblinAWSConfigurationKeys.*; -import static gobblin.cluster.GobblinClusterConfigurationKeys.*; +import static org.apache.gobblin.aws.GobblinAWSUtils.*; +import static org.apache.gobblin.aws.GobblinAWSConfigurationKeys.*; +import static org.apache.gobblin.cluster.GobblinClusterConfigurationKeys.*; /** @@ -296,7 +296,7 @@ public class GobblinAWSClusterLauncher { this.closer.close(); } } - + this.countDownLatch.countDown(); this.stopped = true; }
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSClusterManager.java ---------------------------------------------------------------------- diff --git a/gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSClusterManager.java b/gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSClusterManager.java index abb822b..e18ca5b 100644 --- a/gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSClusterManager.java +++ b/gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSClusterManager.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.aws; +package org.apache.gobblin.aws; import java.util.Collections; import java.util.List; @@ -39,13 +39,13 @@ import com.google.common.base.Optional; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.annotation.Alpha; -import gobblin.cluster.GobblinClusterConfigurationKeys; -import gobblin.cluster.GobblinClusterManager; -import gobblin.cluster.GobblinHelixJobScheduler; -import gobblin.cluster.HelixMessageSubTypes; -import gobblin.cluster.JobConfigurationManager; -import gobblin.util.JvmUtils; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.cluster.GobblinClusterConfigurationKeys; +import org.apache.gobblin.cluster.GobblinClusterManager; +import org.apache.gobblin.cluster.GobblinHelixJobScheduler; +import org.apache.gobblin.cluster.HelixMessageSubTypes; +import org.apache.gobblin.cluster.JobConfigurationManager; +import org.apache.gobblin.util.JvmUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSConfigurationKeys.java ---------------------------------------------------------------------- diff --git a/gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSConfigurationKeys.java b/gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSConfigurationKeys.java index beb7bc1..3b50947 100644 --- a/gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSConfigurationKeys.java +++ b/gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSConfigurationKeys.java @@ -14,9 +14,9 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.aws; +package org.apache.gobblin.aws; -import gobblin.annotation.Alpha; +import org.apache.gobblin.annotation.Alpha; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSTaskRunner.java ---------------------------------------------------------------------- diff --git a/gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSTaskRunner.java b/gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSTaskRunner.java index 2772aa0..dc9693b 100644 --- a/gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSTaskRunner.java +++ b/gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSTaskRunner.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.aws; +package org.apache.gobblin.aws; import java.util.Collections; import java.util.List; @@ -40,14 +40,14 @@ import com.google.common.util.concurrent.Service; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.annotation.Alpha; -import gobblin.cluster.GobblinClusterConfigurationKeys; -import gobblin.cluster.GobblinClusterManager; -import gobblin.cluster.GobblinHelixTask; -import gobblin.cluster.GobblinHelixTaskFactory; -import gobblin.cluster.GobblinTaskRunner; -import gobblin.cluster.HelixMessageSubTypes; -import gobblin.util.JvmUtils; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.cluster.GobblinClusterConfigurationKeys; +import org.apache.gobblin.cluster.GobblinClusterManager; +import org.apache.gobblin.cluster.GobblinHelixTask; +import org.apache.gobblin.cluster.GobblinHelixTaskFactory; +import org.apache.gobblin.cluster.GobblinTaskRunner; +import org.apache.gobblin.cluster.HelixMessageSubTypes; +import org.apache.gobblin.util.JvmUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSUtils.java ---------------------------------------------------------------------- diff --git a/gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSUtils.java b/gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSUtils.java index b1f136d..547fb08 100644 --- a/gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSUtils.java +++ b/gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSUtils.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.aws; +package org.apache.gobblin.aws; import java.io.File; import java.util.List; @@ -31,7 +31,7 @@ import org.slf4j.Logger; import com.google.common.base.Joiner; import com.google.common.base.Preconditions; -import gobblin.annotation.Alpha; +import org.apache.gobblin.annotation.Alpha; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-aws/src/main/java/org/apache/gobblin/aws/Log4jConfigHelper.java ---------------------------------------------------------------------- diff --git a/gobblin-aws/src/main/java/org/apache/gobblin/aws/Log4jConfigHelper.java b/gobblin-aws/src/main/java/org/apache/gobblin/aws/Log4jConfigHelper.java index 1c5f720..0903079 100644 --- a/gobblin-aws/src/main/java/org/apache/gobblin/aws/Log4jConfigHelper.java +++ b/gobblin-aws/src/main/java/org/apache/gobblin/aws/Log4jConfigHelper.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.aws; +package org.apache.gobblin.aws; import java.io.IOException; import java.io.InputStream; @@ -26,7 +26,7 @@ import org.apache.log4j.PropertyConfigurator; import com.google.common.io.Closer; -import gobblin.annotation.Alpha; +import org.apache.gobblin.annotation.Alpha; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-aws/src/test/java/org/apache/gobblin/aws/AWSJobConfigurationManagerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-aws/src/test/java/org/apache/gobblin/aws/AWSJobConfigurationManagerTest.java b/gobblin-aws/src/test/java/org/apache/gobblin/aws/AWSJobConfigurationManagerTest.java index 4e0afd1..8bcf048 100644 --- a/gobblin-aws/src/test/java/org/apache/gobblin/aws/AWSJobConfigurationManagerTest.java +++ b/gobblin-aws/src/test/java/org/apache/gobblin/aws/AWSJobConfigurationManagerTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.aws; +package org.apache.gobblin.aws; import java.io.File; import java.io.IOException; @@ -37,8 +37,8 @@ import com.google.common.eventbus.Subscribe; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; import com.typesafe.config.ConfigValueFactory; -import gobblin.cluster.GobblinClusterConfigurationKeys; -import gobblin.cluster.event.NewJobConfigArrivalEvent; +import org.apache.gobblin.cluster.GobblinClusterConfigurationKeys; +import org.apache.gobblin.cluster.event.NewJobConfigArrivalEvent; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-aws/src/test/java/org/apache/gobblin/aws/CloudInitScriptBuilderTest.java ---------------------------------------------------------------------- diff --git a/gobblin-aws/src/test/java/org/apache/gobblin/aws/CloudInitScriptBuilderTest.java b/gobblin-aws/src/test/java/org/apache/gobblin/aws/CloudInitScriptBuilderTest.java index 067e474..a601991 100644 --- a/gobblin-aws/src/test/java/org/apache/gobblin/aws/CloudInitScriptBuilderTest.java +++ b/gobblin-aws/src/test/java/org/apache/gobblin/aws/CloudInitScriptBuilderTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.aws; +package org.apache.gobblin.aws; import org.apache.commons.codec.binary.Base64; import org.apache.commons.io.IOUtils; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-aws/src/test/java/org/apache/gobblin/aws/GobblinAWSClusterLauncherTest.java ---------------------------------------------------------------------- diff --git a/gobblin-aws/src/test/java/org/apache/gobblin/aws/GobblinAWSClusterLauncherTest.java b/gobblin-aws/src/test/java/org/apache/gobblin/aws/GobblinAWSClusterLauncherTest.java index 1ae1e33..5cd9fb9 100644 --- a/gobblin-aws/src/test/java/org/apache/gobblin/aws/GobblinAWSClusterLauncherTest.java +++ b/gobblin-aws/src/test/java/org/apache/gobblin/aws/GobblinAWSClusterLauncherTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.aws; +package org.apache.gobblin.aws; import java.io.IOException; import java.net.URL; @@ -56,14 +56,14 @@ import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; import com.typesafe.config.ConfigValueFactory; -import gobblin.cluster.GobblinClusterConfigurationKeys; -import gobblin.cluster.GobblinHelixConstants; -import gobblin.cluster.HelixMessageSubTypes; -import gobblin.cluster.HelixMessageTestBase; -import gobblin.cluster.HelixUtils; -import gobblin.cluster.TestHelper; -import gobblin.cluster.TestShutdownMessageHandlerFactory; -import gobblin.testing.AssertWithBackoff; +import org.apache.gobblin.cluster.GobblinClusterConfigurationKeys; +import org.apache.gobblin.cluster.GobblinHelixConstants; +import org.apache.gobblin.cluster.HelixMessageSubTypes; +import org.apache.gobblin.cluster.HelixMessageTestBase; +import org.apache.gobblin.cluster.HelixUtils; +import org.apache.gobblin.cluster.TestHelper; +import org.apache.gobblin.cluster.TestShutdownMessageHandlerFactory; +import org.apache.gobblin.testing.AssertWithBackoff; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/ClusterEventMetadataGenerator.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/ClusterEventMetadataGenerator.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/ClusterEventMetadataGenerator.java index cc8e0d1..6aeb89c 100644 --- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/ClusterEventMetadataGenerator.java +++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/ClusterEventMetadataGenerator.java @@ -15,20 +15,20 @@ * limitations under the License. */ -package gobblin.cluster; +package org.apache.gobblin.cluster; import java.util.List; import java.util.Map; import com.google.common.collect.ImmutableMap; -import gobblin.annotation.Alias; -import gobblin.configuration.ConfigurationKeys; -import gobblin.metrics.event.EventName; -import gobblin.runtime.EventMetadataUtils; -import gobblin.runtime.JobContext; -import gobblin.runtime.TaskState; -import gobblin.runtime.api.EventMetadataGenerator; +import org.apache.gobblin.annotation.Alias; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.metrics.event.EventName; +import org.apache.gobblin.runtime.EventMetadataUtils; +import org.apache.gobblin.runtime.JobContext; +import org.apache.gobblin.runtime.TaskState; +import org.apache.gobblin.runtime.api.EventMetadataGenerator; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/ContainerMetrics.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/ContainerMetrics.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/ContainerMetrics.java index 34358ce..62f3652 100644 --- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/ContainerMetrics.java +++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/ContainerMetrics.java @@ -15,17 +15,17 @@ * limitations under the License. */ -package gobblin.cluster; +package org.apache.gobblin.cluster; import java.util.List; import java.util.concurrent.Callable; import com.google.common.collect.ImmutableList; -import gobblin.annotation.Alpha; -import gobblin.configuration.State; -import gobblin.metrics.GobblinMetrics; -import gobblin.metrics.Tag; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.metrics.GobblinMetrics; +import org.apache.gobblin.metrics.Tag; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterConfigurationKeys.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterConfigurationKeys.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterConfigurationKeys.java index b2f27a1..9c3f6c8 100644 --- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterConfigurationKeys.java +++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterConfigurationKeys.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.cluster; +package org.apache.gobblin.cluster; -import gobblin.annotation.Alpha; +import org.apache.gobblin.annotation.Alpha; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterManager.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterManager.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterManager.java index 25ee4f0..22e0480 100644 --- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterManager.java +++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterManager.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.cluster; +package org.apache.gobblin.cluster; import java.io.IOException; import java.lang.reflect.InvocationTargetException; @@ -72,19 +72,19 @@ import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; import com.typesafe.config.ConfigValueFactory; -import gobblin.annotation.Alpha; -import gobblin.cluster.event.ClusterManagerShutdownRequest; -import gobblin.configuration.ConfigurationKeys; -import gobblin.metrics.Tag; -import gobblin.runtime.api.MutableJobCatalog; -import gobblin.runtime.app.ApplicationException; -import gobblin.runtime.app.ApplicationLauncher; -import gobblin.runtime.app.ServiceBasedAppLauncher; -import gobblin.scheduler.SchedulerService; -import gobblin.util.ConfigUtils; -import gobblin.util.JvmUtils; -import gobblin.util.logs.Log4jConfigurationHelper; -import gobblin.util.reflection.GobblinConstructorUtils; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.cluster.event.ClusterManagerShutdownRequest; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.metrics.Tag; +import org.apache.gobblin.runtime.api.MutableJobCatalog; +import org.apache.gobblin.runtime.app.ApplicationException; +import org.apache.gobblin.runtime.app.ApplicationLauncher; +import org.apache.gobblin.runtime.app.ServiceBasedAppLauncher; +import org.apache.gobblin.scheduler.SchedulerService; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.util.JvmUtils; +import org.apache.gobblin.util.logs.Log4jConfigurationHelper; +import org.apache.gobblin.util.reflection.GobblinConstructorUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterMetricTagNames.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterMetricTagNames.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterMetricTagNames.java index 05c015e..0ecf6b3 100644 --- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterMetricTagNames.java +++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterMetricTagNames.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.cluster; +package org.apache.gobblin.cluster; -import gobblin.annotation.Alpha; +import org.apache.gobblin.annotation.Alpha; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterUtils.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterUtils.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterUtils.java index 1ff7b8c..a8a335a 100644 --- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterUtils.java +++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterUtils.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.cluster; +package org.apache.gobblin.cluster; import java.net.InetAddress; import java.net.UnknownHostException; @@ -23,7 +23,7 @@ import java.net.UnknownHostException; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; -import gobblin.annotation.Alpha; +import org.apache.gobblin.annotation.Alpha; @Alpha public class GobblinClusterUtils { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixConstants.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixConstants.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixConstants.java index 41b540f..bbb8d2e 100644 --- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixConstants.java +++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixConstants.java @@ -17,7 +17,7 @@ * under the License. */ -package gobblin.cluster; +package org.apache.gobblin.cluster; /** * Class for defining constants used while interacting with Helix http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixJob.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixJob.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixJob.java index 433fa76..d9eab64 100644 --- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixJob.java +++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixJob.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.cluster; +package org.apache.gobblin.cluster; import java.util.List; import java.util.Properties; @@ -30,14 +30,14 @@ import org.quartz.JobDataMap; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; -import gobblin.annotation.Alpha; -import gobblin.configuration.ConfigurationKeys; -import gobblin.metrics.Tag; -import gobblin.runtime.JobException; -import gobblin.runtime.JobLauncher; -import gobblin.runtime.listeners.JobListener; -import gobblin.scheduler.BaseGobblinJob; -import gobblin.scheduler.JobScheduler; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.metrics.Tag; +import org.apache.gobblin.runtime.JobException; +import org.apache.gobblin.runtime.JobLauncher; +import org.apache.gobblin.runtime.listeners.JobListener; +import org.apache.gobblin.scheduler.BaseGobblinJob; +import org.apache.gobblin.scheduler.JobScheduler; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixJobLauncher.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixJobLauncher.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixJobLauncher.java index ab32dc2..7d32827 100644 --- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixJobLauncher.java +++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixJobLauncher.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.cluster; +package org.apache.gobblin.cluster; import java.io.IOException; import java.net.URI; @@ -46,28 +46,28 @@ import com.google.common.collect.Lists; import com.google.common.collect.Maps; import com.typesafe.config.Config; -import gobblin.annotation.Alpha; -import gobblin.configuration.ConfigurationKeys; -import gobblin.metastore.StateStore; -import gobblin.metrics.Tag; -import gobblin.metrics.event.TimingEvent; -import gobblin.rest.LauncherTypeEnum; -import gobblin.runtime.AbstractJobLauncher; -import gobblin.runtime.ExecutionModel; -import gobblin.runtime.JobLauncher; -import gobblin.runtime.JobState; -import gobblin.runtime.Task; -import gobblin.runtime.TaskConfigurationKeys; -import gobblin.runtime.TaskState; -import gobblin.runtime.TaskStateCollectorService; -import gobblin.runtime.util.StateStores; -import gobblin.source.workunit.MultiWorkUnit; -import gobblin.source.workunit.WorkUnit; -import gobblin.util.ConfigUtils; -import gobblin.util.Id; -import gobblin.util.JobLauncherUtils; -import gobblin.util.ParallelRunner; -import gobblin.util.SerializationUtils; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.metastore.StateStore; +import org.apache.gobblin.metrics.Tag; +import org.apache.gobblin.metrics.event.TimingEvent; +import org.apache.gobblin.rest.LauncherTypeEnum; +import org.apache.gobblin.runtime.AbstractJobLauncher; +import org.apache.gobblin.runtime.ExecutionModel; +import org.apache.gobblin.runtime.JobLauncher; +import org.apache.gobblin.runtime.JobState; +import org.apache.gobblin.runtime.Task; +import org.apache.gobblin.runtime.TaskConfigurationKeys; +import org.apache.gobblin.runtime.TaskState; +import org.apache.gobblin.runtime.TaskStateCollectorService; +import org.apache.gobblin.runtime.util.StateStores; +import org.apache.gobblin.source.workunit.MultiWorkUnit; +import org.apache.gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.util.Id; +import org.apache.gobblin.util.JobLauncherUtils; +import org.apache.gobblin.util.ParallelRunner; +import org.apache.gobblin.util.SerializationUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixJobScheduler.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixJobScheduler.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixJobScheduler.java index c598c72..0a43380 100644 --- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixJobScheduler.java +++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixJobScheduler.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.cluster; +package org.apache.gobblin.cluster; import java.net.URI; import java.net.URISyntaxException; @@ -33,18 +33,18 @@ import com.google.common.collect.Maps; import com.google.common.eventbus.EventBus; import com.google.common.eventbus.Subscribe; -import gobblin.annotation.Alpha; -import gobblin.configuration.ConfigurationKeys; -import gobblin.metrics.Tag; -import gobblin.runtime.JobException; -import gobblin.runtime.JobLauncher; -import gobblin.runtime.api.MutableJobCatalog; -import gobblin.runtime.listeners.JobListener; -import gobblin.scheduler.JobScheduler; -import gobblin.cluster.event.DeleteJobConfigArrivalEvent; -import gobblin.cluster.event.NewJobConfigArrivalEvent; -import gobblin.cluster.event.UpdateJobConfigArrivalEvent; -import gobblin.scheduler.SchedulerService; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.metrics.Tag; +import org.apache.gobblin.runtime.JobException; +import org.apache.gobblin.runtime.JobLauncher; +import org.apache.gobblin.runtime.api.MutableJobCatalog; +import org.apache.gobblin.runtime.listeners.JobListener; +import org.apache.gobblin.scheduler.JobScheduler; +import org.apache.gobblin.cluster.event.DeleteJobConfigArrivalEvent; +import org.apache.gobblin.cluster.event.NewJobConfigArrivalEvent; +import org.apache.gobblin.cluster.event.UpdateJobConfigArrivalEvent; +import org.apache.gobblin.scheduler.SchedulerService; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixMessagingService.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixMessagingService.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixMessagingService.java index f5eee2c..3bc0fd3 100644 --- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixMessagingService.java +++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixMessagingService.java @@ -1,4 +1,4 @@ -package gobblin.cluster; +package org.apache.gobblin.cluster; import com.google.common.base.Strings; import java.util.ArrayList; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTask.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTask.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTask.java index 0809a66..7af4ee1 100644 --- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTask.java +++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTask.java @@ -15,11 +15,11 @@ * limitations under the License. */ -package gobblin.cluster; +package org.apache.gobblin.cluster; import com.google.common.io.Closer; -import gobblin.metastore.StateStore; -import gobblin.runtime.util.StateStores; +import org.apache.gobblin.metastore.StateStore; +import org.apache.gobblin.runtime.util.StateStores; import java.io.IOException; import java.util.List; @@ -38,24 +38,24 @@ import com.google.common.base.Throwables; import com.google.common.collect.Lists; import com.typesafe.config.ConfigFactory; -import gobblin.annotation.Alpha; -import gobblin.broker.SharedResourcesBrokerFactory; -import gobblin.broker.iface.SharedResourcesBroker; -import gobblin.configuration.ConfigurationKeys; -import gobblin.runtime.AbstractJobLauncher; -import gobblin.runtime.GobblinMultiTaskAttempt; -import gobblin.runtime.JobState; -import gobblin.runtime.TaskExecutor; -import gobblin.runtime.TaskState; -import gobblin.runtime.TaskStateTracker; -import gobblin.runtime.util.JobMetrics; -import gobblin.source.workunit.MultiWorkUnit; -import gobblin.source.workunit.WorkUnit; -import gobblin.util.Id; -import gobblin.util.JobLauncherUtils; -import gobblin.util.SerializationUtils; -import gobblin.broker.gobblin_scopes.GobblinScopeTypes; -import gobblin.broker.gobblin_scopes.JobScopeInstance; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.broker.SharedResourcesBrokerFactory; +import org.apache.gobblin.broker.iface.SharedResourcesBroker; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.runtime.AbstractJobLauncher; +import org.apache.gobblin.runtime.GobblinMultiTaskAttempt; +import org.apache.gobblin.runtime.JobState; +import org.apache.gobblin.runtime.TaskExecutor; +import org.apache.gobblin.runtime.TaskState; +import org.apache.gobblin.runtime.TaskStateTracker; +import org.apache.gobblin.runtime.util.JobMetrics; +import org.apache.gobblin.source.workunit.MultiWorkUnit; +import org.apache.gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.util.Id; +import org.apache.gobblin.util.JobLauncherUtils; +import org.apache.gobblin.util.SerializationUtils; +import org.apache.gobblin.broker.gobblin_scopes.GobblinScopeTypes; +import org.apache.gobblin.broker.gobblin_scopes.JobScopeInstance; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTaskDriver.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTaskDriver.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTaskDriver.java index 333f636..c56f8e2 100644 --- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTaskDriver.java +++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTaskDriver.java @@ -16,7 +16,7 @@ * specific language governing permissions and limitations * under the License. */ -package gobblin.cluster; +package org.apache.gobblin.cluster; import com.google.common.base.Joiner; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTaskFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTaskFactory.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTaskFactory.java index 8e0b39d..e66756f 100644 --- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTaskFactory.java +++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTaskFactory.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package gobblin.cluster; +package org.apache.gobblin.cluster; import com.typesafe.config.Config; -import gobblin.runtime.util.StateStores; +import org.apache.gobblin.runtime.util.StateStores; import java.io.IOException; import org.apache.hadoop.fs.FileSystem; @@ -36,9 +36,9 @@ import com.codahale.metrics.Counter; import com.google.common.base.Optional; import com.google.common.base.Throwables; -import gobblin.annotation.Alpha; -import gobblin.runtime.TaskExecutor; -import gobblin.runtime.TaskStateTracker; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.runtime.TaskExecutor; +import org.apache.gobblin.runtime.TaskStateTracker; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTaskStateTracker.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTaskStateTracker.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTaskStateTracker.java index 4d5132b..2abc70f 100644 --- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTaskStateTracker.java +++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTaskStateTracker.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.cluster; +package org.apache.gobblin.cluster; import java.util.Map; import java.util.Properties; @@ -29,10 +29,10 @@ import org.slf4j.LoggerFactory; import com.google.common.collect.Maps; -import gobblin.annotation.Alpha; -import gobblin.metrics.GobblinMetrics; -import gobblin.runtime.AbstractTaskStateTracker; -import gobblin.runtime.Task; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.metrics.GobblinMetrics; +import org.apache.gobblin.runtime.AbstractTaskStateTracker; +import org.apache.gobblin.runtime.Task; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinTaskRunner.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinTaskRunner.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinTaskRunner.java index 7faf393..7dd2676 100644 --- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinTaskRunner.java +++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinTaskRunner.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.cluster; +package org.apache.gobblin.cluster; import java.io.IOException; import java.net.URI; @@ -70,16 +70,16 @@ import com.google.common.util.concurrent.ServiceManager; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.annotation.Alpha; -import gobblin.configuration.ConfigurationKeys; -import gobblin.metrics.GobblinMetrics; -import gobblin.runtime.TaskExecutor; -import gobblin.runtime.TaskStateTracker; -import gobblin.runtime.services.JMXReportingService; -import gobblin.util.ConfigUtils; -import gobblin.util.HadoopUtils; -import gobblin.util.JvmUtils; -import gobblin.util.logs.Log4jConfigurationHelper; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.metrics.GobblinMetrics; +import org.apache.gobblin.runtime.TaskExecutor; +import org.apache.gobblin.runtime.TaskStateTracker; +import org.apache.gobblin.runtime.services.JMXReportingService; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.util.HadoopUtils; +import org.apache.gobblin.util.JvmUtils; +import org.apache.gobblin.util.logs.Log4jConfigurationHelper; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinTaskStateModel.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinTaskStateModel.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinTaskStateModel.java index b16a6e6..5a96e48 100644 --- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinTaskStateModel.java +++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinTaskStateModel.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.cluster; +package org.apache.gobblin.cluster; import java.util.Map; import java.util.concurrent.ScheduledExecutorService; @@ -24,8 +24,8 @@ import org.apache.helix.HelixManager; import org.apache.helix.task.TaskFactory; import org.apache.helix.task.TaskStateModel; -import gobblin.annotation.Alpha; -import gobblin.runtime.TaskExecutor; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.runtime.TaskExecutor; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinTaskStateModelFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinTaskStateModelFactory.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinTaskStateModelFactory.java index 930666e..335a1e0 100644 --- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinTaskStateModelFactory.java +++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinTaskStateModelFactory.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.cluster; +package org.apache.gobblin.cluster; import java.util.Map; import java.util.concurrent.ScheduledExecutorService; @@ -25,8 +25,8 @@ import org.apache.helix.task.TaskFactory; import org.apache.helix.task.TaskStateModel; import org.apache.helix.task.TaskStateModelFactory; -import gobblin.annotation.Alpha; -import gobblin.runtime.TaskExecutor; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.runtime.TaskExecutor; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/HelixMessageSubTypes.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/HelixMessageSubTypes.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/HelixMessageSubTypes.java index 4b4cd84..4e93397 100644 --- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/HelixMessageSubTypes.java +++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/HelixMessageSubTypes.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.cluster; +package org.apache.gobblin.cluster; -import gobblin.annotation.Alpha; +import org.apache.gobblin.annotation.Alpha; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/HelixUtils.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/HelixUtils.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/HelixUtils.java index 2a38044..8be0621 100644 --- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/HelixUtils.java +++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/HelixUtils.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package gobblin.cluster; +package org.apache.gobblin.cluster; import org.apache.helix.manager.zk.ZKHelixManager; import org.apache.helix.model.HelixConfigScope; import org.apache.helix.tools.ClusterSetup; -import gobblin.annotation.Alpha; +import org.apache.gobblin.annotation.Alpha; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/JobConfigurationManager.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/JobConfigurationManager.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/JobConfigurationManager.java index f254a2f..42fab27 100644 --- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/JobConfigurationManager.java +++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/JobConfigurationManager.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.cluster; +package org.apache.gobblin.cluster; import java.io.File; import java.util.List; @@ -30,13 +30,13 @@ import com.google.common.eventbus.EventBus; import com.google.common.util.concurrent.AbstractIdleService; import com.typesafe.config.Config; -import gobblin.annotation.Alpha; -import gobblin.cluster.event.DeleteJobConfigArrivalEvent; -import gobblin.cluster.event.NewJobConfigArrivalEvent; -import gobblin.cluster.event.UpdateJobConfigArrivalEvent; -import gobblin.configuration.ConfigurationKeys; -import gobblin.util.ConfigUtils; -import gobblin.util.SchedulerUtils; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.cluster.event.DeleteJobConfigArrivalEvent; +import org.apache.gobblin.cluster.event.NewJobConfigArrivalEvent; +import org.apache.gobblin.cluster.event.UpdateJobConfigArrivalEvent; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.util.SchedulerUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/NoopReplyHandler.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/NoopReplyHandler.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/NoopReplyHandler.java index 136aa00..ed3cfa5 100644 --- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/NoopReplyHandler.java +++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/NoopReplyHandler.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.cluster; +package org.apache.gobblin.cluster; import org.apache.helix.messaging.AsyncCallback; import org.apache.helix.model.Message; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/ScheduledJobConfigurationManager.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/ScheduledJobConfigurationManager.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/ScheduledJobConfigurationManager.java index 15c1c3c..9290b5a 100644 --- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/ScheduledJobConfigurationManager.java +++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/ScheduledJobConfigurationManager.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.cluster; +package org.apache.gobblin.cluster; import java.lang.reflect.InvocationTargetException; import java.net.URI; @@ -37,14 +37,14 @@ import com.google.common.collect.Maps; import com.google.common.eventbus.EventBus; import com.typesafe.config.Config; -import gobblin.annotation.Alpha; -import gobblin.runtime.api.JobSpec; -import gobblin.runtime.api.Spec; -import gobblin.runtime.api.SpecExecutorInstance; -import gobblin.runtime.api.SpecExecutorInstanceConsumer; -import gobblin.util.ClassAliasResolver; -import gobblin.util.ConfigUtils; -import gobblin.util.ExecutorsUtils; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.runtime.api.JobSpec; +import org.apache.gobblin.runtime.api.Spec; +import org.apache.gobblin.runtime.api.SpecExecutorInstance; +import org.apache.gobblin.runtime.api.SpecExecutorInstanceConsumer; +import org.apache.gobblin.util.ClassAliasResolver; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.util.ExecutorsUtils; @Alpha http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/StreamingJobConfigurationManager.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/StreamingJobConfigurationManager.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/StreamingJobConfigurationManager.java index d5071c0..e660710 100644 --- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/StreamingJobConfigurationManager.java +++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/StreamingJobConfigurationManager.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.cluster; +package org.apache.gobblin.cluster; import java.lang.reflect.InvocationTargetException; import java.util.List; @@ -35,16 +35,16 @@ import com.google.common.eventbus.EventBus; import com.google.common.util.concurrent.Service; import com.typesafe.config.Config; -import gobblin.annotation.Alpha; -import gobblin.runtime.api.JobSpec; -import gobblin.runtime.api.MutableJobCatalog; -import gobblin.runtime.api.Spec; -import gobblin.runtime.api.SpecExecutorInstance; -import gobblin.runtime.api.SpecExecutorInstanceConsumer; -import gobblin.util.ClassAliasResolver; -import gobblin.util.ConfigUtils; -import gobblin.util.ExecutorsUtils; -import gobblin.util.reflection.GobblinConstructorUtils; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.runtime.api.JobSpec; +import org.apache.gobblin.runtime.api.MutableJobCatalog; +import org.apache.gobblin.runtime.api.Spec; +import org.apache.gobblin.runtime.api.SpecExecutorInstance; +import org.apache.gobblin.runtime.api.SpecExecutorInstanceConsumer; +import org.apache.gobblin.util.ClassAliasResolver; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.util.ExecutorsUtils; +import org.apache.gobblin.util.reflection.GobblinConstructorUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/event/ClusterManagerShutdownRequest.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/event/ClusterManagerShutdownRequest.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/event/ClusterManagerShutdownRequest.java index 601b0e2..ba60f99 100644 --- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/event/ClusterManagerShutdownRequest.java +++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/event/ClusterManagerShutdownRequest.java @@ -16,9 +16,9 @@ */ -package gobblin.cluster.event; +package org.apache.gobblin.cluster.event; -import gobblin.annotation.Alpha; +import org.apache.gobblin.annotation.Alpha; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/event/DeleteJobConfigArrivalEvent.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/event/DeleteJobConfigArrivalEvent.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/event/DeleteJobConfigArrivalEvent.java index 109fba9..e55c709 100644 --- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/event/DeleteJobConfigArrivalEvent.java +++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/event/DeleteJobConfigArrivalEvent.java @@ -15,11 +15,11 @@ * limitations under the License. */ -package gobblin.cluster.event; +package org.apache.gobblin.cluster.event; import java.util.Properties; -import gobblin.annotation.Alpha; +import org.apache.gobblin.annotation.Alpha; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/event/NewJobConfigArrivalEvent.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/event/NewJobConfigArrivalEvent.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/event/NewJobConfigArrivalEvent.java index f2bc49d..ea07503 100644 --- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/event/NewJobConfigArrivalEvent.java +++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/event/NewJobConfigArrivalEvent.java @@ -15,11 +15,11 @@ * limitations under the License. */ -package gobblin.cluster.event; +package org.apache.gobblin.cluster.event; import java.util.Properties; -import gobblin.annotation.Alpha; +import org.apache.gobblin.annotation.Alpha; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/event/UpdateJobConfigArrivalEvent.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/event/UpdateJobConfigArrivalEvent.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/event/UpdateJobConfigArrivalEvent.java index 79ccb68..d2204a5 100644 --- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/event/UpdateJobConfigArrivalEvent.java +++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/event/UpdateJobConfigArrivalEvent.java @@ -15,11 +15,11 @@ * limitations under the License. */ -package gobblin.cluster.event; +package org.apache.gobblin.cluster.event; import java.util.Properties; -import gobblin.annotation.Alpha; +import org.apache.gobblin.annotation.Alpha; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/ClusterEventMetadataGeneratorTest.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/ClusterEventMetadataGeneratorTest.java b/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/ClusterEventMetadataGeneratorTest.java index 0f422a6..7718969 100644 --- a/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/ClusterEventMetadataGeneratorTest.java +++ b/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/ClusterEventMetadataGeneratorTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.cluster; +package org.apache.gobblin.cluster; import java.util.Map; @@ -25,12 +25,12 @@ import org.slf4j.LoggerFactory; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.configuration.ConfigurationKeys; -import gobblin.metrics.event.EventName; -import gobblin.runtime.EventMetadataUtils; -import gobblin.runtime.JobContext; -import gobblin.runtime.JobState; -import gobblin.runtime.TaskState; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.metrics.event.EventName; +import org.apache.gobblin.runtime.EventMetadataUtils; +import org.apache.gobblin.runtime.JobContext; +import org.apache.gobblin.runtime.JobState; +import org.apache.gobblin.runtime.TaskState; /** * Unit tests for {@link ClusterEventMetadataGenerator}. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/GobblinClusterKillTest.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/GobblinClusterKillTest.java b/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/GobblinClusterKillTest.java index 1ba98f4..13bf91e 100644 --- a/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/GobblinClusterKillTest.java +++ b/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/GobblinClusterKillTest.java @@ -15,14 +15,14 @@ * limitations under the License. */ -package gobblin.cluster; +package org.apache.gobblin.cluster; import com.google.common.base.Optional; import com.google.common.base.Predicate; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; import com.typesafe.config.ConfigValueFactory; -import gobblin.testing.AssertWithBackoff; +import org.apache.gobblin.testing.AssertWithBackoff; import java.io.File; import java.io.IOException; import java.io.InputStream; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/GobblinClusterManagerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/GobblinClusterManagerTest.java b/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/GobblinClusterManagerTest.java index 4f0e123..9adcd67 100644 --- a/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/GobblinClusterManagerTest.java +++ b/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/GobblinClusterManagerTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.cluster; +package org.apache.gobblin.cluster; import java.net.URL; @@ -41,8 +41,8 @@ import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; import com.typesafe.config.ConfigValueFactory; -import gobblin.cluster.event.ClusterManagerShutdownRequest; -import gobblin.testing.AssertWithBackoff; +import org.apache.gobblin.cluster.event.ClusterManagerShutdownRequest; +import org.apache.gobblin.testing.AssertWithBackoff; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/GobblinHelixJobLauncherTest.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/GobblinHelixJobLauncherTest.java b/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/GobblinHelixJobLauncherTest.java index 6cbb7d1..b9dc5cd 100644 --- a/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/GobblinHelixJobLauncherTest.java +++ b/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/GobblinHelixJobLauncherTest.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package gobblin.cluster; +package org.apache.gobblin.cluster; -import gobblin.metastore.DatasetStateStore; -import gobblin.util.ClassAliasResolver; +import org.apache.gobblin.metastore.DatasetStateStore; +import org.apache.gobblin.util.ClassAliasResolver; import java.io.Closeable; import java.io.File; import java.io.IOException; @@ -48,13 +48,13 @@ import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; import com.typesafe.config.ConfigValueFactory; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.metrics.Tag; -import gobblin.runtime.FsDatasetStateStore; -import gobblin.runtime.JobException; -import gobblin.runtime.JobState; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.metrics.Tag; +import org.apache.gobblin.runtime.FsDatasetStateStore; +import org.apache.gobblin.runtime.JobException; +import org.apache.gobblin.runtime.JobState; +import org.apache.gobblin.util.ConfigUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/GobblinHelixTaskTest.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/GobblinHelixTaskTest.java b/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/GobblinHelixTaskTest.java index d4f88df..d1197b0 100644 --- a/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/GobblinHelixTaskTest.java +++ b/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/GobblinHelixTaskTest.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package gobblin.cluster; +package org.apache.gobblin.cluster; import com.typesafe.config.ConfigFactory; -import gobblin.metastore.FsStateStore; +import org.apache.gobblin.metastore.FsStateStore; import java.io.File; import java.io.IOException; import java.util.Map; @@ -45,18 +45,18 @@ import org.testng.annotations.Test; import com.google.common.base.Optional; import com.google.common.collect.Maps; -import gobblin.configuration.ConfigurationKeys; -import gobblin.example.simplejson.SimpleJsonConverter; -import gobblin.example.simplejson.SimpleJsonSource; -import gobblin.runtime.AbstractJobLauncher; -import gobblin.runtime.JobState; -import gobblin.runtime.TaskExecutor; -import gobblin.source.workunit.WorkUnit; -import gobblin.util.Id; -import gobblin.util.SerializationUtils; -import gobblin.writer.AvroDataWriterBuilder; -import gobblin.writer.Destination; -import gobblin.writer.WriterOutputFormat; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.example.simplejson.SimpleJsonConverter; +import org.apache.gobblin.example.simplejson.SimpleJsonSource; +import org.apache.gobblin.runtime.AbstractJobLauncher; +import org.apache.gobblin.runtime.JobState; +import org.apache.gobblin.runtime.TaskExecutor; +import org.apache.gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.util.Id; +import org.apache.gobblin.util.SerializationUtils; +import org.apache.gobblin.writer.AvroDataWriterBuilder; +import org.apache.gobblin.writer.Destination; +import org.apache.gobblin.writer.WriterOutputFormat; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/GobblinTaskRunnerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/GobblinTaskRunnerTest.java b/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/GobblinTaskRunnerTest.java index 4adccd6..286c50a 100644 --- a/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/GobblinTaskRunnerTest.java +++ b/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/GobblinTaskRunnerTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.cluster; +package org.apache.gobblin.cluster; import java.io.IOException; import java.net.URL; @@ -35,7 +35,7 @@ import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; import com.typesafe.config.ConfigValueFactory; -import gobblin.testing.AssertWithBackoff; +import org.apache.gobblin.testing.AssertWithBackoff; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/HelixMessageTestBase.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/HelixMessageTestBase.java b/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/HelixMessageTestBase.java index 36d634c..4adf516 100644 --- a/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/HelixMessageTestBase.java +++ b/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/HelixMessageTestBase.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.cluster; +package org.apache.gobblin.cluster; import org.apache.helix.model.Message; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/HelixUtilsTest.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/HelixUtilsTest.java b/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/HelixUtilsTest.java index 5ff4c31..2afd01f 100644 --- a/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/HelixUtilsTest.java +++ b/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/HelixUtilsTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.cluster; +package org.apache.gobblin.cluster; import java.io.IOException; import java.net.URL; @@ -35,7 +35,7 @@ import org.testng.annotations.Test; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.util.ConfigUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/JobConfigurationManagerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/JobConfigurationManagerTest.java b/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/JobConfigurationManagerTest.java index ec9ab18..73098f2 100644 --- a/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/JobConfigurationManagerTest.java +++ b/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/JobConfigurationManagerTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.cluster; +package org.apache.gobblin.cluster; import java.io.File; import java.io.IOException; @@ -39,8 +39,8 @@ import com.google.common.io.Files; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; import com.typesafe.config.ConfigValueFactory; -import gobblin.cluster.event.NewJobConfigArrivalEvent; -import gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.cluster.event.NewJobConfigArrivalEvent; +import org.apache.gobblin.configuration.ConfigurationKeys; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/TestHelper.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/TestHelper.java b/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/TestHelper.java index 7f4229c..b717585 100644 --- a/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/TestHelper.java +++ b/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/TestHelper.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.cluster; +package org.apache.gobblin.cluster; import java.io.File; import java.io.IOException; @@ -37,8 +37,8 @@ import org.testng.Assert; import com.google.common.io.Closer; import com.google.common.io.Files; -import gobblin.configuration.ConfigurationKeys; -import gobblin.util.JobLauncherUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.util.JobLauncherUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/TestShutdownMessageHandlerFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/TestShutdownMessageHandlerFactory.java b/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/TestShutdownMessageHandlerFactory.java index 8d5d29d..c0b80a9 100644 --- a/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/TestShutdownMessageHandlerFactory.java +++ b/gobblin-cluster/src/test/java/org/apache/gobblin/cluster/TestShutdownMessageHandlerFactory.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.cluster; +package org.apache.gobblin.cluster; import java.util.Collections; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/CliOptions.java ---------------------------------------------------------------------- diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/CliOptions.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/CliOptions.java index 8d764fa..f5e4e49 100644 --- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/CliOptions.java +++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/CliOptions.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.compaction; +package org.apache.gobblin.compaction; import java.io.IOException; import java.util.Properties; @@ -30,7 +30,7 @@ import org.apache.commons.configuration.ConfigurationException; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.util.GenericOptionsParser; -import gobblin.util.JobConfigurationUtils; +import org.apache.gobblin.util.JobConfigurationUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/Compactor.java ---------------------------------------------------------------------- diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/Compactor.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/Compactor.java index 0ce6d85..ce1bb67 100644 --- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/Compactor.java +++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/Compactor.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.compaction; +package org.apache.gobblin.compaction; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/CompactorCreationException.java ---------------------------------------------------------------------- diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/CompactorCreationException.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/CompactorCreationException.java index 428dc18..adc9c0e 100644 --- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/CompactorCreationException.java +++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/CompactorCreationException.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.compaction; +package org.apache.gobblin.compaction; /** * Throw by {@link CompactorFactory} if there is a problem creating a {@link Compactor}. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/CompactorFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/CompactorFactory.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/CompactorFactory.java index 557984e..cb7e7c0 100644 --- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/CompactorFactory.java +++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/CompactorFactory.java @@ -15,16 +15,16 @@ * limitations under the License. */ -package gobblin.compaction; +package org.apache.gobblin.compaction; import java.util.List; import java.util.Properties; import com.google.common.base.Optional; -import gobblin.annotation.Alpha; -import gobblin.compaction.listeners.CompactorListener; -import gobblin.metrics.Tag; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.compaction.listeners.CompactorListener; +import org.apache.gobblin.metrics.Tag; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/ReflectionCompactorFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/ReflectionCompactorFactory.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/ReflectionCompactorFactory.java index e4b1d83..eaeebd3 100644 --- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/ReflectionCompactorFactory.java +++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/ReflectionCompactorFactory.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.compaction; +package org.apache.gobblin.compaction; import java.util.List; import java.util.Properties; @@ -25,8 +25,8 @@ import com.google.common.base.Optional; import org.apache.commons.lang3.reflect.ConstructorUtils; -import gobblin.compaction.listeners.CompactorListener; -import gobblin.metrics.Tag; +import org.apache.gobblin.compaction.listeners.CompactorListener; +import org.apache.gobblin.metrics.Tag; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/action/CompactionCompleteAction.java ---------------------------------------------------------------------- diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/action/CompactionCompleteAction.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/action/CompactionCompleteAction.java index 576d458..a5b21bc 100644 --- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/action/CompactionCompleteAction.java +++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/action/CompactionCompleteAction.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.compaction.action; -import gobblin.dataset.Dataset; -import gobblin.metrics.event.EventSubmitter; +package org.apache.gobblin.compaction.action; +import org.apache.gobblin.dataset.Dataset; +import org.apache.gobblin.metrics.event.EventSubmitter; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/action/CompactionCompleteFileOperationAction.java ---------------------------------------------------------------------- diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/action/CompactionCompleteFileOperationAction.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/action/CompactionCompleteFileOperationAction.java index b1deeba..713fd32 100644 --- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/action/CompactionCompleteFileOperationAction.java +++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/action/CompactionCompleteFileOperationAction.java @@ -15,24 +15,24 @@ * limitations under the License. */ -package gobblin.compaction.action; +package org.apache.gobblin.compaction.action; import com.google.common.collect.ImmutableMap; import com.google.common.collect.Lists; -import gobblin.compaction.dataset.DatasetHelper; -import gobblin.compaction.event.CompactionSlaEventHelper; -import gobblin.compaction.mapreduce.CompactionAvroJobConfigurator; -import gobblin.compaction.mapreduce.MRCompactor; -import gobblin.compaction.mapreduce.MRCompactorJobRunner; -import gobblin.compaction.mapreduce.avro.AvroKeyMapper; -import gobblin.compaction.parser.CompactionPathParser; -import gobblin.compaction.verify.InputRecordCountHelper; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.dataset.FileSystemDataset; -import gobblin.metrics.event.EventSubmitter; -import gobblin.util.HadoopUtils; -import gobblin.util.WriterUtils; +import org.apache.gobblin.compaction.dataset.DatasetHelper; +import org.apache.gobblin.compaction.event.CompactionSlaEventHelper; +import org.apache.gobblin.compaction.mapreduce.CompactionAvroJobConfigurator; +import org.apache.gobblin.compaction.mapreduce.MRCompactor; +import org.apache.gobblin.compaction.mapreduce.MRCompactorJobRunner; +import org.apache.gobblin.compaction.mapreduce.avro.AvroKeyMapper; +import org.apache.gobblin.compaction.parser.CompactionPathParser; +import org.apache.gobblin.compaction.verify.InputRecordCountHelper; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.dataset.FileSystemDataset; +import org.apache.gobblin.metrics.event.EventSubmitter; +import org.apache.gobblin.util.HadoopUtils; +import org.apache.gobblin.util.WriterUtils; import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.apache.hadoop.fs.FileSystem; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/action/CompactionHiveRegistrationAction.java ---------------------------------------------------------------------- diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/action/CompactionHiveRegistrationAction.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/action/CompactionHiveRegistrationAction.java index f386353..7792a50 100644 --- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/action/CompactionHiveRegistrationAction.java +++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/action/CompactionHiveRegistrationAction.java @@ -15,19 +15,19 @@ * limitations under the License. */ -package gobblin.compaction.action; +package org.apache.gobblin.compaction.action; -import gobblin.compaction.event.CompactionSlaEventHelper; -import gobblin.compaction.parser.CompactionPathParser; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.dataset.FileSystemDataset; -import gobblin.hive.HiveRegister; -import gobblin.hive.policy.HiveRegistrationPolicy; -import gobblin.hive.policy.HiveRegistrationPolicyBase; -import gobblin.hive.spec.HiveSpec; -import gobblin.metrics.event.EventSubmitter; +import org.apache.gobblin.compaction.event.CompactionSlaEventHelper; +import org.apache.gobblin.compaction.parser.CompactionPathParser; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.dataset.FileSystemDataset; +import org.apache.gobblin.hive.HiveRegister; +import org.apache.gobblin.hive.policy.HiveRegistrationPolicy; +import org.apache.gobblin.hive.policy.HiveRegistrationPolicyBase; +import org.apache.gobblin.hive.spec.HiveSpec; +import org.apache.gobblin.metrics.event.EventSubmitter; import lombok.extern.slf4j.Slf4j; import org.apache.hadoop.fs.Path; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/action/CompactionMarkDirectoryAction.java ---------------------------------------------------------------------- diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/action/CompactionMarkDirectoryAction.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/action/CompactionMarkDirectoryAction.java index f071c5b..b504996 100644 --- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/action/CompactionMarkDirectoryAction.java +++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/action/CompactionMarkDirectoryAction.java @@ -15,15 +15,15 @@ * limitations under the License. */ -package gobblin.compaction.action; +package org.apache.gobblin.compaction.action; -import gobblin.compaction.event.CompactionSlaEventHelper; -import gobblin.compaction.mapreduce.CompactionAvroJobConfigurator; -import gobblin.compaction.mapreduce.MRCompactor; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.dataset.FileSystemDataset; -import gobblin.metrics.event.EventSubmitter; +import org.apache.gobblin.compaction.event.CompactionSlaEventHelper; +import org.apache.gobblin.compaction.mapreduce.CompactionAvroJobConfigurator; +import org.apache.gobblin.compaction.mapreduce.MRCompactor; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.dataset.FileSystemDataset; +import org.apache.gobblin.metrics.event.EventSubmitter; import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/audit/AuditCountClient.java ---------------------------------------------------------------------- diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/audit/AuditCountClient.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/audit/AuditCountClient.java index 3a9334e..b9179f3 100644 --- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/audit/AuditCountClient.java +++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/audit/AuditCountClient.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.compaction.audit; +package org.apache.gobblin.compaction.audit; import java.io.IOException; import java.util.Map; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/audit/AuditCountClientFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/audit/AuditCountClientFactory.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/audit/AuditCountClientFactory.java index f16076c..48748db 100644 --- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/audit/AuditCountClientFactory.java +++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/audit/AuditCountClientFactory.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.compaction.audit; +package org.apache.gobblin.compaction.audit; -import gobblin.configuration.State; +import org.apache.gobblin.configuration.State; /** * A factory class responsible for creating {@link AuditCountClient} http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/audit/KafkaAuditCountHttpClient.java ---------------------------------------------------------------------- diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/audit/KafkaAuditCountHttpClient.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/audit/KafkaAuditCountHttpClient.java index 5c0554f..7f6fb68 100644 --- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/audit/KafkaAuditCountHttpClient.java +++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/audit/KafkaAuditCountHttpClient.java @@ -15,14 +15,14 @@ * limitations under the License. */ -package gobblin.compaction.audit; +package org.apache.gobblin.compaction.audit; import com.google.common.annotations.VisibleForTesting; import com.google.common.collect.Maps; import com.google.gson.JsonElement; import com.google.gson.JsonObject; import com.google.gson.JsonParser; -import gobblin.configuration.State; +import org.apache.gobblin.configuration.State; import javax.annotation.concurrent.ThreadSafe; import lombok.extern.slf4j.Slf4j; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/audit/KafkaAuditCountHttpClientFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/audit/KafkaAuditCountHttpClientFactory.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/audit/KafkaAuditCountHttpClientFactory.java index efbb7b9..21f7104 100644 --- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/audit/KafkaAuditCountHttpClientFactory.java +++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/audit/KafkaAuditCountHttpClientFactory.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package gobblin.compaction.audit; +package org.apache.gobblin.compaction.audit; -import gobblin.annotation.Alias; -import gobblin.configuration.State; +import org.apache.gobblin.annotation.Alias; +import org.apache.gobblin.configuration.State; /** * Factory to create an instance of type {@link KafkaAuditCountHttpClient} http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/audit/PinotAuditCountHttpClient.java ---------------------------------------------------------------------- diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/audit/PinotAuditCountHttpClient.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/audit/PinotAuditCountHttpClient.java index 8ab299d..0e06606 100644 --- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/audit/PinotAuditCountHttpClient.java +++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/audit/PinotAuditCountHttpClient.java @@ -15,14 +15,14 @@ * limitations under the License. */ -package gobblin.compaction.audit; +package org.apache.gobblin.compaction.audit; import com.google.api.client.util.Charsets; import com.google.gson.JsonArray; import com.google.gson.JsonElement; import com.google.gson.JsonObject; import com.google.gson.JsonParser; -import gobblin.configuration.State; +import org.apache.gobblin.configuration.State; import javax.annotation.concurrent.ThreadSafe; import lombok.extern.slf4j.Slf4j; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/audit/PinotAuditCountHttpClientFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/audit/PinotAuditCountHttpClientFactory.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/audit/PinotAuditCountHttpClientFactory.java index 93cac78..dca333e 100644 --- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/audit/PinotAuditCountHttpClientFactory.java +++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/audit/PinotAuditCountHttpClientFactory.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package gobblin.compaction.audit; +package org.apache.gobblin.compaction.audit; -import gobblin.annotation.Alias; -import gobblin.configuration.State; +import org.apache.gobblin.annotation.Alias; +import org.apache.gobblin.configuration.State; /** * Factory to create an instance of type {@link PinotAuditCountHttpClient} http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/conditions/RecompactionCombineCondition.java ---------------------------------------------------------------------- diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/conditions/RecompactionCombineCondition.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/conditions/RecompactionCombineCondition.java index fc0cddb..811be5b 100644 --- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/conditions/RecompactionCombineCondition.java +++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/conditions/RecompactionCombineCondition.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.compaction.conditions; +package org.apache.gobblin.compaction.conditions; import java.lang.reflect.InvocationTargetException; @@ -25,12 +25,12 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; import com.google.common.collect.ImmutableList; -import gobblin.annotation.Alias; -import gobblin.compaction.dataset.DatasetHelper; -import gobblin.compaction.dataset.Dataset; -import gobblin.compaction.mapreduce.MRCompactor; -import gobblin.util.ClassAliasResolver; -import gobblin.util.reflection.GobblinConstructorUtils; +import org.apache.gobblin.annotation.Alias; +import org.apache.gobblin.compaction.dataset.DatasetHelper; +import org.apache.gobblin.compaction.dataset.Dataset; +import org.apache.gobblin.compaction.mapreduce.MRCompactor; +import org.apache.gobblin.util.ClassAliasResolver; +import org.apache.gobblin.util.reflection.GobblinConstructorUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/conditions/RecompactionCondition.java ---------------------------------------------------------------------- diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/conditions/RecompactionCondition.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/conditions/RecompactionCondition.java index c7bb6da..46c40d8 100644 --- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/conditions/RecompactionCondition.java +++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/conditions/RecompactionCondition.java @@ -15,8 +15,8 @@ * limitations under the License. */ -package gobblin.compaction.conditions; -import gobblin.compaction.dataset.DatasetHelper; +package org.apache.gobblin.compaction.conditions; +import org.apache.gobblin.compaction.dataset.DatasetHelper; /** * There are different recompaction conditions and their combinations in Gobblin recompaction flow . For example, http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/conditions/RecompactionConditionBasedOnDuration.java ---------------------------------------------------------------------- diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/conditions/RecompactionConditionBasedOnDuration.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/conditions/RecompactionConditionBasedOnDuration.java index a565349..c432ed2 100644 --- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/conditions/RecompactionConditionBasedOnDuration.java +++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/conditions/RecompactionConditionBasedOnDuration.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package gobblin.compaction.conditions; +package org.apache.gobblin.compaction.conditions; -import gobblin.annotation.Alias; -import gobblin.compaction.dataset.DatasetHelper; -import gobblin.compaction.dataset.Dataset; -import gobblin.compaction.mapreduce.MRCompactor; +import org.apache.gobblin.annotation.Alias; +import org.apache.gobblin.compaction.dataset.DatasetHelper; +import org.apache.gobblin.compaction.dataset.Dataset; +import org.apache.gobblin.compaction.mapreduce.MRCompactor; import org.joda.time.DateTime; import org.joda.time.Period; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/conditions/RecompactionConditionBasedOnFileCount.java ---------------------------------------------------------------------- diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/conditions/RecompactionConditionBasedOnFileCount.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/conditions/RecompactionConditionBasedOnFileCount.java index afbd400..b8817fe 100644 --- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/conditions/RecompactionConditionBasedOnFileCount.java +++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/conditions/RecompactionConditionBasedOnFileCount.java @@ -15,14 +15,14 @@ * limitations under the License. */ -package gobblin.compaction.conditions; +package org.apache.gobblin.compaction.conditions; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import gobblin.annotation.Alias; -import gobblin.compaction.dataset.DatasetHelper; -import gobblin.compaction.mapreduce.MRCompactor; -import gobblin.compaction.dataset.Dataset; +import org.apache.gobblin.annotation.Alias; +import org.apache.gobblin.compaction.dataset.DatasetHelper; +import org.apache.gobblin.compaction.mapreduce.MRCompactor; +import org.apache.gobblin.compaction.dataset.Dataset; /** * An implementation {@link RecompactionCondition} which examines the number of files in the late outputDir
