http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/GlobCleanableDatasetFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/GlobCleanableDatasetFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/GlobCleanableDatasetFinder.java index e894f9a..70369b7 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/GlobCleanableDatasetFinder.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/GlobCleanableDatasetFinder.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.retention.profile; +package org.apache.gobblin.data.management.retention.profile; import java.io.IOException; import java.util.Properties; @@ -24,8 +24,8 @@ import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; import org.slf4j.LoggerFactory; -import gobblin.data.management.retention.dataset.ConfigurableCleanableDataset; -import gobblin.data.management.version.FileSystemDatasetVersion; +import org.apache.gobblin.data.management.retention.dataset.ConfigurableCleanableDataset; +import org.apache.gobblin.data.management.version.FileSystemDatasetVersion; /**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/ManagedCleanableDatasetFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/ManagedCleanableDatasetFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/ManagedCleanableDatasetFinder.java index ccd9f3b..a4c9910 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/ManagedCleanableDatasetFinder.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/ManagedCleanableDatasetFinder.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.retention.profile; +package org.apache.gobblin.data.management.retention.profile; import java.io.IOException; import java.net.URISyntaxException; @@ -27,15 +27,15 @@ import org.slf4j.LoggerFactory; import com.typesafe.config.Config; -import gobblin.config.client.ConfigClient; -import gobblin.config.client.ConfigClientCache; -import gobblin.config.client.api.ConfigStoreFactoryDoesNotExistsException; -import gobblin.config.client.api.VersionStabilityPolicy; -import gobblin.config.store.api.ConfigStoreCreationException; -import gobblin.config.store.api.VersionDoesNotExistException; -import gobblin.configuration.ConfigurationKeys; -import gobblin.data.management.retention.dataset.ConfigurableCleanableDataset; -import gobblin.data.management.version.FileSystemDatasetVersion; +import org.apache.gobblin.config.client.ConfigClient; +import org.apache.gobblin.config.client.ConfigClientCache; +import org.apache.gobblin.config.client.api.ConfigStoreFactoryDoesNotExistsException; +import org.apache.gobblin.config.client.api.VersionStabilityPolicy; +import org.apache.gobblin.config.store.api.ConfigStoreCreationException; +import org.apache.gobblin.config.store.api.VersionDoesNotExistException; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.data.management.retention.dataset.ConfigurableCleanableDataset; +import org.apache.gobblin.data.management.version.FileSystemDatasetVersion; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/ModificationTimeDatasetProfile.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/ModificationTimeDatasetProfile.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/ModificationTimeDatasetProfile.java index fce977d..e1a96ed 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/ModificationTimeDatasetProfile.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/ModificationTimeDatasetProfile.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.retention.profile; +package org.apache.gobblin.data.management.retention.profile; import java.io.IOException; import java.util.Properties; @@ -22,8 +22,8 @@ import java.util.Properties; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; -import gobblin.dataset.Dataset; -import gobblin.data.management.retention.dataset.ModificationTimeDataset; +import org.apache.gobblin.dataset.Dataset; +import org.apache.gobblin.data.management.retention.dataset.ModificationTimeDataset; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/MultiCleanableDatasetFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/MultiCleanableDatasetFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/MultiCleanableDatasetFinder.java index 2abc2e3..93479e5 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/MultiCleanableDatasetFinder.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/MultiCleanableDatasetFinder.java @@ -14,9 +14,9 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.retention.profile; +package org.apache.gobblin.data.management.retention.profile; -import gobblin.data.management.retention.DatasetCleaner; +import org.apache.gobblin.data.management.retention.DatasetCleaner; import java.net.URI; import java.util.Properties; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/MultiDatasetFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/MultiDatasetFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/MultiDatasetFinder.java index b7deb5a..d1bb84e 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/MultiDatasetFinder.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/MultiDatasetFinder.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.retention.profile; +package org.apache.gobblin.data.management.retention.profile; import java.io.IOException; import java.lang.reflect.InvocationTargetException; @@ -36,15 +36,15 @@ import com.google.common.collect.ImmutableList; import com.google.common.collect.Lists; import com.typesafe.config.Config; -import gobblin.config.client.ConfigClient; -import gobblin.config.client.ConfigClientCache; -import gobblin.config.client.api.ConfigStoreFactoryDoesNotExistsException; -import gobblin.config.client.api.VersionStabilityPolicy; -import gobblin.config.store.api.ConfigStoreCreationException; -import gobblin.config.store.api.VersionDoesNotExistException; -import gobblin.dataset.Dataset; -import gobblin.dataset.DatasetsFinder; -import gobblin.util.reflection.GobblinConstructorUtils; +import org.apache.gobblin.config.client.ConfigClient; +import org.apache.gobblin.config.client.ConfigClientCache; +import org.apache.gobblin.config.client.api.ConfigStoreFactoryDoesNotExistsException; +import org.apache.gobblin.config.client.api.VersionStabilityPolicy; +import org.apache.gobblin.config.store.api.ConfigStoreCreationException; +import org.apache.gobblin.config.store.api.VersionDoesNotExistException; +import org.apache.gobblin.dataset.Dataset; +import org.apache.gobblin.dataset.DatasetsFinder; +import org.apache.gobblin.util.reflection.GobblinConstructorUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/ProxyableDatasetProfile.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/ProxyableDatasetProfile.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/ProxyableDatasetProfile.java index 8014585..1cbc604 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/ProxyableDatasetProfile.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/ProxyableDatasetProfile.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.retention.profile; +package org.apache.gobblin.data.management.retention.profile; import java.io.IOException; import java.util.Properties; @@ -26,13 +26,13 @@ import org.apache.hadoop.fs.Path; import com.google.common.base.Preconditions; -import gobblin.configuration.ConfigurationKeys; -import gobblin.data.management.retention.DatasetCleaner; -import gobblin.dataset.Dataset; -import gobblin.data.management.retention.dataset.ConfigurableCleanableDataset; -import gobblin.data.management.retention.version.DatasetVersion; -import gobblin.util.ProxiedFileSystemCache; -import gobblin.util.RateControlledFileSystem; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.data.management.retention.DatasetCleaner; +import org.apache.gobblin.dataset.Dataset; +import org.apache.gobblin.data.management.retention.dataset.ConfigurableCleanableDataset; +import org.apache.gobblin.data.management.retention.version.DatasetVersion; +import org.apache.gobblin.util.ProxiedFileSystemCache; +import org.apache.gobblin.util.RateControlledFileSystem; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/SnapshotDatasetProfile.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/SnapshotDatasetProfile.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/SnapshotDatasetProfile.java index c92323d..1ed92db 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/SnapshotDatasetProfile.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/SnapshotDatasetProfile.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.retention.profile; +package org.apache.gobblin.data.management.retention.profile; import java.io.IOException; import java.util.Properties; @@ -23,8 +23,8 @@ import java.util.Properties; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; -import gobblin.data.management.retention.dataset.SnapshotDataset; -import gobblin.dataset.Dataset; +import org.apache.gobblin.data.management.retention.dataset.SnapshotDataset; +import org.apache.gobblin.dataset.Dataset; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/TrackingDatasetProfile.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/TrackingDatasetProfile.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/TrackingDatasetProfile.java index d1ae7ce..fceca48 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/TrackingDatasetProfile.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/TrackingDatasetProfile.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.retention.profile; +package org.apache.gobblin.data.management.retention.profile; import java.io.IOException; import java.util.List; @@ -24,9 +24,9 @@ import java.util.Properties; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; -import gobblin.dataset.Dataset; -import gobblin.data.management.retention.dataset.TrackingDataset; -import gobblin.data.management.retention.version.finder.DateTimeDatasetVersionFinder; +import org.apache.gobblin.dataset.Dataset; +import org.apache.gobblin.data.management.retention.dataset.TrackingDataset; +import org.apache.gobblin.data.management.retention.version.finder.DateTimeDatasetVersionFinder; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/DatasetVersion.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/DatasetVersion.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/DatasetVersion.java index 6414239..7884c93 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/DatasetVersion.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/DatasetVersion.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package gobblin.data.management.retention.version; +package org.apache.gobblin.data.management.retention.version; import java.util.Set; import org.apache.hadoop.fs.Path; -import gobblin.data.management.version.FileSystemDatasetVersion; +import org.apache.gobblin.data.management.version.FileSystemDatasetVersion; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/FileStatusDatasetVersion.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/FileStatusDatasetVersion.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/FileStatusDatasetVersion.java index 05622f7..e36bff7 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/FileStatusDatasetVersion.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/FileStatusDatasetVersion.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.retention.version; +package org.apache.gobblin.data.management.retention.version; import java.util.Set; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/HiveDatasetVersionCleaner.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/HiveDatasetVersionCleaner.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/HiveDatasetVersionCleaner.java index 6e907b9..ffcc3b3 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/HiveDatasetVersionCleaner.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/HiveDatasetVersionCleaner.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; import java.util.HashSet; @@ -32,12 +32,12 @@ import com.google.common.base.Optional; import com.google.common.base.Preconditions; import com.typesafe.config.Config; -import gobblin.data.management.retention.dataset.CleanableDataset; -import gobblin.data.management.retention.dataset.CleanableHiveDataset; -import gobblin.data.management.version.DatasetVersion; -import gobblin.data.management.version.HiveDatasetVersion; -import gobblin.util.AutoReturnableObject; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.data.management.retention.dataset.CleanableDataset; +import org.apache.gobblin.data.management.retention.dataset.CleanableHiveDataset; +import org.apache.gobblin.data.management.version.DatasetVersion; +import org.apache.gobblin.data.management.version.HiveDatasetVersion; +import org.apache.gobblin.util.AutoReturnableObject; +import org.apache.gobblin.util.ConfigUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/StringDatasetVersion.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/StringDatasetVersion.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/StringDatasetVersion.java index fa8df7a..194c04d 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/StringDatasetVersion.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/StringDatasetVersion.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.retention.version; +package org.apache.gobblin.data.management.retention.version; import java.util.Set; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/TimestampedDatasetVersion.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/TimestampedDatasetVersion.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/TimestampedDatasetVersion.java index 9553e6a..a25cab9 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/TimestampedDatasetVersion.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/TimestampedDatasetVersion.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.retention.version; +package org.apache.gobblin.data.management.retention.version; import java.util.Collection; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/VersionCleaner.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/VersionCleaner.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/VersionCleaner.java index f44e726..ee0a36c 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/VersionCleaner.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/VersionCleaner.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; @@ -22,8 +22,8 @@ import com.google.common.base.Preconditions; import lombok.extern.slf4j.Slf4j; -import gobblin.data.management.retention.dataset.CleanableDataset; -import gobblin.data.management.version.DatasetVersion; +import org.apache.gobblin.data.management.retention.dataset.CleanableDataset; +import org.apache.gobblin.data.management.version.DatasetVersion; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/DatasetVersionFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/DatasetVersionFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/DatasetVersionFinder.java index a0fde57..a509b19 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/DatasetVersionFinder.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/DatasetVersionFinder.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package gobblin.data.management.retention.version.finder; +package org.apache.gobblin.data.management.retention.version.finder; import java.util.Properties; import org.apache.hadoop.fs.FileSystem; -import gobblin.data.management.retention.version.DatasetVersion; +import org.apache.gobblin.data.management.retention.version.DatasetVersion; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/DateTimeDatasetVersionFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/DateTimeDatasetVersionFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/DateTimeDatasetVersionFinder.java index 0631404..0c05215 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/DateTimeDatasetVersionFinder.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/DateTimeDatasetVersionFinder.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.retention.version.finder; +package org.apache.gobblin.data.management.retention.version.finder; import java.io.IOException; import java.util.Properties; @@ -26,8 +26,8 @@ import org.apache.hadoop.fs.Path; import com.typesafe.config.Config; -import gobblin.data.management.retention.version.DatasetVersion; -import gobblin.data.management.retention.version.TimestampedDatasetVersion; +import org.apache.gobblin.data.management.retention.version.DatasetVersion; +import org.apache.gobblin.data.management.retention.version.TimestampedDatasetVersion; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/FileLevelTimestampVersionFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/FileLevelTimestampVersionFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/FileLevelTimestampVersionFinder.java index ca84b92..a5e2750 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/FileLevelTimestampVersionFinder.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/FileLevelTimestampVersionFinder.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.retention.version.finder; +package org.apache.gobblin.data.management.retention.version.finder; import java.io.IOException; import java.util.Collection; @@ -23,9 +23,9 @@ import java.util.Properties; import org.apache.hadoop.fs.FileSystem; -import gobblin.data.management.retention.version.TimestampedDatasetVersion; -import gobblin.data.management.retention.version.DatasetVersion; -import gobblin.dataset.Dataset; +import org.apache.gobblin.data.management.retention.version.TimestampedDatasetVersion; +import org.apache.gobblin.data.management.retention.version.DatasetVersion; +import org.apache.gobblin.dataset.Dataset; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/GlobModTimeDatasetVersionFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/GlobModTimeDatasetVersionFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/GlobModTimeDatasetVersionFinder.java index 88bf426..ec9d866 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/GlobModTimeDatasetVersionFinder.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/GlobModTimeDatasetVersionFinder.java @@ -14,15 +14,15 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.retention.version.finder; +package org.apache.gobblin.data.management.retention.version.finder; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; import com.typesafe.config.Config; -import gobblin.data.management.retention.version.DatasetVersion; -import gobblin.data.management.retention.version.TimestampedDatasetVersion; +import org.apache.gobblin.data.management.retention.version.DatasetVersion; +import org.apache.gobblin.data.management.retention.version.TimestampedDatasetVersion; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/ModDateTimeDatasetVersionFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/ModDateTimeDatasetVersionFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/ModDateTimeDatasetVersionFinder.java index 427d77d..028ed66 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/ModDateTimeDatasetVersionFinder.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/ModDateTimeDatasetVersionFinder.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.retention.version.finder; +package org.apache.gobblin.data.management.retention.version.finder; import java.io.IOException; import java.util.Collection; @@ -23,9 +23,9 @@ import java.util.Properties; import org.apache.hadoop.fs.FileSystem; -import gobblin.data.management.retention.version.TimestampedDatasetVersion; -import gobblin.data.management.retention.version.DatasetVersion; -import gobblin.dataset.Dataset; +import org.apache.gobblin.data.management.retention.version.TimestampedDatasetVersion; +import org.apache.gobblin.data.management.retention.version.DatasetVersion; +import org.apache.gobblin.dataset.Dataset; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/SingleVersionFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/SingleVersionFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/SingleVersionFinder.java index 1adb9d1..d53ce6c 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/SingleVersionFinder.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/SingleVersionFinder.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.retention.version.finder; +package org.apache.gobblin.data.management.retention.version.finder; import java.io.IOException; import java.util.Collection; @@ -27,10 +27,10 @@ import com.google.common.collect.Lists; import lombok.Getter; -import gobblin.data.management.retention.version.DatasetVersion; -import gobblin.data.management.retention.version.FileStatusDatasetVersion; -import gobblin.dataset.Dataset; -import gobblin.dataset.FileSystemDataset; +import org.apache.gobblin.data.management.retention.version.DatasetVersion; +import org.apache.gobblin.data.management.retention.version.FileStatusDatasetVersion; +import org.apache.gobblin.dataset.Dataset; +import org.apache.gobblin.dataset.FileSystemDataset; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/UnixTimestampVersionFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/UnixTimestampVersionFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/UnixTimestampVersionFinder.java index cdf7fe1..10b2511 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/UnixTimestampVersionFinder.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/UnixTimestampVersionFinder.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package gobblin.data.management.retention.version.finder; +package org.apache.gobblin.data.management.retention.version.finder; -import gobblin.data.management.retention.version.DatasetVersion; -import gobblin.data.management.retention.version.TimestampedDatasetVersion; +import org.apache.gobblin.data.management.retention.version.DatasetVersion; +import org.apache.gobblin.data.management.retention.version.TimestampedDatasetVersion; import java.util.Properties; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/VersionFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/VersionFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/VersionFinder.java index aed468e..b6f81d9 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/VersionFinder.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/VersionFinder.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.data.management.retention.version.finder; +package org.apache.gobblin.data.management.retention.version.finder; -import gobblin.data.management.retention.version.DatasetVersion; +import org.apache.gobblin.data.management.retention.version.DatasetVersion; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/WatermarkDatasetVersionFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/WatermarkDatasetVersionFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/WatermarkDatasetVersionFinder.java index af0d738..60c6cb5 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/WatermarkDatasetVersionFinder.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/WatermarkDatasetVersionFinder.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.retention.version.finder; +package org.apache.gobblin.data.management.retention.version.finder; import java.util.Properties; @@ -24,8 +24,8 @@ import lombok.extern.slf4j.Slf4j; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; -import gobblin.data.management.retention.version.DatasetVersion; -import gobblin.data.management.retention.version.StringDatasetVersion; +import org.apache.gobblin.data.management.retention.version.DatasetVersion; +import org.apache.gobblin.data.management.retention.version.StringDatasetVersion; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/AsyncTrash.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/AsyncTrash.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/AsyncTrash.java index 905781d..a57687c 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/AsyncTrash.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/AsyncTrash.java @@ -15,11 +15,11 @@ * limitations under the License. */ -package gobblin.data.management.trash; +package org.apache.gobblin.data.management.trash; -import gobblin.util.Decorator; -import gobblin.util.ExecutorsUtils; -import gobblin.util.executors.ScalingThreadPoolExecutor; +import org.apache.gobblin.util.Decorator; +import org.apache.gobblin.util.ExecutorsUtils; +import org.apache.gobblin.util.executors.ScalingThreadPoolExecutor; import java.io.Closeable; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/GobblinProxiedTrash.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/GobblinProxiedTrash.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/GobblinProxiedTrash.java index 5cdfa5d..bcb262a 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/GobblinProxiedTrash.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/GobblinProxiedTrash.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/main/java/org/apache/gobblin/data/management/trash/GobblinTrash.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/GobblinTrash.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/GobblinTrash.java index f997fa8..ab166aa 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/GobblinTrash.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/GobblinTrash.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/main/java/org/apache/gobblin/data/management/trash/ImmediateDeletionTrash.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/ImmediateDeletionTrash.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/ImmediateDeletionTrash.java index fdb0bf2..ca8c7cf 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/ImmediateDeletionTrash.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/ImmediateDeletionTrash.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; @@ -23,7 +23,7 @@ import java.util.Properties; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; -import gobblin.util.ProxiedFileSystemCache; +import org.apache.gobblin.util.ProxiedFileSystemCache; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/MockTrash.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/MockTrash.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/MockTrash.java index 60e0b28..58aed6a 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/MockTrash.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/MockTrash.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.List; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/NoopSnapshotCleanupPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/NoopSnapshotCleanupPolicy.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/NoopSnapshotCleanupPolicy.java index a89524b..cbf6423 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/NoopSnapshotCleanupPolicy.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/NoopSnapshotCleanupPolicy.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/main/java/org/apache/gobblin/data/management/trash/ProxiedTrash.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/ProxiedTrash.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/ProxiedTrash.java index b7af0b0..2453c16 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/ProxiedTrash.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/ProxiedTrash.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.List; @@ -34,7 +34,7 @@ import com.google.common.cache.Cache; import com.google.common.cache.CacheBuilder; import com.google.common.collect.Lists; -import gobblin.util.ProxiedFileSystemCache; +import org.apache.gobblin.util.ProxiedFileSystemCache; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/SnapshotCleanupPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/SnapshotCleanupPolicy.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/SnapshotCleanupPolicy.java index 8d5fed5..a84317e 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/SnapshotCleanupPolicy.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/SnapshotCleanupPolicy.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.trash; +package org.apache.gobblin.data.management.trash; import org.apache.hadoop.fs.FileStatus; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/TestTrash.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/TestTrash.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/TestTrash.java index be8c5e8..864c147 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/TestTrash.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/TestTrash.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.List; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/TimeBasedSnapshotCleanupPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/TimeBasedSnapshotCleanupPolicy.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/TimeBasedSnapshotCleanupPolicy.java index ea90c8f..54c084b 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/TimeBasedSnapshotCleanupPolicy.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/TimeBasedSnapshotCleanupPolicy.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/main/java/org/apache/gobblin/data/management/trash/Trash.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/Trash.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/Trash.java index d4b2ad3..caf95d0 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/Trash.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/Trash.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; @@ -38,7 +38,7 @@ import org.joda.time.format.DateTimeFormatter; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import gobblin.util.PathUtils; +import org.apache.gobblin.util.PathUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/TrashFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/TrashFactory.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/TrashFactory.java index 665cb1e..79aa677 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/TrashFactory.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/TrashFactory.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/main/java/org/apache/gobblin/data/management/version/DatasetVersion.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/DatasetVersion.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/DatasetVersion.java index 613e39a..12879bb 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/DatasetVersion.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/DatasetVersion.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.version; +package org.apache.gobblin.data.management.version; /** * Dataset version. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/FileStatusAware.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/FileStatusAware.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/FileStatusAware.java index c177185..3049b62 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/FileStatusAware.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/FileStatusAware.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.version; +package org.apache.gobblin.data.management.version; import java.util.Set; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/FileStatusDatasetVersion.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/FileStatusDatasetVersion.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/FileStatusDatasetVersion.java index 113a59c..fac432d 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/FileStatusDatasetVersion.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/FileStatusDatasetVersion.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.version; +package org.apache.gobblin.data.management.version; import java.util.Set; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/FileStatusTimestampedDatasetVersion.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/FileStatusTimestampedDatasetVersion.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/FileStatusTimestampedDatasetVersion.java index 7065952..c0d09eb 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/FileStatusTimestampedDatasetVersion.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/FileStatusTimestampedDatasetVersion.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.version; +package org.apache.gobblin.data.management.version; import java.util.Set; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/FileSystemDatasetVersion.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/FileSystemDatasetVersion.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/FileSystemDatasetVersion.java index 2a154fa..07e9741 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/FileSystemDatasetVersion.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/FileSystemDatasetVersion.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.version; +package org.apache.gobblin.data.management.version; import java.util.Set; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/HiveDatasetVersion.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/HiveDatasetVersion.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/HiveDatasetVersion.java index 0bba8f2..ec7dad4 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/HiveDatasetVersion.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/HiveDatasetVersion.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.version; +package org.apache.gobblin.data.management.version; import org.apache.hadoop.hive.ql.metadata.Partition; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/StringDatasetVersion.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/StringDatasetVersion.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/StringDatasetVersion.java index 6b0bde2..df22cae 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/StringDatasetVersion.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/StringDatasetVersion.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.version; +package org.apache.gobblin.data.management.version; import java.util.Set; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/TimestampedDatasetVersion.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/TimestampedDatasetVersion.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/TimestampedDatasetVersion.java index 95490dd..33719af 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/TimestampedDatasetVersion.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/TimestampedDatasetVersion.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.version; +package org.apache.gobblin.data.management.version; import java.util.Set; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/TimestampedHiveDatasetVersion.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/TimestampedHiveDatasetVersion.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/TimestampedHiveDatasetVersion.java index 3f67742..60d17ea 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/TimestampedHiveDatasetVersion.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/TimestampedHiveDatasetVersion.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.version; +package org.apache.gobblin.data.management.version; import lombok.EqualsAndHashCode; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/AbstractDatasetVersionFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/AbstractDatasetVersionFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/AbstractDatasetVersionFinder.java index 8ecfb3c..12fcf9f 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/AbstractDatasetVersionFinder.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/AbstractDatasetVersionFinder.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.version.finder; +package org.apache.gobblin.data.management.version.finder; import java.io.IOException; import java.util.Collection; @@ -28,10 +28,10 @@ import org.apache.hadoop.fs.Path; import com.google.common.collect.Lists; -import gobblin.dataset.Dataset; -import gobblin.dataset.FileSystemDataset; -import gobblin.data.management.version.FileSystemDatasetVersion; -import gobblin.util.PathUtils; +import org.apache.gobblin.dataset.Dataset; +import org.apache.gobblin.dataset.FileSystemDataset; +import org.apache.gobblin.data.management.version.FileSystemDatasetVersion; +import org.apache.gobblin.util.PathUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/AbstractHiveDatasetVersionFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/AbstractHiveDatasetVersionFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/AbstractHiveDatasetVersionFinder.java index af5061a..ce167b4 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/AbstractHiveDatasetVersionFinder.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/AbstractHiveDatasetVersionFinder.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 java.io.IOException; import java.util.Collection; @@ -31,12 +31,12 @@ import com.google.common.base.Predicates; import com.google.common.collect.Iterables; import com.google.common.collect.Lists; -import gobblin.data.management.copy.hive.HiveDataset; -import gobblin.data.management.copy.hive.HiveUtils; -import gobblin.data.management.version.DatasetVersion; -import gobblin.data.management.version.HiveDatasetVersion; -import gobblin.dataset.Dataset; -import gobblin.util.AutoReturnableObject; +import org.apache.gobblin.data.management.copy.hive.HiveDataset; +import org.apache.gobblin.data.management.copy.hive.HiveUtils; +import org.apache.gobblin.data.management.version.DatasetVersion; +import org.apache.gobblin.data.management.version.HiveDatasetVersion; +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-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/DatasetVersionFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/DatasetVersionFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/DatasetVersionFinder.java index a34a335..ba38584 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/DatasetVersionFinder.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/DatasetVersionFinder.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.version.finder; +package org.apache.gobblin.data.management.version.finder; import java.util.Properties; @@ -23,8 +23,8 @@ import org.apache.hadoop.fs.FileStatus; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; -import gobblin.data.management.version.FileSystemDatasetVersion; -import gobblin.dataset.FileSystemDataset; +import org.apache.gobblin.data.management.version.FileSystemDatasetVersion; +import org.apache.gobblin.dataset.FileSystemDataset; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/DatePartitionHiveVersionFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/DatePartitionHiveVersionFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/DatePartitionHiveVersionFinder.java index 0255699..cc01a55 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/DatePartitionHiveVersionFinder.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/DatePartitionHiveVersionFinder.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 org.apache.commons.lang3.StringUtils; import org.apache.hadoop.fs.FileSystem; @@ -28,9 +28,9 @@ import com.google.common.base.Predicate; import com.google.common.collect.Iterables; import com.typesafe.config.Config; -import gobblin.configuration.ConfigurationKeys; -import gobblin.data.management.version.TimestampedHiveDatasetVersion; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.data.management.version.TimestampedHiveDatasetVersion; +import org.apache.gobblin.util.ConfigUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/DateTimeDatasetVersionFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/DateTimeDatasetVersionFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/DateTimeDatasetVersionFinder.java index bc3600f..7a2fc92 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/DateTimeDatasetVersionFinder.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/DateTimeDatasetVersionFinder.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.version.finder; +package org.apache.gobblin.data.management.version.finder; import java.util.Properties; @@ -33,10 +33,10 @@ import com.google.common.base.Preconditions; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.configuration.ConfigurationKeys; -import gobblin.data.management.version.FileStatusTimestampedDatasetVersion; -import gobblin.data.management.version.FileSystemDatasetVersion; -import gobblin.data.management.version.TimestampedDatasetVersion; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.data.management.version.FileStatusTimestampedDatasetVersion; +import org.apache.gobblin.data.management.version.FileSystemDatasetVersion; +import org.apache.gobblin.data.management.version.TimestampedDatasetVersion; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/FileLevelTimestampVersionFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/FileLevelTimestampVersionFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/FileLevelTimestampVersionFinder.java index 44f39ea..f688813 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/FileLevelTimestampVersionFinder.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/FileLevelTimestampVersionFinder.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.version.finder; +package org.apache.gobblin.data.management.version.finder; import java.io.IOException; import java.util.Collection; @@ -32,11 +32,11 @@ import com.google.common.collect.Lists; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.data.management.version.FileSystemDatasetVersion; -import gobblin.data.management.version.TimestampedDatasetVersion; -import gobblin.dataset.Dataset; -import gobblin.dataset.FileSystemDataset; -import gobblin.util.FileListUtils; +import org.apache.gobblin.data.management.version.FileSystemDatasetVersion; +import org.apache.gobblin.data.management.version.TimestampedDatasetVersion; +import org.apache.gobblin.dataset.Dataset; +import org.apache.gobblin.dataset.FileSystemDataset; +import org.apache.gobblin.util.FileListUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/GlobModTimeDatasetVersionFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/GlobModTimeDatasetVersionFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/GlobModTimeDatasetVersionFinder.java index 904fb72..c71eb2d 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/GlobModTimeDatasetVersionFinder.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/GlobModTimeDatasetVersionFinder.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.version.finder; +package org.apache.gobblin.data.management.version.finder; import java.io.IOException; import java.util.Properties; @@ -27,8 +27,8 @@ import org.joda.time.DateTime; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.data.management.version.FileSystemDatasetVersion; -import gobblin.data.management.version.TimestampedDatasetVersion; +import org.apache.gobblin.data.management.version.FileSystemDatasetVersion; +import org.apache.gobblin.data.management.version.TimestampedDatasetVersion; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/ModDateTimeDatasetVersionFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/ModDateTimeDatasetVersionFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/ModDateTimeDatasetVersionFinder.java index 00125f6..bc0e1a3 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/ModDateTimeDatasetVersionFinder.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/ModDateTimeDatasetVersionFinder.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.version.finder; +package org.apache.gobblin.data.management.version.finder; import java.io.IOException; import java.util.Collection; @@ -29,10 +29,10 @@ import com.google.common.collect.Lists; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.data.management.version.FileSystemDatasetVersion; -import gobblin.data.management.version.TimestampedDatasetVersion; -import gobblin.dataset.Dataset; -import gobblin.dataset.FileSystemDataset; +import org.apache.gobblin.data.management.version.FileSystemDatasetVersion; +import org.apache.gobblin.data.management.version.TimestampedDatasetVersion; +import org.apache.gobblin.dataset.Dataset; +import org.apache.gobblin.dataset.FileSystemDataset; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/SingleVersionFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/SingleVersionFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/SingleVersionFinder.java index 6dc089f..8fde9a9 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/SingleVersionFinder.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/SingleVersionFinder.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.version.finder; +package org.apache.gobblin.data.management.version.finder; import java.io.IOException; import java.util.Collection; @@ -28,11 +28,11 @@ import org.apache.hadoop.fs.FileSystem; import lombok.Getter; -import gobblin.dataset.Dataset; -import gobblin.dataset.FileSystemDataset; -import gobblin.data.management.version.FileSystemDatasetVersion; -import gobblin.data.management.version.FileStatusDatasetVersion; -import gobblin.data.management.version.StringDatasetVersion; +import org.apache.gobblin.dataset.Dataset; +import org.apache.gobblin.dataset.FileSystemDataset; +import org.apache.gobblin.data.management.version.FileSystemDatasetVersion; +import org.apache.gobblin.data.management.version.FileStatusDatasetVersion; +import org.apache.gobblin.data.management.version.StringDatasetVersion; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/UnixTimestampVersionFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/UnixTimestampVersionFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/UnixTimestampVersionFinder.java index 8d08427..46288be 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/UnixTimestampVersionFinder.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/UnixTimestampVersionFinder.java @@ -15,11 +15,11 @@ * limitations under the License. */ -package gobblin.data.management.version.finder; +package org.apache.gobblin.data.management.version.finder; -import gobblin.data.management.version.FileSystemDatasetVersion; -import gobblin.data.management.version.StringDatasetVersion; -import gobblin.data.management.version.TimestampedDatasetVersion; +import org.apache.gobblin.data.management.version.FileSystemDatasetVersion; +import org.apache.gobblin.data.management.version.StringDatasetVersion; +import org.apache.gobblin.data.management.version.TimestampedDatasetVersion; import java.util.Properties; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/VersionFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/VersionFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/VersionFinder.java index e1599c0..7b8b14f 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/VersionFinder.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/VersionFinder.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package gobblin.data.management.version.finder; +package org.apache.gobblin.data.management.version.finder; import java.io.IOException; import java.util.Collection; -import gobblin.dataset.Dataset; -import gobblin.data.management.version.DatasetVersion; +import org.apache.gobblin.dataset.Dataset; +import org.apache.gobblin.data.management.version.DatasetVersion; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/WatermarkDatasetVersionFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/WatermarkDatasetVersionFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/WatermarkDatasetVersionFinder.java index 9446460..5c14054 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/WatermarkDatasetVersionFinder.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/WatermarkDatasetVersionFinder.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package gobblin.data.management.version.finder; +package org.apache.gobblin.data.management.version.finder; -import gobblin.data.management.version.FileSystemDatasetVersion; -import gobblin.data.management.version.StringDatasetVersion; +import org.apache.gobblin.data.management.version.FileSystemDatasetVersion; +import org.apache.gobblin.data.management.version.StringDatasetVersion; import java.util.Properties; import java.util.regex.Matcher; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblinDistcp.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblinDistcp.java b/gobblin-data-management/src/main/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblinDistcp.java index 59f79a0..e52748f 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblinDistcp.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblinDistcp.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.embedded; +package org.apache.gobblin.runtime.embedded; import java.io.IOException; import java.net.URISyntaxException; @@ -25,16 +25,16 @@ import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.Path; import org.apache.hadoop.util.ClassUtil; -import gobblin.annotation.Alias; -import gobblin.configuration.ConfigurationKeys; -import gobblin.data.management.copy.CopySource; -import gobblin.data.management.copy.RecursiveCopyableDataset; -import gobblin.runtime.api.JobTemplate; -import gobblin.runtime.api.SpecNotFoundException; -import gobblin.runtime.cli.CliObjectOption; -import gobblin.runtime.cli.NotOnCli; -import gobblin.runtime.cli.PublicMethodsGobblinCliFactory; -import gobblin.runtime.template.ResourceBasedJobTemplate; +import org.apache.gobblin.annotation.Alias; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.data.management.copy.CopySource; +import org.apache.gobblin.data.management.copy.RecursiveCopyableDataset; +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.NotOnCli; +import org.apache.gobblin.runtime.cli.PublicMethodsGobblinCliFactory; +import org.apache.gobblin.runtime.template.ResourceBasedJobTemplate; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/runtime/retention/DatasetCleanerCli.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/runtime/retention/DatasetCleanerCli.java b/gobblin-data-management/src/main/java/org/apache/gobblin/runtime/retention/DatasetCleanerCli.java index f1ca40c..47b4cf0 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/runtime/retention/DatasetCleanerCli.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/runtime/retention/DatasetCleanerCli.java @@ -15,11 +15,11 @@ * limitations under the License. */ -package gobblin.runtime.retention; +package org.apache.gobblin.runtime.retention; -import gobblin.annotation.Alias; -import gobblin.data.management.retention.DatasetCleaner; -import gobblin.runtime.cli.CliApplication; +import org.apache.gobblin.annotation.Alias; +import org.apache.gobblin.data.management.retention.DatasetCleaner; +import org.apache.gobblin.runtime.cli.CliApplication; import org.apache.commons.cli.CommandLine; import org.apache.commons.cli.CommandLineParser; import org.apache.commons.cli.DefaultParser; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/util/commit/DeleteFileCommitStep.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/util/commit/DeleteFileCommitStep.java b/gobblin-data-management/src/main/java/org/apache/gobblin/util/commit/DeleteFileCommitStep.java index 82084e4..bf105a6 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/util/commit/DeleteFileCommitStep.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/util/commit/DeleteFileCommitStep.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.commit; +package org.apache.gobblin.util.commit; import java.io.IOException; import java.net.URI; @@ -38,10 +38,10 @@ import com.google.common.collect.Lists; import com.google.common.collect.Iterables; import com.google.common.collect.Sets; -import gobblin.commit.CommitStep; -import gobblin.data.management.trash.Trash; -import gobblin.data.management.trash.TrashFactory; -import gobblin.util.PathUtils; +import org.apache.gobblin.commit.CommitStep; +import org.apache.gobblin.data.management.trash.Trash; +import org.apache.gobblin.data.management.trash.TrashFactory; +import org.apache.gobblin.util.PathUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/util/request_allocation/SimpleHiveDatasetTieringPrioritizer.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/util/request_allocation/SimpleHiveDatasetTieringPrioritizer.java b/gobblin-data-management/src/main/java/org/apache/gobblin/util/request_allocation/SimpleHiveDatasetTieringPrioritizer.java index 8c6a6b0..5123ad2 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/util/request_allocation/SimpleHiveDatasetTieringPrioritizer.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/util/request_allocation/SimpleHiveDatasetTieringPrioritizer.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util.request_allocation; +package org.apache.gobblin.util.request_allocation; import java.io.IOException; import java.io.Serializable; @@ -28,15 +28,15 @@ import java.util.regex.Pattern; import com.google.common.collect.Maps; -import gobblin.annotation.Alias; -import gobblin.data.management.copy.AllEqualComparator; -import gobblin.data.management.copy.CopyEntity; -import gobblin.data.management.copy.hive.HiveDataset; -import gobblin.data.management.copy.hive.WhitelistBlacklist; -import gobblin.data.management.copy.prioritization.FileSetComparator; -import gobblin.data.management.partition.CopyableDatasetRequestor; -import gobblin.data.management.partition.FileSet; -import gobblin.dataset.Dataset; +import org.apache.gobblin.annotation.Alias; +import org.apache.gobblin.data.management.copy.AllEqualComparator; +import org.apache.gobblin.data.management.copy.CopyEntity; +import org.apache.gobblin.data.management.copy.hive.HiveDataset; +import org.apache.gobblin.data.management.copy.hive.WhitelistBlacklist; +import org.apache.gobblin.data.management.copy.prioritization.FileSetComparator; +import org.apache.gobblin.data.management.partition.CopyableDatasetRequestor; +import org.apache.gobblin.data.management.partition.FileSet; +import org.apache.gobblin.dataset.Dataset; import lombok.AllArgsConstructor; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/util/test/RetentionTestDataGenerator.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/util/test/RetentionTestDataGenerator.java b/gobblin-data-management/src/main/java/org/apache/gobblin/util/test/RetentionTestDataGenerator.java index c10f869..2f85dae 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/util/test/RetentionTestDataGenerator.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/util/test/RetentionTestDataGenerator.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.util.test; +package org.apache.gobblin.util.test; import java.io.File; import java.io.IOException; @@ -35,8 +35,8 @@ import org.testng.Assert; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.configuration.ConfigurationKeys; -import gobblin.util.PathUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.util.PathUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/util/test/RetentionTestHelper.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/util/test/RetentionTestHelper.java b/gobblin-data-management/src/main/java/org/apache/gobblin/util/test/RetentionTestHelper.java index 7fa7647..d4ba4b9 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/util/test/RetentionTestHelper.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/util/test/RetentionTestHelper.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.util.test; +package org.apache.gobblin.util.test; import static org.mockito.Matchers.any; import static org.mockito.Mockito.mock; @@ -35,16 +35,16 @@ import com.google.common.collect.ImmutableMap; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.config.client.ConfigClient; -import gobblin.configuration.ConfigurationKeys; -import gobblin.data.management.retention.DatasetCleaner; -import gobblin.data.management.retention.dataset.CleanableDataset; -import gobblin.data.management.retention.dataset.CleanableDatasetBase; -import gobblin.data.management.retention.profile.MultiCleanableDatasetFinder; -import gobblin.dataset.Dataset; -import gobblin.dataset.DatasetsFinder; -import gobblin.util.PathUtils; -import gobblin.util.reflection.GobblinConstructorUtils; +import org.apache.gobblin.config.client.ConfigClient; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.data.management.retention.DatasetCleaner; +import org.apache.gobblin.data.management.retention.dataset.CleanableDataset; +import org.apache.gobblin.data.management.retention.dataset.CleanableDatasetBase; +import org.apache.gobblin.data.management.retention.profile.MultiCleanableDatasetFinder; +import org.apache.gobblin.dataset.Dataset; +import org.apache.gobblin.dataset.DatasetsFinder; +import org.apache.gobblin.util.PathUtils; +import org.apache.gobblin.util.reflection.GobblinConstructorUtils; /** * Helper methods for Retention integration tests http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/ConversionHiveTestUtils.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/ConversionHiveTestUtils.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/ConversionHiveTestUtils.java index 2f5b69e..1f2d263 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/ConversionHiveTestUtils.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/ConversionHiveTestUtils.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management; +package org.apache.gobblin.data.management; import java.io.IOException; import java.io.InputStream; @@ -25,9 +25,9 @@ import org.apache.commons.io.IOUtils; import org.apache.commons.lang3.StringUtils; import org.apache.hadoop.fs.Path; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.source.extractor.extract.LongWatermark; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.source.extractor.extract.LongWatermark; public class ConversionHiveTestUtils { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/BackfillHiveSourceTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/BackfillHiveSourceTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/BackfillHiveSourceTest.java index 4f9991a..f28dc06 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/BackfillHiveSourceTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/BackfillHiveSourceTest.java @@ -14,16 +14,16 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.conversion.hive; +package org.apache.gobblin.data.management.conversion.hive; import org.apache.hadoop.hive.ql.metadata.Partition; import org.mockito.Mockito; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.configuration.SourceState; -import gobblin.data.management.conversion.hive.source.BackfillHiveSource; -import gobblin.source.extractor.extract.LongWatermark; +import org.apache.gobblin.configuration.SourceState; +import org.apache.gobblin.data.management.conversion.hive.source.BackfillHiveSource; +import org.apache.gobblin.source.extractor.extract.LongWatermark; @Test(groups = {"gobblin.data.management.conversion"}) http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/CopyPartitionParametersTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/CopyPartitionParametersTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/CopyPartitionParametersTest.java index eb5b93c..4441bf7 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/CopyPartitionParametersTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/CopyPartitionParametersTest.java @@ -1,4 +1,4 @@ -package gobblin.data.management.conversion.hive; +package org.apache.gobblin.data.management.conversion.hive; import java.util.Collections; import java.util.HashMap; @@ -12,8 +12,8 @@ import org.testng.annotations.Test; import com.google.common.base.Optional; -import gobblin.configuration.WorkUnitState; -import gobblin.data.management.conversion.hive.publisher.HiveConvertPublisher; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.data.management.conversion.hive.publisher.HiveConvertPublisher; /**
