http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanCompactionJobLauncher.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanCompactionJobLauncher.java b/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanCompactionJobLauncher.java index 34bb9ce..c0b8bf3 100644 --- a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanCompactionJobLauncher.java +++ b/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanCompactionJobLauncher.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.azkaban; +package org.apache.gobblin.azkaban; import java.io.IOException; import java.util.Properties; @@ -26,15 +26,15 @@ import com.google.common.base.Optional; import org.apache.log4j.Logger; -import gobblin.compaction.Compactor; -import gobblin.compaction.CompactorFactory; -import gobblin.compaction.CompactorCreationException; -import gobblin.compaction.listeners.CompactorListener; -import gobblin.compaction.listeners.CompactorListenerCreationException; -import gobblin.compaction.listeners.CompactorListenerFactory; -import gobblin.compaction.ReflectionCompactorFactory; -import gobblin.compaction.listeners.ReflectionCompactorListenerFactory; -import gobblin.metrics.Tag; +import org.apache.gobblin.compaction.Compactor; +import org.apache.gobblin.compaction.CompactorFactory; +import org.apache.gobblin.compaction.CompactorCreationException; +import org.apache.gobblin.compaction.listeners.CompactorListener; +import org.apache.gobblin.compaction.listeners.CompactorListenerCreationException; +import org.apache.gobblin.compaction.listeners.CompactorListenerFactory; +import org.apache.gobblin.compaction.ReflectionCompactorFactory; +import org.apache.gobblin.compaction.listeners.ReflectionCompactorListenerFactory; +import org.apache.gobblin.metrics.Tag; /**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanGobblinDaemon.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanGobblinDaemon.java b/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanGobblinDaemon.java index 6d73d4e..b9cdace 100644 --- a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanGobblinDaemon.java +++ b/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanGobblinDaemon.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.azkaban; +package org.apache.gobblin.azkaban; import java.util.List; import java.util.Properties; @@ -23,9 +23,9 @@ import org.apache.log4j.Logger; import com.google.common.collect.Lists; -import gobblin.metrics.RootMetricContext; -import gobblin.metrics.Tag; -import gobblin.scheduler.SchedulerDaemon; +import org.apache.gobblin.metrics.RootMetricContext; +import org.apache.gobblin.metrics.Tag; +import org.apache.gobblin.scheduler.SchedulerDaemon; import azkaban.jobExecutor.AbstractJob; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanGobblinYarnAppLauncher.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanGobblinYarnAppLauncher.java b/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanGobblinYarnAppLauncher.java index 79a0d6f..52c193b 100644 --- a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanGobblinYarnAppLauncher.java +++ b/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanGobblinYarnAppLauncher.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.azkaban; +package org.apache.gobblin.azkaban; import java.io.IOException; import java.util.Properties; @@ -26,8 +26,8 @@ import org.apache.log4j.Logger; import com.typesafe.config.Config; -import gobblin.util.ConfigUtils; -import gobblin.yarn.GobblinYarnAppLauncher; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.yarn.GobblinYarnAppLauncher; import azkaban.jobExecutor.AbstractJob; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanIntegrationTestLauncher.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanIntegrationTestLauncher.java b/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanIntegrationTestLauncher.java index 265691e..ca85475 100644 --- a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanIntegrationTestLauncher.java +++ b/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanIntegrationTestLauncher.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.azkaban; +package org.apache.gobblin.azkaban; import java.util.Properties; @@ -23,8 +23,8 @@ import org.apache.log4j.Logger; import azkaban.jobExecutor.AbstractJob; -import gobblin.configuration.ConfigurationKeys; -import gobblin.test.setup.config.TestHarnessLauncher; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.test.setup.config.TestHarnessLauncher; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanJobLauncher.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanJobLauncher.java b/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanJobLauncher.java index 71ee4ff..4aff1df 100644 --- a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanJobLauncher.java +++ b/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanJobLauncher.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.azkaban; +package org.apache.gobblin.azkaban; import java.io.File; import java.io.IOException; @@ -43,22 +43,22 @@ import com.google.common.collect.Lists; import com.google.common.collect.Sets; import com.google.common.io.Closer; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.metrics.GobblinMetrics; -import gobblin.metrics.RootMetricContext; -import gobblin.metrics.Tag; -import gobblin.runtime.JobException; -import gobblin.runtime.JobLauncher; -import gobblin.runtime.JobLauncherFactory; -import gobblin.runtime.app.ApplicationException; -import gobblin.runtime.app.ApplicationLauncher; -import gobblin.runtime.app.ServiceBasedAppLauncher; -import gobblin.runtime.listeners.EmailNotificationJobListener; -import gobblin.runtime.listeners.JobListener; -import gobblin.util.HadoopUtils; -import gobblin.util.TimeRangeChecker; -import gobblin.util.hadoop.TokenUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.metrics.GobblinMetrics; +import org.apache.gobblin.metrics.RootMetricContext; +import org.apache.gobblin.metrics.Tag; +import org.apache.gobblin.runtime.JobException; +import org.apache.gobblin.runtime.JobLauncher; +import org.apache.gobblin.runtime.JobLauncherFactory; +import org.apache.gobblin.runtime.app.ApplicationException; +import org.apache.gobblin.runtime.app.ApplicationLauncher; +import org.apache.gobblin.runtime.app.ServiceBasedAppLauncher; +import org.apache.gobblin.runtime.listeners.EmailNotificationJobListener; +import org.apache.gobblin.runtime.listeners.JobListener; +import org.apache.gobblin.util.HadoopUtils; +import org.apache.gobblin.util.TimeRangeChecker; +import org.apache.gobblin.util.hadoop.TokenUtils; import azkaban.jobExecutor.AbstractJob; import javax.annotation.Nullable; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanStateStoreCleanerJob.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanStateStoreCleanerJob.java b/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanStateStoreCleanerJob.java index cbd8c8d..9b78acd 100644 --- a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanStateStoreCleanerJob.java +++ b/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanStateStoreCleanerJob.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.azkaban; +package org.apache.gobblin.azkaban; import java.io.IOException; import java.util.Properties; @@ -24,7 +24,7 @@ import org.apache.log4j.Logger; import azkaban.jobExecutor.AbstractJob; -import gobblin.metastore.util.StateStoreCleaner; +import org.apache.gobblin.metastore.util.StateStoreCleaner; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanTags.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanTags.java b/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanTags.java index f512f74..dbc266b 100644 --- a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanTags.java +++ b/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanTags.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.azkaban; +package org.apache.gobblin.azkaban; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/conversion/hive/validation/ValidationJob.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/conversion/hive/validation/ValidationJob.java b/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/conversion/hive/validation/ValidationJob.java index 51b8a57..8bf2c21 100644 --- a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/conversion/hive/validation/ValidationJob.java +++ b/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/conversion/hive/validation/ValidationJob.java @@ -14,12 +14,12 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.conversion.hive.validation; +package org.apache.gobblin.data.management.conversion.hive.validation; -import gobblin.config.client.ConfigClient; -import gobblin.config.client.api.VersionStabilityPolicy; -import gobblin.configuration.ConfigurationKeys; -import gobblin.util.PathUtils; +import org.apache.gobblin.config.client.ConfigClient; +import org.apache.gobblin.config.client.api.VersionStabilityPolicy; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.util.PathUtils; import java.io.IOException; import java.io.InputStreamReader; import java.net.URI; @@ -76,27 +76,27 @@ import com.google.common.util.concurrent.UncheckedExecutionException; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDataset; -import gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDatasetFinder; -import gobblin.data.management.conversion.hive.events.EventConstants; -import gobblin.data.management.conversion.hive.provider.HiveUnitUpdateProvider; -import gobblin.data.management.conversion.hive.provider.UpdateNotFoundException; -import gobblin.data.management.conversion.hive.provider.UpdateProviderFactory; -import gobblin.data.management.conversion.hive.query.HiveValidationQueryGenerator; -import gobblin.data.management.conversion.hive.source.HiveSource; -import gobblin.data.management.copy.hive.HiveDataset; -import gobblin.data.management.copy.hive.HiveDatasetFinder; -import gobblin.data.management.copy.hive.HiveUtils; -import gobblin.hive.HiveMetastoreClientPool; -import gobblin.hive.HiveSerDeWrapper; -import gobblin.util.HiveJdbcConnector; -import gobblin.instrumented.Instrumented; -import gobblin.metrics.MetricContext; -import gobblin.metrics.event.EventSubmitter; -import gobblin.util.AutoReturnableObject; -import gobblin.util.ConfigUtils; -import gobblin.util.ExecutorsUtils; -import gobblin.util.HadoopUtils; +import org.apache.gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDataset; +import org.apache.gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDatasetFinder; +import org.apache.gobblin.data.management.conversion.hive.events.EventConstants; +import org.apache.gobblin.data.management.conversion.hive.provider.HiveUnitUpdateProvider; +import org.apache.gobblin.data.management.conversion.hive.provider.UpdateNotFoundException; +import org.apache.gobblin.data.management.conversion.hive.provider.UpdateProviderFactory; +import org.apache.gobblin.data.management.conversion.hive.query.HiveValidationQueryGenerator; +import org.apache.gobblin.data.management.conversion.hive.source.HiveSource; +import org.apache.gobblin.data.management.copy.hive.HiveDataset; +import org.apache.gobblin.data.management.copy.hive.HiveDatasetFinder; +import org.apache.gobblin.data.management.copy.hive.HiveUtils; +import org.apache.gobblin.hive.HiveMetastoreClientPool; +import org.apache.gobblin.hive.HiveSerDeWrapper; +import org.apache.gobblin.util.HiveJdbcConnector; +import org.apache.gobblin.instrumented.Instrumented; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.event.EventSubmitter; +import org.apache.gobblin.util.AutoReturnableObject; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.util.ExecutorsUtils; +import org.apache.gobblin.util.HadoopUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/retention/Avro2OrcStaleDatasetCleaner.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/retention/Avro2OrcStaleDatasetCleaner.java b/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/retention/Avro2OrcStaleDatasetCleaner.java index 0ed30df..1dd14b2 100644 --- a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/retention/Avro2OrcStaleDatasetCleaner.java +++ b/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/retention/Avro2OrcStaleDatasetCleaner.java @@ -1,4 +1,4 @@ -package gobblin.data.management.retention; +package org.apache.gobblin.data.management.retention; import java.io.IOException; import java.util.Arrays; @@ -22,18 +22,18 @@ import com.typesafe.config.ConfigFactory; import azkaban.jobExecutor.AbstractJob; -import gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDataset; -import gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDatasetFinder; -import gobblin.data.management.conversion.hive.events.EventConstants; -import gobblin.data.management.conversion.hive.validation.ValidationJob; -import gobblin.data.management.copy.hive.HiveDataset; -import gobblin.data.management.copy.hive.HiveDatasetFinder; -import gobblin.data.management.copy.hive.HiveUtils; -import gobblin.instrumented.Instrumented; -import gobblin.metrics.MetricContext; -import gobblin.metrics.event.EventSubmitter; -import gobblin.util.AutoReturnableObject; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDataset; +import org.apache.gobblin.data.management.conversion.hive.dataset.ConvertibleHiveDatasetFinder; +import org.apache.gobblin.data.management.conversion.hive.events.EventConstants; +import org.apache.gobblin.data.management.conversion.hive.validation.ValidationJob; +import org.apache.gobblin.data.management.copy.hive.HiveDataset; +import org.apache.gobblin.data.management.copy.hive.HiveDatasetFinder; +import org.apache.gobblin.data.management.copy.hive.HiveUtils; +import org.apache.gobblin.instrumented.Instrumented; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.event.EventSubmitter; +import org.apache.gobblin.util.AutoReturnableObject; +import org.apache.gobblin.util.ConfigUtils; public class Avro2OrcStaleDatasetCleaner extends AbstractJob { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/retention/DatasetCleanerJob.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/retention/DatasetCleanerJob.java b/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/retention/DatasetCleanerJob.java index 794ce46..f69f54c 100644 --- a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/retention/DatasetCleanerJob.java +++ b/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/retention/DatasetCleanerJob.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.retention; +package org.apache.gobblin.data.management.retention; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/trash/TrashCollectorJob.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/trash/TrashCollectorJob.java b/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/trash/TrashCollectorJob.java index e349dd2..bae4804 100644 --- a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/trash/TrashCollectorJob.java +++ b/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/trash/TrashCollectorJob.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-modules/gobblin-codecs/src/main/java/org/apache/gobblin/codec/Base64Codec.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-codecs/src/main/java/org/apache/gobblin/codec/Base64Codec.java b/gobblin-modules/gobblin-codecs/src/main/java/org/apache/gobblin/codec/Base64Codec.java index 531dd7f..0c85909 100644 --- a/gobblin-modules/gobblin-codecs/src/main/java/org/apache/gobblin/codec/Base64Codec.java +++ b/gobblin-modules/gobblin-codecs/src/main/java/org/apache/gobblin/codec/Base64Codec.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.codec; +package org.apache.gobblin.codec; import java.io.IOException; import java.io.InputStream; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-codecs/src/main/java/org/apache/gobblin/codec/GzipCodec.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-codecs/src/main/java/org/apache/gobblin/codec/GzipCodec.java b/gobblin-modules/gobblin-codecs/src/main/java/org/apache/gobblin/codec/GzipCodec.java index 79c4c14..5f4e61f 100644 --- a/gobblin-modules/gobblin-codecs/src/main/java/org/apache/gobblin/codec/GzipCodec.java +++ b/gobblin-modules/gobblin-codecs/src/main/java/org/apache/gobblin/codec/GzipCodec.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.codec; +package org.apache.gobblin.codec; import java.io.IOException; import java.io.InputStream; @@ -22,7 +22,7 @@ import java.io.OutputStream; import java.util.zip.GZIPInputStream; import java.util.zip.GZIPOutputStream; -import gobblin.codec.StreamCodec; +import org.apache.gobblin.codec.StreamCodec; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/ComplianceConfigurationKeys.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/ComplianceConfigurationKeys.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/ComplianceConfigurationKeys.java index 44a33c2..4ef4474 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/ComplianceConfigurationKeys.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/ComplianceConfigurationKeys.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance; +package org.apache.gobblin.compliance; /** * Class containing keys for the configuration properties needed for gobblin-compliance http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/ComplianceEvents.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/ComplianceEvents.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/ComplianceEvents.java index 9d0a3d1..58c1f54 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/ComplianceEvents.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/ComplianceEvents.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance; +package org.apache.gobblin.compliance; /** * Class for event namespaces for gobblin-compliance http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/ComplianceJob.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/ComplianceJob.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/ComplianceJob.java index bedc24d..cbf8c66 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/ComplianceJob.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/ComplianceJob.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance; +package org.apache.gobblin.compliance; import java.io.Closeable; import java.io.IOException; @@ -31,17 +31,17 @@ import com.google.common.io.Closer; import com.google.common.util.concurrent.ListeningExecutorService; import com.google.common.util.concurrent.MoreExecutors; -import gobblin.configuration.State; -import gobblin.dataset.DatasetsFinder; -import gobblin.instrumented.Instrumentable; -import gobblin.instrumented.Instrumented; -import gobblin.metrics.GobblinMetrics; -import gobblin.metrics.MetricContext; -import gobblin.metrics.Tag; -import gobblin.metrics.event.EventSubmitter; -import gobblin.util.AzkabanTags; -import gobblin.util.ExecutorsUtils; -import gobblin.util.executors.ScalingThreadPoolExecutor; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.dataset.DatasetsFinder; +import org.apache.gobblin.instrumented.Instrumentable; +import org.apache.gobblin.instrumented.Instrumented; +import org.apache.gobblin.metrics.GobblinMetrics; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.Tag; +import org.apache.gobblin.metrics.event.EventSubmitter; +import org.apache.gobblin.util.AzkabanTags; +import org.apache.gobblin.util.ExecutorsUtils; +import org.apache.gobblin.util.executors.ScalingThreadPoolExecutor; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/DatasetDescriptor.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/DatasetDescriptor.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/DatasetDescriptor.java index 9f83d79..00c6b17 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/DatasetDescriptor.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/DatasetDescriptor.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance; +package org.apache.gobblin.compliance; import com.google.common.base.Optional; import com.google.common.base.Throwables; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/DatasetDescriptorImpl.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/DatasetDescriptorImpl.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/DatasetDescriptorImpl.java index fb42bda..e4d4699 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/DatasetDescriptorImpl.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/DatasetDescriptorImpl.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance; +package org.apache.gobblin.compliance; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HivePartitionDataset.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HivePartitionDataset.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HivePartitionDataset.java index 2549e0a..1ccba6f 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HivePartitionDataset.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HivePartitionDataset.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance; +package org.apache.gobblin.compliance; import java.util.List; import java.util.Map; @@ -26,8 +26,8 @@ import org.apache.hadoop.hive.ql.metadata.Partition; import com.google.common.base.Optional; -import gobblin.dataset.Dataset; -import gobblin.hive.HiveSerDeWrapper; +import org.apache.gobblin.dataset.Dataset; +import org.apache.gobblin.hive.HiveSerDeWrapper; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HivePartitionDatasetPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HivePartitionDatasetPolicy.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HivePartitionDatasetPolicy.java index de2957a..1f8b192 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HivePartitionDatasetPolicy.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HivePartitionDatasetPolicy.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance; +package org.apache.gobblin.compliance; import java.util.ArrayList; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HivePartitionFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HivePartitionFinder.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HivePartitionFinder.java index a12da62..064cba7 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HivePartitionFinder.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HivePartitionFinder.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance; +package org.apache.gobblin.compliance; import java.io.IOException; import java.util.ArrayList; @@ -36,14 +36,14 @@ import com.google.common.base.Splitter; import lombok.extern.slf4j.Slf4j; -import gobblin.configuration.State; -import gobblin.data.management.copy.hive.HiveDataset; -import gobblin.data.management.copy.hive.HiveDatasetFinder; -import gobblin.dataset.DatasetsFinder; -import gobblin.hive.HiveMetastoreClientPool; -import gobblin.util.AutoReturnableObject; -import gobblin.util.WriterUtils; -import gobblin.util.reflection.GobblinConstructorUtils; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.data.management.copy.hive.HiveDataset; +import org.apache.gobblin.data.management.copy.hive.HiveDatasetFinder; +import org.apache.gobblin.dataset.DatasetsFinder; +import org.apache.gobblin.hive.HiveMetastoreClientPool; +import org.apache.gobblin.util.AutoReturnableObject; +import org.apache.gobblin.util.WriterUtils; +import org.apache.gobblin.util.reflection.GobblinConstructorUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HivePartitionVersion.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HivePartitionVersion.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HivePartitionVersion.java index 2180c85..8348ace 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HivePartitionVersion.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HivePartitionVersion.java @@ -14,11 +14,11 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance; +package org.apache.gobblin.compliance; import org.apache.hadoop.hive.ql.metadata.Partition; -import gobblin.data.management.version.DatasetVersion; +import org.apache.gobblin.data.management.version.DatasetVersion; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HivePartitionVersionFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HivePartitionVersionFinder.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HivePartitionVersionFinder.java index 8a47207..b13716b 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HivePartitionVersionFinder.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HivePartitionVersionFinder.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance; +package org.apache.gobblin.compliance; import java.io.IOException; import java.security.PrivilegedExceptionAction; @@ -38,12 +38,12 @@ import com.google.common.base.Splitter; import lombok.extern.slf4j.Slf4j; -import gobblin.compliance.retention.ComplianceRetentionJob; -import gobblin.compliance.retention.HivePartitionRetentionVersion; -import gobblin.configuration.State; -import gobblin.data.management.copy.hive.HiveDataset; -import gobblin.dataset.Dataset; -import gobblin.util.AutoReturnableObject; +import org.apache.gobblin.compliance.retention.ComplianceRetentionJob; +import org.apache.gobblin.compliance.retention.HivePartitionRetentionVersion; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.data.management.copy.hive.HiveDataset; +import org.apache.gobblin.dataset.Dataset; +import org.apache.gobblin.util.AutoReturnableObject; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HivePartitionVersionPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HivePartitionVersionPolicy.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HivePartitionVersionPolicy.java index 0f8ffab..7cb98b4 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HivePartitionVersionPolicy.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HivePartitionVersionPolicy.java @@ -14,9 +14,9 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance; +package org.apache.gobblin.compliance; -import gobblin.configuration.State; +import org.apache.gobblin.configuration.State; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HiveProxyQueryExecutor.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HiveProxyQueryExecutor.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HiveProxyQueryExecutor.java index b14d989..02e90ad 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HiveProxyQueryExecutor.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HiveProxyQueryExecutor.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance; +package org.apache.gobblin.compliance; import java.io.Closeable; import java.io.IOException; @@ -40,9 +40,9 @@ import com.google.common.base.Splitter; import edu.umd.cs.findbugs.annotations.SuppressWarnings; import lombok.extern.slf4j.Slf4j; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.util.HostUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.util.HostUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/Policy.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/Policy.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/Policy.java index 8dc218f..aa4e81b 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/Policy.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/Policy.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance; +package org.apache.gobblin.compliance; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/QueryExecutor.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/QueryExecutor.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/QueryExecutor.java index 90905d9..36903a0 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/QueryExecutor.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/QueryExecutor.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance; +package org.apache.gobblin.compliance; import java.io.IOException; import java.sql.SQLException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/azkaban/ComplianceAzkabanJob.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/azkaban/ComplianceAzkabanJob.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/azkaban/ComplianceAzkabanJob.java index 0ec7f49..0371b2b 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/azkaban/ComplianceAzkabanJob.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/azkaban/ComplianceAzkabanJob.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance.azkaban; +package org.apache.gobblin.compliance.azkaban; import java.io.IOException; import java.util.Properties; @@ -29,10 +29,10 @@ import com.google.common.base.Preconditions; import azkaban.jobExecutor.AbstractJob; import azkaban.utils.Props; -import gobblin.compliance.ComplianceJob; -import gobblin.util.reflection.GobblinConstructorUtils; +import org.apache.gobblin.compliance.ComplianceJob; +import org.apache.gobblin.util.reflection.GobblinConstructorUtils; -import static gobblin.compliance.ComplianceConfigurationKeys.GOBBLIN_COMPLIANCE_JOB_CLASS; +import static org.apache.gobblin.compliance.ComplianceConfigurationKeys.GOBBLIN_COMPLIANCE_JOB_CLASS; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/CommitPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/CommitPolicy.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/CommitPolicy.java index 68a9900..ff793f6 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/CommitPolicy.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/CommitPolicy.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance.purger; +package org.apache.gobblin.compliance.purger; /** * @author adsharma http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerCommitPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerCommitPolicy.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerCommitPolicy.java index 144df69..304eae6 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerCommitPolicy.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerCommitPolicy.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance.purger; +package org.apache.gobblin.compliance.purger; import com.google.common.base.Preconditions; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerConverter.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerConverter.java index 4ff7c1b..6858601 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerConverter.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerConverter.java @@ -14,11 +14,11 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance.purger; +package org.apache.gobblin.compliance.purger; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.Converter; -import gobblin.converter.SingleRecordIterable; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.Converter; +import org.apache.gobblin.converter.SingleRecordIterable; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerExtractor.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerExtractor.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerExtractor.java index e79d791..9d8cd6d 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerExtractor.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerExtractor.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance.purger; +package org.apache.gobblin.compliance.purger; import java.io.IOException; import java.util.Map; @@ -23,14 +23,14 @@ import com.google.common.annotations.VisibleForTesting; import com.google.common.base.Optional; import com.google.common.base.Preconditions; -import gobblin.compliance.ComplianceConfigurationKeys; -import gobblin.compliance.DatasetDescriptor; -import gobblin.compliance.HivePartitionDataset; -import gobblin.compliance.HivePartitionFinder; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.source.extractor.Extractor; -import gobblin.util.reflection.GobblinConstructorUtils; +import org.apache.gobblin.compliance.ComplianceConfigurationKeys; +import org.apache.gobblin.compliance.DatasetDescriptor; +import org.apache.gobblin.compliance.HivePartitionDataset; +import org.apache.gobblin.compliance.HivePartitionFinder; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.source.extractor.Extractor; +import org.apache.gobblin.util.reflection.GobblinConstructorUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerPolicy.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerPolicy.java index 0e05fef..18273cc 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerPolicy.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerPolicy.java @@ -14,15 +14,15 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance.purger; +package org.apache.gobblin.compliance.purger; import com.google.common.base.Preconditions; import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; -import gobblin.compliance.ComplianceConfigurationKeys; -import gobblin.compliance.HivePartitionDataset; +import org.apache.gobblin.compliance.ComplianceConfigurationKeys; +import org.apache.gobblin.compliance.HivePartitionDataset; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerPublisher.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerPublisher.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerPublisher.java index 0313627..6bcb638 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerPublisher.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerPublisher.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance.purger; +package org.apache.gobblin.compliance.purger; import java.security.PrivilegedExceptionAction; import java.util.Collection; @@ -33,19 +33,19 @@ import com.google.common.base.Splitter; import lombok.extern.slf4j.Slf4j; -import gobblin.compliance.ComplianceConfigurationKeys; -import gobblin.compliance.ComplianceEvents; -import gobblin.compliance.HivePartitionDataset; -import gobblin.compliance.utils.DatasetUtils; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.instrumented.Instrumented; -import gobblin.metrics.MetricContext; -import gobblin.metrics.event.EventSubmitter; -import gobblin.publisher.DataPublisher; -import gobblin.source.workunit.WorkUnit; -import gobblin.util.HostUtils; +import org.apache.gobblin.compliance.ComplianceConfigurationKeys; +import org.apache.gobblin.compliance.ComplianceEvents; +import org.apache.gobblin.compliance.HivePartitionDataset; +import org.apache.gobblin.compliance.utils.DatasetUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.instrumented.Instrumented; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.event.EventSubmitter; +import org.apache.gobblin.publisher.DataPublisher; +import org.apache.gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.util.HostUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerQueryTemplate.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerQueryTemplate.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerQueryTemplate.java index a971e35..5cc87a8 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerQueryTemplate.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerQueryTemplate.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance.purger; +package org.apache.gobblin.compliance.purger; import java.util.ArrayList; import java.util.List; @@ -24,7 +24,7 @@ import org.apache.hadoop.hive.metastore.api.FieldSchema; import com.google.common.base.Optional; -import gobblin.compliance.utils.PartitionUtils; +import org.apache.gobblin.compliance.utils.PartitionUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerSource.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerSource.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerSource.java index 2fb56f1..f1499bf 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerSource.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerSource.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance.purger; +package org.apache.gobblin.compliance.purger; import java.io.IOException; import java.util.ArrayList; @@ -34,23 +34,23 @@ import com.google.common.collect.Iterables; import lombok.extern.slf4j.Slf4j; -import gobblin.compliance.ComplianceConfigurationKeys; -import gobblin.compliance.ComplianceEvents; -import gobblin.compliance.utils.DatasetUtils; -import gobblin.compliance.HivePartitionDataset; -import gobblin.compliance.HivePartitionFinder; -import gobblin.compliance.utils.ProxyUtils; -import gobblin.configuration.SourceState; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.dataset.DatasetsFinder; -import gobblin.instrumented.Instrumented; -import gobblin.metrics.MetricContext; -import gobblin.metrics.event.EventSubmitter; -import gobblin.source.Source; -import gobblin.source.extractor.Extractor; -import gobblin.source.workunit.WorkUnit; -import gobblin.util.reflection.GobblinConstructorUtils; +import org.apache.gobblin.compliance.ComplianceConfigurationKeys; +import org.apache.gobblin.compliance.ComplianceEvents; +import org.apache.gobblin.compliance.utils.DatasetUtils; +import org.apache.gobblin.compliance.HivePartitionDataset; +import org.apache.gobblin.compliance.HivePartitionFinder; +import org.apache.gobblin.compliance.utils.ProxyUtils; +import org.apache.gobblin.configuration.SourceState; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.dataset.DatasetsFinder; +import org.apache.gobblin.instrumented.Instrumented; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.event.EventSubmitter; +import org.apache.gobblin.source.Source; +import org.apache.gobblin.source.extractor.Extractor; +import org.apache.gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.util.reflection.GobblinConstructorUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerWriter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerWriter.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerWriter.java index 2fe5a1d..9975134 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerWriter.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerWriter.java @@ -14,14 +14,14 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance.purger; +package org.apache.gobblin.compliance.purger; import java.io.IOException; import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; -import gobblin.writer.DataWriter; +import org.apache.gobblin.writer.DataWriter; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerWriterBuilder.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerWriterBuilder.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerWriterBuilder.java index 14242a1..b4f666b 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerWriterBuilder.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerWriterBuilder.java @@ -14,12 +14,12 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance.purger; +package org.apache.gobblin.compliance.purger; import java.io.IOException; -import gobblin.writer.DataWriter; -import gobblin.writer.DataWriterBuilder; +import org.apache.gobblin.writer.DataWriter; +import org.apache.gobblin.writer.DataWriterBuilder; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/PurgePolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/PurgePolicy.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/PurgePolicy.java index de8de9d..bf3b761 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/PurgePolicy.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/PurgePolicy.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance.purger; +package org.apache.gobblin.compliance.purger; /** * @author adsharma http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/PurgeableDataset.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/PurgeableDataset.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/PurgeableDataset.java index 2c9e75d..b326b5c 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/PurgeableDataset.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/PurgeableDataset.java @@ -14,11 +14,11 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance.purger; +package org.apache.gobblin.compliance.purger; import java.io.IOException; -import gobblin.data.management.dataset.Dataset; +import org.apache.gobblin.data.management.dataset.Dataset; public interface PurgeableDataset extends Dataset { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/PurgeableHivePartitionDataset.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/PurgeableHivePartitionDataset.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/PurgeableHivePartitionDataset.java index 31fe6bf..cacdc99 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/PurgeableHivePartitionDataset.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/PurgeableHivePartitionDataset.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance.purger; +package org.apache.gobblin.compliance.purger; import java.io.IOException; import java.sql.SQLException; @@ -33,13 +33,13 @@ import lombok.Getter; import lombok.Setter; import lombok.extern.slf4j.Slf4j; -import gobblin.compliance.ComplianceConfigurationKeys; -import gobblin.compliance.HivePartitionDataset; -import gobblin.compliance.HiveProxyQueryExecutor; -import gobblin.compliance.utils.PartitionUtils; -import gobblin.compliance.utils.ProxyUtils; -import gobblin.configuration.State; -import gobblin.util.reflection.GobblinConstructorUtils; +import org.apache.gobblin.compliance.ComplianceConfigurationKeys; +import org.apache.gobblin.compliance.HivePartitionDataset; +import org.apache.gobblin.compliance.HiveProxyQueryExecutor; +import org.apache.gobblin.compliance.utils.PartitionUtils; +import org.apache.gobblin.compliance.utils.ProxyUtils; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.util.reflection.GobblinConstructorUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/PurgeableHivePartitionDatasetSchema.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/PurgeableHivePartitionDatasetSchema.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/PurgeableHivePartitionDatasetSchema.java index 1605b8e..f8523a9 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/PurgeableHivePartitionDatasetSchema.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/PurgeableHivePartitionDatasetSchema.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance.purger; +package org.apache.gobblin.compliance.purger; /** * Dummy class for schema corresponding to {@link PurgeableHivePartitionDataset} http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/AdhocRestorePolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/AdhocRestorePolicy.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/AdhocRestorePolicy.java index 9e2751f..c4482a0 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/AdhocRestorePolicy.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/AdhocRestorePolicy.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance.restore; +package org.apache.gobblin.compliance.restore; import java.io.IOException; @@ -22,12 +22,12 @@ import org.apache.hadoop.fs.FileSystem; import com.google.common.base.Preconditions; -import gobblin.compliance.ComplianceConfigurationKeys; -import gobblin.compliance.HivePartitionDataset; -import gobblin.compliance.HivePartitionFinder; -import gobblin.compliance.utils.ProxyUtils; -import gobblin.configuration.State; -import gobblin.util.HadoopUtils; +import org.apache.gobblin.compliance.ComplianceConfigurationKeys; +import org.apache.gobblin.compliance.HivePartitionDataset; +import org.apache.gobblin.compliance.HivePartitionFinder; +import org.apache.gobblin.compliance.utils.ProxyUtils; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.util.HadoopUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/ComplianceRestoreJob.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/ComplianceRestoreJob.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/ComplianceRestoreJob.java index f9c6415..8f3d516 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/ComplianceRestoreJob.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/ComplianceRestoreJob.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance.restore; +package org.apache.gobblin.compliance.restore; import java.io.IOException; import java.util.List; @@ -36,15 +36,15 @@ import com.google.common.util.concurrent.ListenableFuture; import javax.annotation.Nullable; import lombok.extern.slf4j.Slf4j; -import gobblin.compliance.ComplianceConfigurationKeys; -import gobblin.compliance.ComplianceEvents; -import gobblin.compliance.ComplianceJob; -import gobblin.compliance.utils.ProxyUtils; -import gobblin.configuration.State; -import gobblin.dataset.Dataset; -import gobblin.dataset.DatasetsFinder; -import gobblin.util.ExecutorsUtils; -import gobblin.util.reflection.GobblinConstructorUtils; +import org.apache.gobblin.compliance.ComplianceConfigurationKeys; +import org.apache.gobblin.compliance.ComplianceEvents; +import org.apache.gobblin.compliance.ComplianceJob; +import org.apache.gobblin.compliance.utils.ProxyUtils; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.dataset.Dataset; +import org.apache.gobblin.dataset.DatasetsFinder; +import org.apache.gobblin.util.ExecutorsUtils; +import org.apache.gobblin.util.reflection.GobblinConstructorUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/HivePartitionRestorePolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/HivePartitionRestorePolicy.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/HivePartitionRestorePolicy.java index d5843f4..c501e09 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/HivePartitionRestorePolicy.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/HivePartitionRestorePolicy.java @@ -14,10 +14,10 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance.restore; +package org.apache.gobblin.compliance.restore; -import gobblin.compliance.HivePartitionDataset; -import gobblin.configuration.State; +import org.apache.gobblin.compliance.HivePartitionDataset; +import org.apache.gobblin.configuration.State; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/LKGRestorePolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/LKGRestorePolicy.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/LKGRestorePolicy.java index 5bb0e5e..ccb15d6 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/LKGRestorePolicy.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/LKGRestorePolicy.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance.restore; +package org.apache.gobblin.compliance.restore; import java.io.IOException; import java.util.ArrayList; @@ -25,14 +25,14 @@ import org.apache.hadoop.fs.FileSystem; import com.google.common.base.Preconditions; -import gobblin.compliance.ComplianceConfigurationKeys; -import gobblin.compliance.HivePartitionDataset; -import gobblin.compliance.HivePartitionVersion; -import gobblin.compliance.HivePartitionVersionFinder; -import gobblin.compliance.utils.ProxyUtils; -import gobblin.configuration.State; -import gobblin.util.HadoopUtils; -import gobblin.util.WriterUtils; +import org.apache.gobblin.compliance.ComplianceConfigurationKeys; +import org.apache.gobblin.compliance.HivePartitionDataset; +import org.apache.gobblin.compliance.HivePartitionVersion; +import org.apache.gobblin.compliance.HivePartitionVersionFinder; +import org.apache.gobblin.compliance.utils.ProxyUtils; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.util.HadoopUtils; +import org.apache.gobblin.util.WriterUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/RestorableDataset.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/RestorableDataset.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/RestorableDataset.java index e2760d4..46205b5 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/RestorableDataset.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/RestorableDataset.java @@ -14,11 +14,11 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance.restore; +package org.apache.gobblin.compliance.restore; import java.io.IOException; -import gobblin.dataset.Dataset; +import org.apache.gobblin.dataset.Dataset; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/RestorableHivePartitionDataset.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/RestorableHivePartitionDataset.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/RestorableHivePartitionDataset.java index 1743277..8d4eb9b 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/RestorableHivePartitionDataset.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/RestorableHivePartitionDataset.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance.restore; +package org.apache.gobblin.compliance.restore; import java.io.IOException; import java.sql.SQLException; @@ -34,15 +34,15 @@ import com.google.common.base.Throwables; import lombok.extern.slf4j.Slf4j; -import gobblin.compliance.ComplianceConfigurationKeys; -import gobblin.compliance.HivePartitionDataset; -import gobblin.compliance.HiveProxyQueryExecutor; -import gobblin.compliance.purger.HivePurgerQueryTemplate; -import gobblin.compliance.utils.PartitionUtils; -import gobblin.compliance.utils.ProxyUtils; -import gobblin.configuration.State; -import gobblin.util.HadoopUtils; -import gobblin.util.reflection.GobblinConstructorUtils; +import org.apache.gobblin.compliance.ComplianceConfigurationKeys; +import org.apache.gobblin.compliance.HivePartitionDataset; +import org.apache.gobblin.compliance.HiveProxyQueryExecutor; +import org.apache.gobblin.compliance.purger.HivePurgerQueryTemplate; +import org.apache.gobblin.compliance.utils.PartitionUtils; +import org.apache.gobblin.compliance.utils.ProxyUtils; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.util.HadoopUtils; +import org.apache.gobblin.util.reflection.GobblinConstructorUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/RestorableHivePartitionDatasetFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/RestorableHivePartitionDatasetFinder.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/RestorableHivePartitionDatasetFinder.java index 9acb6e3..f8b2b33 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/RestorableHivePartitionDatasetFinder.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/RestorableHivePartitionDatasetFinder.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance.restore; +package org.apache.gobblin.compliance.restore; import java.io.IOException; import java.util.Collections; @@ -26,11 +26,11 @@ import com.google.common.base.Preconditions; import lombok.extern.slf4j.Slf4j; -import gobblin.compliance.ComplianceConfigurationKeys; -import gobblin.compliance.HivePartitionDataset; -import gobblin.compliance.HivePartitionFinder; -import gobblin.configuration.State; -import gobblin.util.WriterUtils; +import org.apache.gobblin.compliance.ComplianceConfigurationKeys; +import org.apache.gobblin.compliance.HivePartitionDataset; +import org.apache.gobblin.compliance.HivePartitionFinder; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.util.WriterUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/RestorePolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/RestorePolicy.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/RestorePolicy.java index b6cdf68..e0d01ad 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/RestorePolicy.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/RestorePolicy.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance.restore; +package org.apache.gobblin.compliance.restore; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/CleanableHivePartitionDataset.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/CleanableHivePartitionDataset.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/CleanableHivePartitionDataset.java index b8f11a5..c8898f3 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/CleanableHivePartitionDataset.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/CleanableHivePartitionDataset.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance.retention; +package org.apache.gobblin.compliance.retention; import java.io.IOException; import java.util.ArrayList; @@ -30,15 +30,15 @@ import com.google.common.base.Preconditions; import lombok.extern.slf4j.Slf4j; -import gobblin.compliance.ComplianceConfigurationKeys; -import gobblin.compliance.HivePartitionDataset; -import gobblin.compliance.HivePartitionVersion; -import gobblin.compliance.HivePartitionVersionFinder; -import gobblin.compliance.HivePartitionVersionPolicy; -import gobblin.configuration.State; -import gobblin.data.management.retention.dataset.CleanableDataset; -import gobblin.data.management.retention.version.VersionCleaner; -import gobblin.util.reflection.GobblinConstructorUtils; +import org.apache.gobblin.compliance.ComplianceConfigurationKeys; +import org.apache.gobblin.compliance.HivePartitionDataset; +import org.apache.gobblin.compliance.HivePartitionVersion; +import org.apache.gobblin.compliance.HivePartitionVersionFinder; +import org.apache.gobblin.compliance.HivePartitionVersionPolicy; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.data.management.retention.dataset.CleanableDataset; +import org.apache.gobblin.data.management.retention.version.VersionCleaner; +import org.apache.gobblin.util.reflection.GobblinConstructorUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/CleanableHivePartitionDatasetFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/CleanableHivePartitionDatasetFinder.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/CleanableHivePartitionDatasetFinder.java index bf1f8c0..02ff5fd 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/CleanableHivePartitionDatasetFinder.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/CleanableHivePartitionDatasetFinder.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance.retention; +package org.apache.gobblin.compliance.retention; import java.io.IOException; import java.util.ArrayList; @@ -22,10 +22,10 @@ import java.util.List; import org.apache.hadoop.fs.FileSystem; -import gobblin.compliance.HivePartitionDataset; -import gobblin.compliance.HivePartitionFinder; -import gobblin.configuration.State; -import gobblin.util.WriterUtils; +import org.apache.gobblin.compliance.HivePartitionDataset; +import org.apache.gobblin.compliance.HivePartitionFinder; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.util.WriterUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/ComplianceRetentionJob.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/ComplianceRetentionJob.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/ComplianceRetentionJob.java index f0174ca..38f07d2 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/ComplianceRetentionJob.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/ComplianceRetentionJob.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance.retention; +package org.apache.gobblin.compliance.retention; import java.io.IOException; import java.sql.SQLException; @@ -44,23 +44,23 @@ import edu.umd.cs.findbugs.annotations.SuppressWarnings; import javax.annotation.Nullable; import lombok.extern.slf4j.Slf4j; -import gobblin.compliance.ComplianceConfigurationKeys; -import gobblin.compliance.ComplianceEvents; -import gobblin.compliance.ComplianceJob; -import gobblin.compliance.HiveProxyQueryExecutor; -import gobblin.compliance.purger.HivePurgerQueryTemplate; -import gobblin.compliance.utils.ProxyUtils; -import gobblin.configuration.State; -import gobblin.data.management.copy.hive.HiveDataset; -import gobblin.data.management.copy.hive.HiveDatasetFinder; -import gobblin.data.management.retention.dataset.CleanableDataset; -import gobblin.dataset.Dataset; -import gobblin.dataset.DatasetsFinder; -import gobblin.hive.HiveMetastoreClientPool; -import gobblin.util.ExecutorsUtils; -import gobblin.util.reflection.GobblinConstructorUtils; - -import static gobblin.compliance.ComplianceConfigurationKeys.GOBBLIN_COMPLIANCE_DATASET_FINDER_CLASS; +import org.apache.gobblin.compliance.ComplianceConfigurationKeys; +import org.apache.gobblin.compliance.ComplianceEvents; +import org.apache.gobblin.compliance.ComplianceJob; +import org.apache.gobblin.compliance.HiveProxyQueryExecutor; +import org.apache.gobblin.compliance.purger.HivePurgerQueryTemplate; +import org.apache.gobblin.compliance.utils.ProxyUtils; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.data.management.copy.hive.HiveDataset; +import org.apache.gobblin.data.management.copy.hive.HiveDatasetFinder; +import org.apache.gobblin.data.management.retention.dataset.CleanableDataset; +import org.apache.gobblin.dataset.Dataset; +import org.apache.gobblin.dataset.DatasetsFinder; +import org.apache.gobblin.hive.HiveMetastoreClientPool; +import org.apache.gobblin.util.ExecutorsUtils; +import org.apache.gobblin.util.reflection.GobblinConstructorUtils; + +import static org.apache.gobblin.compliance.ComplianceConfigurationKeys.GOBBLIN_COMPLIANCE_DATASET_FINDER_CLASS; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/HivePartitionRetentionVersion.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/HivePartitionRetentionVersion.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/HivePartitionRetentionVersion.java index b5597ea..49c04ec 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/HivePartitionRetentionVersion.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/HivePartitionRetentionVersion.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance.retention; +package org.apache.gobblin.compliance.retention; import org.apache.hadoop.hive.ql.metadata.Partition; @@ -22,8 +22,8 @@ import com.google.common.base.Preconditions; import edu.umd.cs.findbugs.annotations.SuppressWarnings; -import gobblin.compliance.ComplianceConfigurationKeys; -import gobblin.compliance.HivePartitionVersion; +import org.apache.gobblin.compliance.ComplianceConfigurationKeys; +import org.apache.gobblin.compliance.HivePartitionVersion; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/HivePartitionVersionRetentionCleaner.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/HivePartitionVersionRetentionCleaner.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/HivePartitionVersionRetentionCleaner.java index 648e2f9..042a4ec 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/HivePartitionVersionRetentionCleaner.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/HivePartitionVersionRetentionCleaner.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance.retention; +package org.apache.gobblin.compliance.retention; import java.io.IOException; import java.sql.SQLException; @@ -27,15 +27,15 @@ import com.google.common.base.Optional; import lombok.extern.slf4j.Slf4j; -import gobblin.compliance.ComplianceConfigurationKeys; -import gobblin.compliance.HiveProxyQueryExecutor; -import gobblin.compliance.purger.HivePurgerQueryTemplate; -import gobblin.compliance.utils.PartitionUtils; -import gobblin.compliance.utils.ProxyUtils; -import gobblin.configuration.State; -import gobblin.data.management.retention.dataset.CleanableDataset; -import gobblin.data.management.version.DatasetVersion; -import gobblin.util.HadoopUtils; +import org.apache.gobblin.compliance.ComplianceConfigurationKeys; +import org.apache.gobblin.compliance.HiveProxyQueryExecutor; +import org.apache.gobblin.compliance.purger.HivePurgerQueryTemplate; +import org.apache.gobblin.compliance.utils.PartitionUtils; +import org.apache.gobblin.compliance.utils.ProxyUtils; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.data.management.retention.dataset.CleanableDataset; +import org.apache.gobblin.data.management.version.DatasetVersion; +import org.apache.gobblin.util.HadoopUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/HivePartitionVersionRetentionCleanerPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/HivePartitionVersionRetentionCleanerPolicy.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/HivePartitionVersionRetentionCleanerPolicy.java index 5e7abbf..384951c 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/HivePartitionVersionRetentionCleanerPolicy.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/HivePartitionVersionRetentionCleanerPolicy.java @@ -14,14 +14,14 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance.retention; +package org.apache.gobblin.compliance.retention; import com.google.common.base.Preconditions; -import gobblin.compliance.ComplianceConfigurationKeys; -import gobblin.compliance.HivePartitionDataset; -import gobblin.compliance.HivePartitionVersion; -import gobblin.compliance.HivePartitionVersionPolicy; -import gobblin.configuration.State; +import org.apache.gobblin.compliance.ComplianceConfigurationKeys; +import org.apache.gobblin.compliance.HivePartitionDataset; +import org.apache.gobblin.compliance.HivePartitionVersion; +import org.apache.gobblin.compliance.HivePartitionVersionPolicy; +import org.apache.gobblin.configuration.State; import java.util.ArrayList; import java.util.Collections; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/HivePartitionVersionRetentionReaper.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/HivePartitionVersionRetentionReaper.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/HivePartitionVersionRetentionReaper.java index b77f803..31e4cfd 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/HivePartitionVersionRetentionReaper.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/HivePartitionVersionRetentionReaper.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compliance.retention; +package org.apache.gobblin.compliance.retention; import java.io.IOException; import java.sql.SQLException; @@ -33,19 +33,19 @@ import com.google.common.base.Preconditions; import lombok.extern.slf4j.Slf4j; -import gobblin.compliance.ComplianceConfigurationKeys; -import gobblin.compliance.HivePartitionVersion; -import gobblin.compliance.HiveProxyQueryExecutor; -import gobblin.compliance.purger.HivePurgerQueryTemplate; -import gobblin.compliance.utils.PartitionUtils; -import gobblin.compliance.utils.ProxyUtils; -import gobblin.configuration.State; -import gobblin.data.management.retention.dataset.CleanableDataset; -import gobblin.data.management.version.DatasetVersion; -import gobblin.util.HadoopUtils; - -import static gobblin.compliance.purger.HivePurgerQueryTemplate.getDropPartitionQuery; -import static gobblin.compliance.purger.HivePurgerQueryTemplate.getUseDbQuery; +import org.apache.gobblin.compliance.ComplianceConfigurationKeys; +import org.apache.gobblin.compliance.HivePartitionVersion; +import org.apache.gobblin.compliance.HiveProxyQueryExecutor; +import org.apache.gobblin.compliance.purger.HivePurgerQueryTemplate; +import org.apache.gobblin.compliance.utils.PartitionUtils; +import org.apache.gobblin.compliance.utils.ProxyUtils; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.data.management.retention.dataset.CleanableDataset; +import org.apache.gobblin.data.management.version.DatasetVersion; +import org.apache.gobblin.util.HadoopUtils; + +import static org.apache.gobblin.compliance.purger.HivePurgerQueryTemplate.getDropPartitionQuery; +import static org.apache.gobblin.compliance.purger.HivePurgerQueryTemplate.getUseDbQuery; /**
