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; /**
