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:39 UTC
[21/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-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;
/**