You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gobblin.apache.org by ab...@apache.org on 2017/07/31 07:52:53 UTC
[35/77] [abbrv] incubator-gobblin git commit: Updated package names,
imports and shell scripts
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-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