gobblin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a...@apache.org
Subject [21/77] [abbrv] incubator-gobblin git commit: Updated package names, imports and shell scripts
Date Mon, 31 Jul 2017 07:52:39 GMT
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/UnixTimestampVersionFinderTest.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/UnixTimestampVersionFinderTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/UnixTimestampVersionFinderTest.java
index f28347d..bd105a0 100644
--- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/UnixTimestampVersionFinderTest.java
+++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/UnixTimestampVersionFinderTest.java
@@ -15,11 +15,11 @@
  * limitations under the License.
  */
 
-package gobblin.data.management.retention;
+package org.apache.gobblin.data.management.retention;
 
-import gobblin.data.management.retention.version.TimestampedDatasetVersion;
-import gobblin.data.management.retention.version.finder.UnixTimestampVersionFinder;
-import gobblin.data.management.retention.version.finder.WatermarkDatasetVersionFinder;
+import org.apache.gobblin.data.management.retention.version.TimestampedDatasetVersion;
+import org.apache.gobblin.data.management.retention.version.finder.UnixTimestampVersionFinder;
+import org.apache.gobblin.data.management.retention.version.finder.WatermarkDatasetVersionFinder;
 
 import java.util.Properties;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/WatermarkDatasetVersionFinderTest.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/WatermarkDatasetVersionFinderTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/WatermarkDatasetVersionFinderTest.java
index 12301f3..6ca40ca 100644
--- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/WatermarkDatasetVersionFinderTest.java
+++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/WatermarkDatasetVersionFinderTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.data.management.retention;
+package org.apache.gobblin.data.management.retention;
 
 import java.util.Properties;
 
@@ -23,8 +23,8 @@ import org.apache.hadoop.fs.Path;
 import org.testng.Assert;
 import org.testng.annotations.Test;
 
-import gobblin.data.management.retention.version.StringDatasetVersion;
-import gobblin.data.management.retention.version.finder.WatermarkDatasetVersionFinder;
+import org.apache.gobblin.data.management.retention.version.StringDatasetVersion;
+import org.apache.gobblin.data.management.retention.version.finder.WatermarkDatasetVersionFinder;
 
 
 public class WatermarkDatasetVersionFinderTest {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/action/RetentionActionTest.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/action/RetentionActionTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/action/RetentionActionTest.java
index 9f1cccb..b15c78f 100644
--- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/action/RetentionActionTest.java
+++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/action/RetentionActionTest.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.data.management.retention.action;
+package org.apache.gobblin.data.management.retention.action;
 
 import org.testng.Assert;
 import org.testng.annotations.Test;
@@ -22,7 +22,7 @@ import org.testng.annotations.Test;
 import com.google.common.collect.ImmutableMap;
 import com.typesafe.config.ConfigFactory;
 
-import gobblin.data.management.policy.SelectAfterTimeBasedPolicy;
+import org.apache.gobblin.data.management.policy.SelectAfterTimeBasedPolicy;
 
 
 @Test(groups = { "gobblin.data.management.retention" })

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/integration/HiveRetentionTest.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/integration/HiveRetentionTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/integration/HiveRetentionTest.java
index 8aeabec..2db01c3 100644
--- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/integration/HiveRetentionTest.java
+++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/integration/HiveRetentionTest.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.data.management.retention.integration;
+package org.apache.gobblin.data.management.retention.integration;
 
 import static org.hamcrest.MatcherAssert.assertThat;
 import static org.hamcrest.Matchers.containsInAnyOrder;
@@ -42,11 +42,11 @@ import com.google.common.collect.FluentIterable;
 import com.google.common.collect.ImmutableList;
 import com.google.common.io.Files;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.data.management.conversion.hive.LocalHiveMetastoreTestUtils;
-import gobblin.util.PathUtils;
-import gobblin.util.test.RetentionTestDataGenerator.FixedThreadLocalMillisProvider;
-import gobblin.util.test.RetentionTestHelper;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.data.management.conversion.hive.LocalHiveMetastoreTestUtils;
+import org.apache.gobblin.util.PathUtils;
+import org.apache.gobblin.util.test.RetentionTestDataGenerator.FixedThreadLocalMillisProvider;
+import org.apache.gobblin.util.test.RetentionTestHelper;
 
 @Test(groups = { "SystemTimeTests"})
 public class HiveRetentionTest {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/integration/RetentionIntegrationTest.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/integration/RetentionIntegrationTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/integration/RetentionIntegrationTest.java
index 0397024..68c25f4 100644
--- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/integration/RetentionIntegrationTest.java
+++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/integration/RetentionIntegrationTest.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.data.management.retention.integration;
+package org.apache.gobblin.data.management.retention.integration;
 
 import lombok.extern.slf4j.Slf4j;
 
@@ -28,9 +28,9 @@ import org.testng.annotations.Test;
 
 import com.google.common.io.Files;
 
-import gobblin.util.PathUtils;
-import gobblin.util.test.RetentionTestDataGenerator;
-import gobblin.util.test.RetentionTestHelper;
+import org.apache.gobblin.util.PathUtils;
+import org.apache.gobblin.util.test.RetentionTestDataGenerator;
+import org.apache.gobblin.util.test.RetentionTestHelper;
 
 /**
  *

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/sql/SqlBasedRetentionPoc.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/sql/SqlBasedRetentionPoc.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/sql/SqlBasedRetentionPoc.java
index a777862..e3d56f3 100644
--- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/sql/SqlBasedRetentionPoc.java
+++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/sql/SqlBasedRetentionPoc.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.data.management.retention.sql;
+package org.apache.gobblin.data.management.retention.sql;
 
 import java.sql.Connection;
 import java.sql.PreparedStatement;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/sql/SqlUdfs.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/sql/SqlUdfs.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/sql/SqlUdfs.java
index c2f964f..336c13f 100644
--- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/sql/SqlUdfs.java
+++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/sql/SqlUdfs.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.data.management.retention.sql;
+package org.apache.gobblin.data.management.retention.sql;
 
 import java.sql.Timestamp;
 import java.util.concurrent.TimeUnit;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/test/ContainsARetentionPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/test/ContainsARetentionPolicy.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/test/ContainsARetentionPolicy.java
index 5eae906..01538d0 100644
--- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/test/ContainsARetentionPolicy.java
+++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/test/ContainsARetentionPolicy.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.data.management.retention.test;
+package org.apache.gobblin.data.management.retention.test;
 
 import java.util.Properties;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/test/ContainsBRetentionPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/test/ContainsBRetentionPolicy.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/test/ContainsBRetentionPolicy.java
index 53e3100..47e5b9f 100644
--- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/test/ContainsBRetentionPolicy.java
+++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/test/ContainsBRetentionPolicy.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.data.management.retention.test;
+package org.apache.gobblin.data.management.retention.test;
 
 import java.util.Properties;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/test/ContainsCRetentionPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/test/ContainsCRetentionPolicy.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/test/ContainsCRetentionPolicy.java
index d9a9ac0..3d4dc9c 100644
--- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/test/ContainsCRetentionPolicy.java
+++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/test/ContainsCRetentionPolicy.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.data.management.retention.test;
+package org.apache.gobblin.data.management.retention.test;
 
 import java.util.Properties;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/test/ContainsStringRetentionPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/test/ContainsStringRetentionPolicy.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/test/ContainsStringRetentionPolicy.java
index d4b97f8..4184f0b 100644
--- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/test/ContainsStringRetentionPolicy.java
+++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/test/ContainsStringRetentionPolicy.java
@@ -15,11 +15,11 @@
  * limitations under the License.
  */
 
-package gobblin.data.management.retention.test;
+package org.apache.gobblin.data.management.retention.test;
 
-import gobblin.data.management.retention.policy.RetentionPolicy;
-import gobblin.data.management.version.DatasetVersion;
-import gobblin.data.management.version.StringDatasetVersion;
+import org.apache.gobblin.data.management.retention.policy.RetentionPolicy;
+import org.apache.gobblin.data.management.version.DatasetVersion;
+import org.apache.gobblin.data.management.version.StringDatasetVersion;
 
 import java.util.Collection;
 import java.util.List;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/version/HiveDatasetVersionCleanerTest.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/version/HiveDatasetVersionCleanerTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/version/HiveDatasetVersionCleanerTest.java
index cd60214..f70bd92 100644
--- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/version/HiveDatasetVersionCleanerTest.java
+++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/version/HiveDatasetVersionCleanerTest.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.data.management.retention.version;
+package org.apache.gobblin.data.management.retention.version;
 
 import java.io.IOException;
 
@@ -26,7 +26,7 @@ import com.typesafe.config.ConfigFactory;
 import org.testng.Assert;
 import org.testng.annotations.Test;
 
-import gobblin.data.management.retention.version.HiveDatasetVersionCleaner;
+import org.apache.gobblin.data.management.retention.version.HiveDatasetVersionCleaner;
 
 
 public class HiveDatasetVersionCleanerTest {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/trash/AsyncTrashTest.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/trash/AsyncTrashTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/trash/AsyncTrashTest.java
index b23301d..0a3e133 100644
--- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/trash/AsyncTrashTest.java
+++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/trash/AsyncTrashTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.data.management.trash;
+package org.apache.gobblin.data.management.trash;
 
 
 import java.util.Properties;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/trash/MockTrashTest.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/trash/MockTrashTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/trash/MockTrashTest.java
index 4ab21fa..3857212 100644
--- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/trash/MockTrashTest.java
+++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/trash/MockTrashTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.data.management.trash;
+package org.apache.gobblin.data.management.trash;
 
 import java.io.IOException;
 import java.util.Properties;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/trash/TestCleanupPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/trash/TestCleanupPolicy.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/trash/TestCleanupPolicy.java
index 0495861..0f7c8de 100644
--- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/trash/TestCleanupPolicy.java
+++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/trash/TestCleanupPolicy.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.data.management.trash;
+package org.apache.gobblin.data.management.trash;
 
 import java.util.Properties;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/trash/TestTrashTest.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/trash/TestTrashTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/trash/TestTrashTest.java
index b2b84b6..6df06f5 100644
--- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/trash/TestTrashTest.java
+++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/trash/TestTrashTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.data.management.trash;
+package org.apache.gobblin.data.management.trash;
 
 import java.io.IOException;
 import java.util.Arrays;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/trash/TrashFactoryTest.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/trash/TrashFactoryTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/trash/TrashFactoryTest.java
index e25242c..8a1d2ad 100644
--- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/trash/TrashFactoryTest.java
+++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/trash/TrashFactoryTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.data.management.trash;
+package org.apache.gobblin.data.management.trash;
 
 import java.io.IOException;
 import java.util.Properties;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/trash/TrashTest.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/trash/TrashTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/trash/TrashTest.java
index 6d760b6..be2691c 100644
--- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/trash/TrashTest.java
+++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/trash/TrashTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.data.management.trash;
+package org.apache.gobblin.data.management.trash;
 
 
 import java.io.IOException;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/trash/TrashTestBase.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/trash/TrashTestBase.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/trash/TrashTestBase.java
index 3c6f9b1..237198a 100644
--- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/trash/TrashTestBase.java
+++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/trash/TrashTestBase.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.data.management.trash;
+package org.apache.gobblin.data.management.trash;
 
 import java.io.IOException;
 import java.util.Properties;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/util/PathUtilsTest.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/util/PathUtilsTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/util/PathUtilsTest.java
index 82ed884..ba7b144 100644
--- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/util/PathUtilsTest.java
+++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/util/PathUtilsTest.java
@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package gobblin.data.management.util;
+package org.apache.gobblin.data.management.util;
 
-import gobblin.util.PathUtils;
+import org.apache.gobblin.util.PathUtils;
 import org.apache.hadoop.fs.Path;
 import org.testng.Assert;
 import org.testng.annotations.Test;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/version/finder/DatePartitionedHiveVersionFinderTest.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/version/finder/DatePartitionedHiveVersionFinderTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/version/finder/DatePartitionedHiveVersionFinderTest.java
index f8286a5..e028c34 100644
--- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/version/finder/DatePartitionedHiveVersionFinderTest.java
+++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/version/finder/DatePartitionedHiveVersionFinderTest.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.data.management.version.finder;
+package org.apache.gobblin.data.management.version.finder;
 
 import static org.hamcrest.MatcherAssert.assertThat;
 import static org.hamcrest.Matchers.anyOf;
@@ -39,9 +39,9 @@ import com.google.common.collect.ImmutableMap;
 import com.typesafe.config.Config;
 import com.typesafe.config.ConfigFactory;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.data.management.conversion.hive.LocalHiveMetastoreTestUtils;
-import gobblin.data.management.version.TimestampedHiveDatasetVersion;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.data.management.conversion.hive.LocalHiveMetastoreTestUtils;
+import org.apache.gobblin.data.management.version.TimestampedHiveDatasetVersion;
 
 
 @Test(groups = { "gobblin.data.management.version" })

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblinDistcpTest.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblinDistcpTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblinDistcpTest.java
index a7b485c..3b289c0 100644
--- a/gobblin-data-management/src/test/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblinDistcpTest.java
+++ b/gobblin-data-management/src/test/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblinDistcpTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.embedded;
+package org.apache.gobblin.runtime.embedded;
 
 import java.io.File;
 import java.io.FileOutputStream;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/util/request_allocation/SimpleHiveDatasetTieringPrioritizerTest.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/util/request_allocation/SimpleHiveDatasetTieringPrioritizerTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/util/request_allocation/SimpleHiveDatasetTieringPrioritizerTest.java
index 5a681f7..0173765 100644
--- a/gobblin-data-management/src/test/java/org/apache/gobblin/util/request_allocation/SimpleHiveDatasetTieringPrioritizerTest.java
+++ b/gobblin-data-management/src/test/java/org/apache/gobblin/util/request_allocation/SimpleHiveDatasetTieringPrioritizerTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
 
 
 import java.util.Properties;
@@ -25,8 +25,8 @@ import org.mockito.Mockito;
 import org.testng.Assert;
 import org.testng.annotations.Test;
 
-import gobblin.data.management.copy.hive.HiveDataset;
-import gobblin.data.management.partition.CopyableDatasetRequestor;
+import org.apache.gobblin.data.management.copy.hive.HiveDataset;
+import org.apache.gobblin.data.management.partition.CopyableDatasetRequestor;
 
 
 public class SimpleHiveDatasetTieringPrioritizerTest {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-example/src/main/java/org/apache/gobblin/example/simplejson/SimpleJsonConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-example/src/main/java/org/apache/gobblin/example/simplejson/SimpleJsonConverter.java b/gobblin-example/src/main/java/org/apache/gobblin/example/simplejson/SimpleJsonConverter.java
index 7558618..7fbabff 100644
--- a/gobblin-example/src/main/java/org/apache/gobblin/example/simplejson/SimpleJsonConverter.java
+++ b/gobblin-example/src/main/java/org/apache/gobblin/example/simplejson/SimpleJsonConverter.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.example.simplejson;
+package org.apache.gobblin.example.simplejson;
 
 import java.lang.reflect.Type;
 import java.util.Map;
@@ -28,12 +28,12 @@ import com.google.gson.Gson;
 import com.google.gson.JsonElement;
 import com.google.gson.reflect.TypeToken;
 
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.Converter;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.SchemaConversionException;
-import gobblin.converter.SingleRecordIterable;
-import gobblin.converter.ToAvroConverterBase;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.Converter;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.converter.SingleRecordIterable;
+import org.apache.gobblin.converter.ToAvroConverterBase;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-example/src/main/java/org/apache/gobblin/example/simplejson/SimpleJsonExtractor.java
----------------------------------------------------------------------
diff --git a/gobblin-example/src/main/java/org/apache/gobblin/example/simplejson/SimpleJsonExtractor.java b/gobblin-example/src/main/java/org/apache/gobblin/example/simplejson/SimpleJsonExtractor.java
index 89b3476..e8e922c 100644
--- a/gobblin-example/src/main/java/org/apache/gobblin/example/simplejson/SimpleJsonExtractor.java
+++ b/gobblin-example/src/main/java/org/apache/gobblin/example/simplejson/SimpleJsonExtractor.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.example.simplejson;
+package org.apache.gobblin.example.simplejson;
 
 import java.io.BufferedReader;
 import java.io.IOException;
@@ -33,11 +33,11 @@ import org.slf4j.LoggerFactory;
 
 import com.google.common.io.Closer;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.password.PasswordManager;
-import gobblin.source.extractor.DataRecordException;
-import gobblin.source.extractor.Extractor;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.password.PasswordManager;
+import org.apache.gobblin.source.extractor.DataRecordException;
+import org.apache.gobblin.source.extractor.Extractor;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-example/src/main/java/org/apache/gobblin/example/simplejson/SimpleJsonSource.java
----------------------------------------------------------------------
diff --git a/gobblin-example/src/main/java/org/apache/gobblin/example/simplejson/SimpleJsonSource.java b/gobblin-example/src/main/java/org/apache/gobblin/example/simplejson/SimpleJsonSource.java
index 91a3811..bb8c495 100644
--- a/gobblin-example/src/main/java/org/apache/gobblin/example/simplejson/SimpleJsonSource.java
+++ b/gobblin-example/src/main/java/org/apache/gobblin/example/simplejson/SimpleJsonSource.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.example.simplejson;
+package org.apache.gobblin.example.simplejson;
 
 import java.io.IOException;
 import java.util.List;
@@ -23,13 +23,13 @@ import java.util.List;
 import com.google.common.base.Splitter;
 import com.google.common.collect.Lists;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.SourceState;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.Source;
-import gobblin.source.extractor.Extractor;
-import gobblin.source.workunit.Extract;
-import gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.SourceState;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.Source;
+import org.apache.gobblin.source.extractor.Extractor;
+import org.apache.gobblin.source.workunit.Extract;
+import org.apache.gobblin.source.workunit.WorkUnit;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/EmbeddedWikipediaExample.java
----------------------------------------------------------------------
diff --git a/gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/EmbeddedWikipediaExample.java b/gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/EmbeddedWikipediaExample.java
index edeca69..f30c61b 100644
--- a/gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/EmbeddedWikipediaExample.java
+++ b/gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/EmbeddedWikipediaExample.java
@@ -15,26 +15,26 @@
  * limitations under the License.
  */
 
-package gobblin.example.wikipedia;
+package org.apache.gobblin.example.wikipedia;
 
 import java.io.IOException;
 import java.net.URISyntaxException;
 
 import org.apache.commons.cli.CommandLine;
 
-import gobblin.annotation.Alias;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.publisher.BaseDataPublisher;
-import gobblin.runtime.api.JobTemplate;
-import gobblin.runtime.api.SpecNotFoundException;
-import gobblin.runtime.cli.CliObjectOption;
-import gobblin.runtime.cli.CliObjectSupport;
-import gobblin.runtime.cli.PublicMethodsGobblinCliFactory;
-import gobblin.runtime.embedded.EmbeddedGobblin;
-import gobblin.runtime.template.ResourceBasedJobTemplate;
-import gobblin.writer.AvroDataWriterBuilder;
-import gobblin.writer.Destination;
-import gobblin.writer.WriterOutputFormat;
+import org.apache.gobblin.annotation.Alias;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.publisher.BaseDataPublisher;
+import org.apache.gobblin.runtime.api.JobTemplate;
+import org.apache.gobblin.runtime.api.SpecNotFoundException;
+import org.apache.gobblin.runtime.cli.CliObjectOption;
+import org.apache.gobblin.runtime.cli.CliObjectSupport;
+import org.apache.gobblin.runtime.cli.PublicMethodsGobblinCliFactory;
+import org.apache.gobblin.runtime.embedded.EmbeddedGobblin;
+import org.apache.gobblin.runtime.template.ResourceBasedJobTemplate;
+import org.apache.gobblin.writer.AvroDataWriterBuilder;
+import org.apache.gobblin.writer.Destination;
+import org.apache.gobblin.writer.WriterOutputFormat;
 
 import avro.shaded.com.google.common.base.Joiner;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/WikipediaConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/WikipediaConverter.java b/gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/WikipediaConverter.java
index 2928f3c..9ba71b7 100644
--- a/gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/WikipediaConverter.java
+++ b/gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/WikipediaConverter.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.example.wikipedia;
+package org.apache.gobblin.example.wikipedia;
 
 import java.lang.reflect.Type;
 import java.util.Map;
@@ -28,9 +28,9 @@ import com.google.gson.Gson;
 import com.google.gson.JsonElement;
 import com.google.gson.reflect.TypeToken;
 
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.SingleRecordIterable;
-import gobblin.converter.ToAvroConverterBase;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.SingleRecordIterable;
+import org.apache.gobblin.converter.ToAvroConverterBase;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/WikipediaExtractor.java
----------------------------------------------------------------------
diff --git a/gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/WikipediaExtractor.java b/gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/WikipediaExtractor.java
index 298135d..0809126 100644
--- a/gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/WikipediaExtractor.java
+++ b/gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/WikipediaExtractor.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.example.wikipedia;
+package org.apache.gobblin.example.wikipedia;
 
 import java.io.BufferedReader;
 import java.io.Closeable;
@@ -59,13 +59,13 @@ import com.google.gson.JsonArray;
 import com.google.gson.JsonElement;
 import com.google.gson.JsonObject;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.http.HttpClientConfigurator;
-import gobblin.http.HttpClientConfiguratorLoader;
-import gobblin.source.extractor.DataRecordException;
-import gobblin.source.extractor.Extractor;
-import gobblin.source.extractor.extract.LongWatermark;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.http.HttpClientConfigurator;
+import org.apache.gobblin.http.HttpClientConfiguratorLoader;
+import org.apache.gobblin.source.extractor.DataRecordException;
+import org.apache.gobblin.source.extractor.Extractor;
+import org.apache.gobblin.source.extractor.extract.LongWatermark;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/WikipediaPartitioner.java
----------------------------------------------------------------------
diff --git a/gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/WikipediaPartitioner.java b/gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/WikipediaPartitioner.java
index ad7ec96..7a93eba 100644
--- a/gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/WikipediaPartitioner.java
+++ b/gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/WikipediaPartitioner.java
@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package gobblin.example.wikipedia;
+package org.apache.gobblin.example.wikipedia;
 
-import gobblin.configuration.State;
-import gobblin.writer.partitioner.WriterPartitioner;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.writer.partitioner.WriterPartitioner;
 
 import org.apache.avro.Schema;
 import org.apache.avro.SchemaBuilder;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/WikipediaSource.java
----------------------------------------------------------------------
diff --git a/gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/WikipediaSource.java b/gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/WikipediaSource.java
index 5ea8770..8e41796 100644
--- a/gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/WikipediaSource.java
+++ b/gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/WikipediaSource.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.example.wikipedia;
+package org.apache.gobblin.example.wikipedia;
 
 import java.io.IOException;
 import java.util.Collections;
@@ -31,17 +31,17 @@ import com.google.common.collect.Lists;
 import com.google.common.collect.Maps;
 import com.google.gson.JsonElement;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.SourceState;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.Source;
-import gobblin.source.extractor.Extractor;
-import gobblin.source.extractor.WatermarkInterval;
-import gobblin.source.extractor.extract.AbstractSource;
-import gobblin.source.extractor.extract.LongWatermark;
-import gobblin.source.workunit.Extract;
-import gobblin.source.workunit.WorkUnit;
-import gobblin.source.workunit.Extract.TableType;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.SourceState;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.Source;
+import org.apache.gobblin.source.extractor.Extractor;
+import org.apache.gobblin.source.extractor.WatermarkInterval;
+import org.apache.gobblin.source.extractor.extract.AbstractSource;
+import org.apache.gobblin.source.extractor.extract.LongWatermark;
+import org.apache.gobblin.source.workunit.Extract;
+import org.apache.gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.source.workunit.Extract.TableType;
 
 /**
  * An implementation of {@link Source} for the Wikipedia example.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveConstants.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveConstants.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveConstants.java
index eb9ab59..8b03e6f 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveConstants.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveConstants.java
@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package gobblin.hive;
+package org.apache.gobblin.hive;
 
-import gobblin.annotation.Alpha;
+import org.apache.gobblin.annotation.Alpha;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveLock.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveLock.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveLock.java
index 3ec790b..85df169 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveLock.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveLock.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.hive;
+package org.apache.gobblin.hive;
 
 import java.util.concurrent.locks.Lock;
 
@@ -24,7 +24,7 @@ import com.google.common.base.Preconditions;
 import com.google.common.base.Strings;
 import com.google.common.util.concurrent.Striped;
 
-import gobblin.util.AutoCloseableLock;
+import org.apache.gobblin.util.AutoCloseableLock;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveMetaStoreClientFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveMetaStoreClientFactory.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveMetaStoreClientFactory.java
index fd4b320..772b5d0 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveMetaStoreClientFactory.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveMetaStoreClientFactory.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.hive;
+package org.apache.gobblin.hive;
 
 import lombok.Getter;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveMetastoreClientPool.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveMetastoreClientPool.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveMetastoreClientPool.java
index 9f296a9..65cfc44 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveMetastoreClientPool.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveMetastoreClientPool.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.hive;
+package org.apache.gobblin.hive;
 
 import java.io.IOException;
 import java.util.Map;
@@ -37,8 +37,8 @@ import com.google.common.cache.RemovalNotification;
 import com.google.common.collect.Maps;
 import com.google.common.io.Closer;
 
-import gobblin.configuration.State;
-import gobblin.util.AutoReturnableObject;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.util.AutoReturnableObject;
 
 import lombok.Getter;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HivePartition.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HivePartition.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HivePartition.java
index dadc065..11bdbc5 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HivePartition.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HivePartition.java
@@ -15,14 +15,14 @@
  * limitations under the License.
  */
 
-package gobblin.hive;
+package org.apache.gobblin.hive;
 
 import java.util.List;
 
 import com.google.common.collect.ImmutableList;
 import com.google.common.collect.Lists;
 
-import gobblin.annotation.Alpha;
+import org.apache.gobblin.annotation.Alpha;
 import lombok.Getter;
 
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HivePartitionComparator.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HivePartitionComparator.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HivePartitionComparator.java
index 32bdcc4..087d5f5 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HivePartitionComparator.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HivePartitionComparator.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.hive;
+package org.apache.gobblin.hive;
 
 import com.google.common.base.Optional;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegProps.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegProps.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegProps.java
index 7ecc857..fd5d8e8 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegProps.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegProps.java
@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package gobblin.hive;
+package org.apache.gobblin.hive;
 
-import gobblin.hive.metastore.HiveMetaStoreUtils;
+import org.apache.gobblin.hive.metastore.HiveMetaStoreUtils;
 import java.util.List;
 
 import com.google.common.base.Optional;
@@ -27,9 +27,9 @@ import com.google.common.base.Splitter;
 import lombok.EqualsAndHashCode;
 import lombok.Getter;
 
-import gobblin.annotation.Alpha;
-import gobblin.configuration.State;
-import gobblin.hive.metastore.HiveMetaStoreBasedRegister;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.hive.metastore.HiveMetaStoreBasedRegister;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegister.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegister.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegister.java
index 0212226..66cce96 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegister.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegister.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.hive;
+package org.apache.gobblin.hive;
 
 import java.io.Closeable;
 import java.io.IOException;
@@ -37,16 +37,16 @@ import com.google.common.collect.Maps;
 import com.google.common.util.concurrent.ListenableFuture;
 import com.google.common.util.concurrent.ListeningExecutorService;
 
-import gobblin.annotation.Alpha;
-import gobblin.configuration.State;
-import gobblin.hive.HiveRegistrationUnit.Column;
-import gobblin.hive.spec.HiveSpec;
-import gobblin.hive.spec.HiveSpecWithPostActivities;
-import gobblin.hive.spec.HiveSpecWithPreActivities;
-import gobblin.hive.spec.HiveSpecWithPredicates;
-import gobblin.hive.spec.activity.Activity;
-import gobblin.util.ExecutorsUtils;
-import gobblin.util.executors.ScalingThreadPoolExecutor;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.hive.HiveRegistrationUnit.Column;
+import org.apache.gobblin.hive.spec.HiveSpec;
+import org.apache.gobblin.hive.spec.HiveSpecWithPostActivities;
+import org.apache.gobblin.hive.spec.HiveSpecWithPreActivities;
+import org.apache.gobblin.hive.spec.HiveSpecWithPredicates;
+import org.apache.gobblin.hive.spec.activity.Activity;
+import org.apache.gobblin.util.ExecutorsUtils;
+import org.apache.gobblin.util.executors.ScalingThreadPoolExecutor;
 import lombok.Getter;
 import lombok.extern.slf4j.Slf4j;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegisterStep.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegisterStep.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegisterStep.java
index 31ecfa5..eb03266 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegisterStep.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegisterStep.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.hive;
+package org.apache.gobblin.hive;
 
 import java.util.Arrays;
 import lombok.AllArgsConstructor;
@@ -31,8 +31,8 @@ import org.apache.hadoop.fs.Path;
 import com.google.common.base.Optional;
 import com.google.common.util.concurrent.ListenableFuture;
 
-import gobblin.commit.CommitStep;
-import gobblin.hive.spec.HiveSpec;
+import org.apache.gobblin.commit.CommitStep;
+import org.apache.gobblin.hive.spec.HiveSpec;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegisterUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegisterUtils.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegisterUtils.java
index 1a7cecb..035413c 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegisterUtils.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegisterUtils.java
@@ -15,16 +15,16 @@
  * limitations under the License.
  */
 
-package gobblin.hive;
+package org.apache.gobblin.hive;
 
 import java.io.IOException;
 
 import org.apache.hadoop.fs.Path;
 
-import gobblin.configuration.State;
-import gobblin.hive.policy.HiveRegistrationPolicy;
-import gobblin.hive.policy.HiveRegistrationPolicyBase;
-import gobblin.hive.spec.HiveSpec;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.hive.policy.HiveRegistrationPolicy;
+import org.apache.gobblin.hive.policy.HiveRegistrationPolicyBase;
+import org.apache.gobblin.hive.spec.HiveSpec;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegistrationUnit.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegistrationUnit.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegistrationUnit.java
index 2caf523..4e82dc6 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegistrationUnit.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegistrationUnit.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.hive;
+package org.apache.gobblin.hive;
 
 import java.io.IOException;
 import java.util.List;
@@ -30,8 +30,8 @@ import com.google.common.collect.ImmutableList;
 import com.google.common.collect.Lists;
 import com.google.common.reflect.TypeToken;
 
-import gobblin.annotation.Alpha;
-import gobblin.configuration.State;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.configuration.State;
 
 import lombok.AllArgsConstructor;
 import lombok.Getter;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegistrationUnitComparator.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegistrationUnitComparator.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegistrationUnitComparator.java
index 4f8e31a..8b76056 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegistrationUnitComparator.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegistrationUnitComparator.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.hive;
+package org.apache.gobblin.hive;
 
 import java.util.Set;
 
@@ -23,8 +23,8 @@ import org.apache.hadoop.fs.Path;
 
 import com.google.common.base.Optional;
 
-import gobblin.annotation.Alpha;
-import gobblin.configuration.State;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.configuration.State;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveSerDeManager.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveSerDeManager.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveSerDeManager.java
index 9ebe1f3..9ed696c 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveSerDeManager.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveSerDeManager.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.hive;
+package org.apache.gobblin.hive;
 
 import java.io.IOException;
 
@@ -25,9 +25,9 @@ import org.apache.hadoop.fs.Path;
 import com.google.common.base.Enums;
 import com.google.common.base.Optional;
 
-import gobblin.annotation.Alpha;
-import gobblin.configuration.State;
-import gobblin.hive.avro.HiveAvroSerDeManager;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.hive.avro.HiveAvroSerDeManager;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveSerDeWrapper.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveSerDeWrapper.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveSerDeWrapper.java
index 9ea9e46..fea2e99 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveSerDeWrapper.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveSerDeWrapper.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.hive;
+package org.apache.gobblin.hive;
 
 import java.io.IOException;
 
@@ -37,8 +37,8 @@ import com.google.common.base.Enums;
 import com.google.common.base.Optional;
 import com.google.common.base.Preconditions;
 
-import gobblin.annotation.Alpha;
-import gobblin.configuration.State;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.configuration.State;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveTable.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveTable.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveTable.java
index e946abd..9029ebd 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveTable.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveTable.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.hive;
+package org.apache.gobblin.hive;
 
 import java.util.List;
 
@@ -24,8 +24,8 @@ import com.google.common.collect.ImmutableList;
 import com.google.common.collect.Lists;
 import com.google.common.reflect.TypeToken;
 
-import gobblin.annotation.Alpha;
-import gobblin.configuration.State;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.configuration.State;
 import lombok.Getter;
 import lombok.Setter;
 import lombok.ToString;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveTableComparator.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveTableComparator.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveTableComparator.java
index 1408eb1..3e29f1b 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveTableComparator.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveTableComparator.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.hive;
+package org.apache.gobblin.hive;
 
 /**
  * An extension to {@link HiveRegistrationUnitComparator} for {@link HiveTable}s.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/PartitionDeregisterStep.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/PartitionDeregisterStep.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/PartitionDeregisterStep.java
index 9e5b39d..550dbbc 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/PartitionDeregisterStep.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/PartitionDeregisterStep.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.hive;
+package org.apache.gobblin.hive;
 
 import java.util.Arrays;
 import lombok.AllArgsConstructor;
@@ -27,8 +27,8 @@ import org.apache.hadoop.hive.metastore.api.Table;
 
 import com.google.common.base.Optional;
 
-import gobblin.commit.CommitStep;
-import gobblin.hive.metastore.HiveMetaStoreUtils;
+import org.apache.gobblin.commit.CommitStep;
+import org.apache.gobblin.hive.metastore.HiveMetaStoreUtils;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/TableDeregisterStep.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/TableDeregisterStep.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/TableDeregisterStep.java
index 8bbd167..274d872 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/TableDeregisterStep.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/TableDeregisterStep.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.hive;
+package org.apache.gobblin.hive;
 
 import lombok.AllArgsConstructor;
 
@@ -25,7 +25,7 @@ import org.apache.hadoop.hive.metastore.api.Table;
 
 import com.google.common.base.Optional;
 
-import gobblin.commit.CommitStep;
+import org.apache.gobblin.commit.CommitStep;
 
 /**
  * {@link CommitStep} to deregister a Hive table.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/avro/HiveAvroSerDeManager.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/avro/HiveAvroSerDeManager.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/avro/HiveAvroSerDeManager.java
index 0547c33..96ebe83 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/avro/HiveAvroSerDeManager.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/avro/HiveAvroSerDeManager.java
@@ -15,11 +15,11 @@
  * limitations under the License.
  */
 
-package gobblin.hive.avro;
+package org.apache.gobblin.hive.avro;
 
 import com.codahale.metrics.Timer;
-import gobblin.instrumented.Instrumented;
-import gobblin.metrics.MetricContext;
+import org.apache.gobblin.instrumented.Instrumented;
+import org.apache.gobblin.metrics.MetricContext;
 import java.io.IOException;
 
 import org.apache.avro.Schema;
@@ -28,13 +28,13 @@ import org.apache.hadoop.fs.Path;
 
 import com.google.common.base.Preconditions;
 
-import gobblin.annotation.Alpha;
-import gobblin.configuration.State;
-import gobblin.hive.HiveRegistrationUnit;
-import gobblin.hive.HiveSerDeManager;
-import gobblin.hive.HiveSerDeWrapper;
-import gobblin.util.AvroUtils;
-import gobblin.util.HadoopUtils;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.hive.HiveRegistrationUnit;
+import org.apache.gobblin.hive.HiveSerDeManager;
+import org.apache.gobblin.hive.HiveSerDeWrapper;
+import org.apache.gobblin.util.AvroUtils;
+import org.apache.gobblin.util.HadoopUtils;
 import lombok.extern.slf4j.Slf4j;
 
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/metastore/HiveMetaStoreBasedRegister.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/metastore/HiveMetaStoreBasedRegister.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/metastore/HiveMetaStoreBasedRegister.java
index 9c724c3..49c08a7 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/metastore/HiveMetaStoreBasedRegister.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/metastore/HiveMetaStoreBasedRegister.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.hive.metastore;
+package org.apache.gobblin.hive.metastore;
 
 import com.google.common.cache.Cache;
 import com.google.common.cache.CacheBuilder;
@@ -44,23 +44,23 @@ import com.google.common.base.Optional;
 import com.google.common.base.Preconditions;
 import com.google.common.primitives.Ints;
 
-import gobblin.annotation.Alpha;
-import gobblin.configuration.State;
-import gobblin.hive.HiveMetaStoreClientFactory;
-import gobblin.hive.HiveLock;
-import gobblin.hive.HiveMetastoreClientPool;
-import gobblin.hive.HivePartition;
-import gobblin.hive.HiveRegProps;
-import gobblin.hive.HiveRegister;
-import gobblin.hive.HiveRegistrationUnit.Column;
-import gobblin.hive.HiveTable;
-import gobblin.hive.spec.HiveSpec;
-import gobblin.metrics.GobblinMetrics;
-import gobblin.metrics.GobblinMetricsRegistry;
-import gobblin.metrics.MetricContext;
-import gobblin.metrics.event.EventSubmitter;
-import gobblin.util.AutoCloseableLock;
-import gobblin.util.AutoReturnableObject;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.hive.HiveMetaStoreClientFactory;
+import org.apache.gobblin.hive.HiveLock;
+import org.apache.gobblin.hive.HiveMetastoreClientPool;
+import org.apache.gobblin.hive.HivePartition;
+import org.apache.gobblin.hive.HiveRegProps;
+import org.apache.gobblin.hive.HiveRegister;
+import org.apache.gobblin.hive.HiveRegistrationUnit.Column;
+import org.apache.gobblin.hive.HiveTable;
+import org.apache.gobblin.hive.spec.HiveSpec;
+import org.apache.gobblin.metrics.GobblinMetrics;
+import org.apache.gobblin.metrics.GobblinMetricsRegistry;
+import org.apache.gobblin.metrics.MetricContext;
+import org.apache.gobblin.metrics.event.EventSubmitter;
+import org.apache.gobblin.util.AutoCloseableLock;
+import org.apache.gobblin.util.AutoReturnableObject;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/metastore/HiveMetaStoreEventHelper.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/metastore/HiveMetaStoreEventHelper.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/metastore/HiveMetaStoreEventHelper.java
index 4bd392e..143ea20 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/metastore/HiveMetaStoreEventHelper.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/metastore/HiveMetaStoreEventHelper.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.hive.metastore;
+package org.apache.gobblin.hive.metastore;
 
 import java.util.List;
 import java.util.Map;
@@ -23,10 +23,10 @@ import java.util.Map;
 import com.google.common.base.Optional;
 import com.google.common.collect.ImmutableMap;
 
-import gobblin.hive.HivePartition;
-import gobblin.hive.HiveTable;
-import gobblin.hive.spec.HiveSpec;
-import gobblin.metrics.event.EventSubmitter;
+import org.apache.gobblin.hive.HivePartition;
+import org.apache.gobblin.hive.HiveTable;
+import org.apache.gobblin.hive.spec.HiveSpec;
+import org.apache.gobblin.metrics.event.EventSubmitter;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/metastore/HiveMetaStoreUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/metastore/HiveMetaStoreUtils.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/metastore/HiveMetaStoreUtils.java
index e4a37e2..61d3f5f 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/metastore/HiveMetaStoreUtils.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/metastore/HiveMetaStoreUtils.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.hive.metastore;
+package org.apache.gobblin.hive.metastore;
 
 import com.google.common.base.Splitter;
 import java.lang.reflect.InvocationTargetException;
@@ -53,13 +53,13 @@ import com.google.common.collect.Lists;
 import com.google.common.collect.Maps;
 import com.google.common.primitives.Ints;
 
-import gobblin.annotation.Alpha;
-import gobblin.configuration.State;
-import gobblin.hive.HiveConstants;
-import gobblin.hive.HivePartition;
-import gobblin.hive.HiveRegistrationUnit;
-import gobblin.hive.HiveRegistrationUnit.Column;
-import gobblin.hive.HiveTable;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.hive.HiveConstants;
+import org.apache.gobblin.hive.HivePartition;
+import org.apache.gobblin.hive.HiveRegistrationUnit;
+import org.apache.gobblin.hive.HiveRegistrationUnit.Column;
+import org.apache.gobblin.hive.HiveTable;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/policy/HiveRegistrationPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/policy/HiveRegistrationPolicy.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/policy/HiveRegistrationPolicy.java
index cb5915a..cca4da0 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/policy/HiveRegistrationPolicy.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/policy/HiveRegistrationPolicy.java
@@ -15,15 +15,15 @@
  * limitations under the License.
  */
 
-package gobblin.hive.policy;
+package org.apache.gobblin.hive.policy;
 
 import java.io.IOException;
 import java.util.Collection;
 
 import org.apache.hadoop.fs.Path;
 
-import gobblin.annotation.Alpha;
-import gobblin.hive.spec.HiveSpec;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.hive.spec.HiveSpec;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/policy/HiveRegistrationPolicyBase.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/policy/HiveRegistrationPolicyBase.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/policy/HiveRegistrationPolicyBase.java
index 96c9f95..728b78f 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/policy/HiveRegistrationPolicyBase.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/policy/HiveRegistrationPolicyBase.java
@@ -15,19 +15,19 @@
  * limitations under the License.
  */
 
-package gobblin.hive.policy;
+package org.apache.gobblin.hive.policy;
 
 import com.codahale.metrics.Timer;
 import com.google.common.base.Splitter;
 import com.typesafe.config.Config;
-import gobblin.config.client.ConfigClient;
-import gobblin.config.client.api.VersionStabilityPolicy;
-import gobblin.hive.HiveRegister;
-import gobblin.hive.metastore.HiveMetaStoreUtils;
-import gobblin.instrumented.Instrumented;
-import gobblin.metrics.MetricContext;
-import gobblin.source.extractor.extract.kafka.ConfigStoreUtils;
-import gobblin.source.extractor.extract.kafka.KafkaSource;
+import org.apache.gobblin.config.client.ConfigClient;
+import org.apache.gobblin.config.client.api.VersionStabilityPolicy;
+import org.apache.gobblin.hive.HiveRegister;
+import org.apache.gobblin.hive.metastore.HiveMetaStoreUtils;
+import org.apache.gobblin.instrumented.Instrumented;
+import org.apache.gobblin.metrics.MetricContext;
+import org.apache.gobblin.source.extractor.extract.kafka.ConfigStoreUtils;
+import org.apache.gobblin.source.extractor.extract.kafka.KafkaSource;
 import java.io.IOException;
 import java.net.URI;
 import java.util.Collection;
@@ -46,15 +46,15 @@ import com.google.common.base.Preconditions;
 import com.google.common.base.Strings;
 import com.google.common.collect.Lists;
 
-import gobblin.annotation.Alpha;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.hive.HivePartition;
-import gobblin.hive.HiveRegProps;
-import gobblin.hive.HiveSerDeManager;
-import gobblin.hive.HiveTable;
-import gobblin.hive.spec.HiveSpec;
-import gobblin.hive.spec.SimpleHiveSpec;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.hive.HivePartition;
+import org.apache.gobblin.hive.HiveRegProps;
+import org.apache.gobblin.hive.HiveSerDeManager;
+import org.apache.gobblin.hive.HiveTable;
+import org.apache.gobblin.hive.spec.HiveSpec;
+import org.apache.gobblin.hive.spec.SimpleHiveSpec;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/policy/HiveSnapshotRegistrationPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/policy/HiveSnapshotRegistrationPolicy.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/policy/HiveSnapshotRegistrationPolicy.java
index 144ebc9..fe02df5 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/policy/HiveSnapshotRegistrationPolicy.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/policy/HiveSnapshotRegistrationPolicy.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.hive.policy;
+package org.apache.gobblin.hive.policy;
 
 import java.io.IOException;
 import java.util.Arrays;
@@ -33,11 +33,11 @@ import com.google.common.base.Throwables;
 import com.google.common.collect.ImmutableList;
 import com.google.common.collect.Lists;
 
-import gobblin.annotation.Alpha;
-import gobblin.configuration.State;
-import gobblin.hive.HiveTable;
-import gobblin.hive.spec.HiveSpec;
-import gobblin.hive.spec.SimpleHiveSpec;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.hive.HiveTable;
+import org.apache.gobblin.hive.spec.HiveSpec;
+import org.apache.gobblin.hive.spec.SimpleHiveSpec;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/HiveSpec.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/HiveSpec.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/HiveSpec.java
index c86f9b8..8a34510 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/HiveSpec.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/HiveSpec.java
@@ -15,15 +15,15 @@
  * limitations under the License.
  */
 
-package gobblin.hive.spec;
+package org.apache.gobblin.hive.spec;
 
 import org.apache.hadoop.fs.Path;
 
 import com.google.common.base.Optional;
 
-import gobblin.annotation.Alpha;
-import gobblin.hive.HivePartition;
-import gobblin.hive.HiveTable;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.hive.HivePartition;
+import org.apache.gobblin.hive.HiveTable;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/HiveSpecWithPostActivities.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/HiveSpecWithPostActivities.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/HiveSpecWithPostActivities.java
index 43d168d..d919ce2 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/HiveSpecWithPostActivities.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/HiveSpecWithPostActivities.java
@@ -15,12 +15,12 @@
  * limitations under the License.
  */
 
-package gobblin.hive.spec;
+package org.apache.gobblin.hive.spec;
 
 import java.util.Collection;
 
-import gobblin.annotation.Alpha;
-import gobblin.hive.spec.activity.Activity;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.hive.spec.activity.Activity;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/HiveSpecWithPreActivities.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/HiveSpecWithPreActivities.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/HiveSpecWithPreActivities.java
index bdbcddc..dfbaea3 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/HiveSpecWithPreActivities.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/HiveSpecWithPreActivities.java
@@ -15,12 +15,12 @@
  * limitations under the License.
  */
 
-package gobblin.hive.spec;
+package org.apache.gobblin.hive.spec;
 
 import java.util.Collection;
 
-import gobblin.annotation.Alpha;
-import gobblin.hive.spec.activity.Activity;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.hive.spec.activity.Activity;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/HiveSpecWithPredicates.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/HiveSpecWithPredicates.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/HiveSpecWithPredicates.java
index 6cc7ade..f14c369 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/HiveSpecWithPredicates.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/HiveSpecWithPredicates.java
@@ -15,14 +15,14 @@
  * limitations under the License.
  */
 
-package gobblin.hive.spec;
+package org.apache.gobblin.hive.spec;
 
 import java.util.Collection;
 
 import com.google.common.base.Predicate;
 
-import gobblin.annotation.Alpha;
-import gobblin.hive.HiveRegister;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.hive.HiveRegister;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/SimpleHiveSpec.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/SimpleHiveSpec.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/SimpleHiveSpec.java
index de93c3f..a455d7e 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/SimpleHiveSpec.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/SimpleHiveSpec.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.hive.spec;
+package org.apache.gobblin.hive.spec;
 
 import org.apache.hadoop.fs.Path;
 
@@ -25,11 +25,11 @@ import com.google.common.base.Preconditions;
 import com.google.common.base.Predicate;
 import com.google.common.collect.Lists;
 
-import gobblin.annotation.Alpha;
-import gobblin.hive.HivePartition;
-import gobblin.hive.HiveTable;
-import gobblin.hive.HiveRegister;
-import gobblin.hive.spec.activity.Activity;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.hive.HivePartition;
+import org.apache.gobblin.hive.HiveTable;
+import org.apache.gobblin.hive.HiveRegister;
+import org.apache.gobblin.hive.spec.activity.Activity;
 
 import lombok.Builder;
 import lombok.Getter;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/activity/Activity.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/activity/Activity.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/activity/Activity.java
index cfe41db..6378099 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/activity/Activity.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/activity/Activity.java
@@ -15,12 +15,12 @@
  * limitations under the License.
  */
 
-package gobblin.hive.spec.activity;
+package org.apache.gobblin.hive.spec.activity;
 
 import java.io.IOException;
 
-import gobblin.annotation.Alpha;
-import gobblin.hive.HiveRegister;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.hive.HiveRegister;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/activity/DropPartitionActivity.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/activity/DropPartitionActivity.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/activity/DropPartitionActivity.java
index 862ecda..730c99e 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/activity/DropPartitionActivity.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/activity/DropPartitionActivity.java
@@ -15,13 +15,13 @@
  * limitations under the License.
  */
 
-package gobblin.hive.spec.activity;
+package org.apache.gobblin.hive.spec.activity;
 
 import java.io.IOException;
 import java.util.List;
 
-import gobblin.hive.HiveRegister;
-import gobblin.hive.HiveRegistrationUnit.Column;
+import org.apache.gobblin.hive.HiveRegister;
+import org.apache.gobblin.hive.HiveRegistrationUnit.Column;
 import lombok.AllArgsConstructor;
 
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/activity/DropTableActivity.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/activity/DropTableActivity.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/activity/DropTableActivity.java
index 6f29040..26f3fc3 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/activity/DropTableActivity.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/activity/DropTableActivity.java
@@ -15,11 +15,11 @@
  * limitations under the License.
  */
 
-package gobblin.hive.spec.activity;
+package org.apache.gobblin.hive.spec.activity;
 
 import java.io.IOException;
 
-import gobblin.hive.HiveRegister;
+import org.apache.gobblin.hive.HiveRegister;
 import lombok.AllArgsConstructor;
 
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/predicate/PartitionNotExistPredicate.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/predicate/PartitionNotExistPredicate.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/predicate/PartitionNotExistPredicate.java
index 7453fa3..acfe27a 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/predicate/PartitionNotExistPredicate.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/predicate/PartitionNotExistPredicate.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.hive.spec.predicate;
+package org.apache.gobblin.hive.spec.predicate;
 
 import java.io.IOException;
 import java.util.List;
@@ -23,8 +23,8 @@ import java.util.List;
 import com.google.common.base.Predicate;
 import com.google.common.base.Throwables;
 
-import gobblin.hive.HiveRegister;
-import gobblin.hive.HiveRegistrationUnit.Column;
+import org.apache.gobblin.hive.HiveRegister;
+import org.apache.gobblin.hive.HiveRegistrationUnit.Column;
 import lombok.AllArgsConstructor;
 
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/predicate/TableNotExistPredicate.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/predicate/TableNotExistPredicate.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/predicate/TableNotExistPredicate.java
index 32227aa..e79a1d8 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/predicate/TableNotExistPredicate.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/predicate/TableNotExistPredicate.java
@@ -15,14 +15,14 @@
  * limitations under the License.
  */
 
-package gobblin.hive.spec.predicate;
+package org.apache.gobblin.hive.spec.predicate;
 
 import java.io.IOException;
 
 import com.google.common.base.Predicate;
 import com.google.common.base.Throwables;
 
-import gobblin.hive.HiveRegister;
+import org.apache.gobblin.hive.HiveRegister;
 import lombok.AllArgsConstructor;
 
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/test/java/org/apache/gobblin/hive/HiveMetaStoreClientFactoryTest.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/test/java/org/apache/gobblin/hive/HiveMetaStoreClientFactoryTest.java b/gobblin-hive-registration/src/test/java/org/apache/gobblin/hive/HiveMetaStoreClientFactoryTest.java
index a55e756..08ceadc 100644
--- a/gobblin-hive-registration/src/test/java/org/apache/gobblin/hive/HiveMetaStoreClientFactoryTest.java
+++ b/gobblin-hive-registration/src/test/java/org/apache/gobblin/hive/HiveMetaStoreClientFactoryTest.java
@@ -1,4 +1,4 @@
-package gobblin.hive;
+package org.apache.gobblin.hive;
 
 import org.apache.hadoop.hive.conf.HiveConf;
 import org.apache.hadoop.hive.metastore.IMetaStoreClient;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/test/java/org/apache/gobblin/hive/HiveRegistrationUnitComparatorTest.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/test/java/org/apache/gobblin/hive/HiveRegistrationUnitComparatorTest.java b/gobblin-hive-registration/src/test/java/org/apache/gobblin/hive/HiveRegistrationUnitComparatorTest.java
index 631a29d..2fcccf0 100644
--- a/gobblin-hive-registration/src/test/java/org/apache/gobblin/hive/HiveRegistrationUnitComparatorTest.java
+++ b/gobblin-hive-registration/src/test/java/org/apache/gobblin/hive/HiveRegistrationUnitComparatorTest.java
@@ -15,12 +15,12 @@
  * limitations under the License.
  */
 
-package gobblin.hive;
+package org.apache.gobblin.hive;
 
 import org.testng.Assert;
 import org.testng.annotations.Test;
 
-import gobblin.configuration.State;
+import org.apache.gobblin.configuration.State;
 
 public class HiveRegistrationUnitComparatorTest {
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/test/java/org/apache/gobblin/hive/metastore/HiveMetaStoreUtilsTest.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/test/java/org/apache/gobblin/hive/metastore/HiveMetaStoreUtilsTest.java b/gobblin-hive-registration/src/test/java/org/apache/gobblin/hive/metastore/HiveMetaStoreUtilsTest.java
index 33f74c6..9e3cdd6 100644
--- a/gobblin-hive-registration/src/test/java/org/apache/gobblin/hive/metastore/HiveMetaStoreUtilsTest.java
+++ b/gobblin-hive-registration/src/test/java/org/apache/gobblin/hive/metastore/HiveMetaStoreUtilsTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.hive.metastore;
+package org.apache.gobblin.hive.metastore;
 
 import java.util.List;
 import java.util.Properties;
@@ -30,8 +30,8 @@ import org.apache.hadoop.hive.serde2.avro.AvroSerDe;
 import org.testng.Assert;
 import org.testng.annotations.Test;
 
-import gobblin.configuration.State;
-import gobblin.hive.HiveTable;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.hive.HiveTable;
 
 
 public class HiveMetaStoreUtilsTest {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-hive-registration/src/test/java/org/apache/gobblin/hive/policy/HiveRegistrationPolicyBaseTest.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/test/java/org/apache/gobblin/hive/policy/HiveRegistrationPolicyBaseTest.java b/gobblin-hive-registration/src/test/java/org/apache/gobblin/hive/policy/HiveRegistrationPolicyBaseTest.java
index e244bda..6eda1d2 100644
--- a/gobblin-hive-registration/src/test/java/org/apache/gobblin/hive/policy/HiveRegistrationPolicyBaseTest.java
+++ b/gobblin-hive-registration/src/test/java/org/apache/gobblin/hive/policy/HiveRegistrationPolicyBaseTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.hive.policy;
+package org.apache.gobblin.hive.policy;
 
 import java.io.IOException;
 import java.util.Collection;
@@ -25,9 +25,9 @@ import org.apache.hadoop.fs.Path;
 import org.testng.Assert;
 import org.testng.annotations.Test;
 
-import gobblin.configuration.State;
-import gobblin.hive.spec.HiveSpec;
-import gobblin.hive.spec.SimpleHiveSpec;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.hive.spec.HiveSpec;
+import org.apache.gobblin.hive.spec.SimpleHiveSpec;
 
 
 /**


Mime
View raw message