http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/writer/FileAwareInputStreamDataWriter.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/writer/FileAwareInputStreamDataWriter.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/writer/FileAwareInputStreamDataWriter.java index 4d0b42b..ec9eea1 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/writer/FileAwareInputStreamDataWriter.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/writer/FileAwareInputStreamDataWriter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.copy.writer; +package org.apache.gobblin.data.management.copy.writer; import java.io.IOException; import java.io.InputStream; @@ -44,37 +44,37 @@ import com.google.common.io.Closer; import lombok.extern.slf4j.Slf4j; -import gobblin.broker.EmptyKey; -import gobblin.broker.gobblin_scopes.GobblinScopeTypes; -import gobblin.broker.iface.NotConfiguredException; -import gobblin.broker.iface.SharedResourcesBroker; -import gobblin.commit.SpeculativeAttemptAwareConstruct; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.crypto.EncryptionConfigParser; -import gobblin.crypto.EncryptionFactory; -import gobblin.data.management.copy.CopyConfiguration; -import gobblin.data.management.copy.CopyEntity; -import gobblin.data.management.copy.CopySource; -import gobblin.data.management.copy.CopyableDatasetMetadata; -import gobblin.data.management.copy.CopyableFile; -import gobblin.data.management.copy.FileAwareInputStream; -import gobblin.data.management.copy.OwnerAndPermission; -import gobblin.data.management.copy.PreserveAttributes; -import gobblin.data.management.copy.recovery.RecoveryHelper; -import gobblin.instrumented.writer.InstrumentedDataWriter; -import gobblin.metrics.event.sla.SlaEventKeys; -import gobblin.state.ConstructState; -import gobblin.util.FileListUtils; -import gobblin.util.FinalState; -import gobblin.util.ForkOperatorUtils; -import gobblin.util.PathUtils; -import gobblin.util.WriterUtils; -import gobblin.util.io.StreamCopier; -import gobblin.util.io.StreamThrottler; -import gobblin.util.io.ThrottledInputStream; -import gobblin.writer.DataWriter; +import org.apache.gobblin.broker.EmptyKey; +import org.apache.gobblin.broker.gobblin_scopes.GobblinScopeTypes; +import org.apache.gobblin.broker.iface.NotConfiguredException; +import org.apache.gobblin.broker.iface.SharedResourcesBroker; +import org.apache.gobblin.commit.SpeculativeAttemptAwareConstruct; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.crypto.EncryptionConfigParser; +import org.apache.gobblin.crypto.EncryptionFactory; +import org.apache.gobblin.data.management.copy.CopyConfiguration; +import org.apache.gobblin.data.management.copy.CopyEntity; +import org.apache.gobblin.data.management.copy.CopySource; +import org.apache.gobblin.data.management.copy.CopyableDatasetMetadata; +import org.apache.gobblin.data.management.copy.CopyableFile; +import org.apache.gobblin.data.management.copy.FileAwareInputStream; +import org.apache.gobblin.data.management.copy.OwnerAndPermission; +import org.apache.gobblin.data.management.copy.PreserveAttributes; +import org.apache.gobblin.data.management.copy.recovery.RecoveryHelper; +import org.apache.gobblin.instrumented.writer.InstrumentedDataWriter; +import org.apache.gobblin.metrics.event.sla.SlaEventKeys; +import org.apache.gobblin.state.ConstructState; +import org.apache.gobblin.util.FileListUtils; +import org.apache.gobblin.util.FinalState; +import org.apache.gobblin.util.ForkOperatorUtils; +import org.apache.gobblin.util.PathUtils; +import org.apache.gobblin.util.WriterUtils; +import org.apache.gobblin.util.io.StreamCopier; +import org.apache.gobblin.util.io.StreamThrottler; +import org.apache.gobblin.util.io.ThrottledInputStream; +import org.apache.gobblin.writer.DataWriter; /**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/writer/FileAwareInputStreamDataWriterBuilder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/writer/FileAwareInputStreamDataWriterBuilder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/writer/FileAwareInputStreamDataWriterBuilder.java index 33fafc3..a162034 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/writer/FileAwareInputStreamDataWriterBuilder.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/writer/FileAwareInputStreamDataWriterBuilder.java @@ -14,13 +14,13 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.copy.writer; +package org.apache.gobblin.data.management.copy.writer; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.data.management.copy.FileAwareInputStream; -import gobblin.writer.DataWriter; -import gobblin.writer.DataWriterBuilder; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.data.management.copy.FileAwareInputStream; +import org.apache.gobblin.writer.DataWriter; +import org.apache.gobblin.writer.DataWriterBuilder; 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/copy/writer/TarArchiveInputStreamDataWriter.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/writer/TarArchiveInputStreamDataWriter.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/writer/TarArchiveInputStreamDataWriter.java index 6a44d33..1804ae6 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/writer/TarArchiveInputStreamDataWriter.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/writer/TarArchiveInputStreamDataWriter.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package gobblin.data.management.copy.writer; +package org.apache.gobblin.data.management.copy.writer; -import gobblin.configuration.State; -import gobblin.data.management.copy.CopyableFile; -import gobblin.data.management.copy.FileAwareInputStream; -import gobblin.util.io.StreamCopier; -import gobblin.util.io.StreamUtils; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.data.management.copy.CopyableFile; +import org.apache.gobblin.data.management.copy.FileAwareInputStream; +import org.apache.gobblin.util.io.StreamCopier; +import org.apache.gobblin.util.io.StreamUtils; import java.io.IOException; import java.io.InputStream; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/writer/TarArchiveInputStreamDataWriterBuilder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/writer/TarArchiveInputStreamDataWriterBuilder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/writer/TarArchiveInputStreamDataWriterBuilder.java index bde0f23..b064c02 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/writer/TarArchiveInputStreamDataWriterBuilder.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/writer/TarArchiveInputStreamDataWriterBuilder.java @@ -14,11 +14,11 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.copy.writer; +package org.apache.gobblin.data.management.copy.writer; -import gobblin.data.management.copy.FileAwareInputStream; -import gobblin.writer.DataWriter; -import gobblin.writer.DataWriterBuilder; +import org.apache.gobblin.data.management.copy.FileAwareInputStream; +import org.apache.gobblin.writer.DataWriter; +import org.apache.gobblin.writer.DataWriterBuilder; 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/dataset/Dataset.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/Dataset.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/Dataset.java index 02276e4..3996dbb 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/Dataset.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/Dataset.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.dataset; +package org.apache.gobblin.data.management.dataset; /** * {@inheritDoc} http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/DatasetUtils.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/DatasetUtils.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/DatasetUtils.java index f258d3b..0488ac9 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/DatasetUtils.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/DatasetUtils.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.dataset; +package org.apache.gobblin.data.management.dataset; import java.io.IOException; import java.util.Collection; @@ -28,10 +28,10 @@ import org.apache.hadoop.fs.PathFilter; import com.google.common.collect.Lists; -import gobblin.data.management.copy.CopyableFile; -import gobblin.data.management.copy.CopyableFileFilter; -import gobblin.dataset.DatasetsFinder; -import gobblin.util.reflection.GobblinConstructorUtils; +import org.apache.gobblin.data.management.copy.CopyableFile; +import org.apache.gobblin.data.management.copy.CopyableFileFilter; +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/dataset/DefaultFileSystemGlobFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/DefaultFileSystemGlobFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/DefaultFileSystemGlobFinder.java index 2610422..8e03fcc 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/DefaultFileSystemGlobFinder.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/DefaultFileSystemGlobFinder.java @@ -1,7 +1,7 @@ -package gobblin.data.management.dataset; +package org.apache.gobblin.data.management.dataset; -import gobblin.data.management.retention.profile.ConfigurableGlobDatasetFinder; -import gobblin.dataset.FileSystemDataset; +import org.apache.gobblin.data.management.retention.profile.ConfigurableGlobDatasetFinder; +import org.apache.gobblin.dataset.FileSystemDataset; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; 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/dataset/DummyDataset.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/DummyDataset.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/DummyDataset.java index e3cca9d..3d7cc7d 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/DummyDataset.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/DummyDataset.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.dataset; +package org.apache.gobblin.data.management.dataset; import lombok.RequiredArgsConstructor; @@ -27,10 +27,10 @@ import org.apache.hadoop.fs.Path; import com.google.common.collect.ImmutableList; -import gobblin.data.management.copy.CopyConfiguration; -import gobblin.data.management.copy.CopyableDataset; -import gobblin.data.management.copy.CopyEntity; -import gobblin.data.management.retention.dataset.CleanableDataset; +import org.apache.gobblin.data.management.copy.CopyConfiguration; +import org.apache.gobblin.data.management.copy.CopyableDataset; +import org.apache.gobblin.data.management.copy.CopyEntity; +import org.apache.gobblin.data.management.retention.dataset.CleanableDataset; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/SimpleDatasetHierarchicalPrioritizer.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/SimpleDatasetHierarchicalPrioritizer.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/SimpleDatasetHierarchicalPrioritizer.java index e89729e..37bc4fd 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/SimpleDatasetHierarchicalPrioritizer.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/SimpleDatasetHierarchicalPrioritizer.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.dataset; +package org.apache.gobblin.data.management.dataset; import java.io.IOException; import java.io.Serializable; @@ -29,12 +29,12 @@ import com.google.common.collect.Maps; import lombok.AllArgsConstructor; -import gobblin.annotation.Alias; -import gobblin.configuration.State; -import gobblin.data.management.copy.AllEqualComparator; -import gobblin.dataset.Dataset; -import gobblin.util.request_allocation.Requestor; -import gobblin.util.request_allocation.SimpleHierarchicalPrioritizer; +import org.apache.gobblin.annotation.Alias; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.data.management.copy.AllEqualComparator; +import org.apache.gobblin.dataset.Dataset; +import org.apache.gobblin.util.request_allocation.Requestor; +import org.apache.gobblin.util.request_allocation.SimpleHierarchicalPrioritizer; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/SimpleDatasetRequest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/SimpleDatasetRequest.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/SimpleDatasetRequest.java index e1d420d..2ebac43 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/SimpleDatasetRequest.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/SimpleDatasetRequest.java @@ -15,20 +15,20 @@ * limitations under the License. */ -package gobblin.data.management.dataset; +package org.apache.gobblin.data.management.dataset; import com.typesafe.config.Config; import lombok.AllArgsConstructor; import lombok.Getter; -import gobblin.annotation.Alias; -import gobblin.dataset.Dataset; -import gobblin.util.request_allocation.Request; -import gobblin.util.request_allocation.Requestor; -import gobblin.util.request_allocation.ResourceEstimator; -import gobblin.util.request_allocation.ResourcePool; -import gobblin.util.request_allocation.ResourceRequirement; +import org.apache.gobblin.annotation.Alias; +import org.apache.gobblin.dataset.Dataset; +import org.apache.gobblin.util.request_allocation.Request; +import org.apache.gobblin.util.request_allocation.Requestor; +import org.apache.gobblin.util.request_allocation.ResourceEstimator; +import org.apache.gobblin.util.request_allocation.ResourcePool; +import org.apache.gobblin.util.request_allocation.ResourceRequirement; /** * A simple {@link Request} which represents a {@link Dataset} http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/SimpleDatasetRequestor.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/SimpleDatasetRequestor.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/SimpleDatasetRequestor.java index 09a63c8..e58fe08 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/SimpleDatasetRequestor.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/SimpleDatasetRequestor.java @@ -16,7 +16,7 @@ */ -package gobblin.data.management.dataset; +package org.apache.gobblin.data.management.dataset; import java.io.IOException; import java.util.Comparator; @@ -27,8 +27,8 @@ import com.google.common.collect.Iterators; import lombok.AllArgsConstructor; import lombok.Getter; -import gobblin.dataset.Dataset; -import gobblin.util.request_allocation.PushDownRequestor; +import org.apache.gobblin.dataset.Dataset; +import org.apache.gobblin.util.request_allocation.PushDownRequestor; /** * A simple {@link gobblin.util.request_allocation.Requestor} used to generate a single {@link SimpleDatasetRequest} http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/hive/HiveConfigClientUtils.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/hive/HiveConfigClientUtils.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/hive/HiveConfigClientUtils.java index 18809e3..b56a498 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/hive/HiveConfigClientUtils.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/hive/HiveConfigClientUtils.java @@ -14,13 +14,13 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.hive; +package org.apache.gobblin.data.management.hive; import org.apache.hadoop.fs.Path; import org.apache.hadoop.hive.metastore.api.Table; -import gobblin.config.client.ConfigClient; -import gobblin.data.management.copy.hive.HiveDataset; +import org.apache.gobblin.config.client.ConfigClient; +import org.apache.gobblin.data.management.copy.hive.HiveDataset; /** * Utility methods for a {@link HiveDataset} to communicate with {@link ConfigClient} http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/hive/HiveRegistrableDataset.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/hive/HiveRegistrableDataset.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/hive/HiveRegistrableDataset.java index 23941d5..0145b82 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/hive/HiveRegistrableDataset.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/hive/HiveRegistrableDataset.java @@ -15,14 +15,14 @@ * limitations under the License. */ -package gobblin.data.management.hive; +package org.apache.gobblin.data.management.hive; import java.io.IOException; import java.util.List; -import gobblin.annotation.Alpha; -import gobblin.dataset.Dataset; -import gobblin.hive.spec.HiveSpec; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.dataset.Dataset; +import org.apache.gobblin.hive.spec.HiveSpec; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/partition/CopyableDatasetRequestor.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/partition/CopyableDatasetRequestor.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/partition/CopyableDatasetRequestor.java index d96264a..50fd6f6 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/partition/CopyableDatasetRequestor.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/partition/CopyableDatasetRequestor.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.partition; +package org.apache.gobblin.data.management.partition; import java.io.IOException; import java.util.Collections; @@ -31,14 +31,14 @@ import com.google.common.collect.Iterators; import com.google.common.collect.Lists; import com.google.common.base.Optional; -import gobblin.data.management.copy.CopyConfiguration; -import gobblin.data.management.copy.CopyEntity; -import gobblin.data.management.copy.CopyableDataset; -import gobblin.data.management.copy.CopyableDatasetBase; -import gobblin.data.management.copy.IterableCopyableDataset; -import gobblin.data.management.copy.IterableCopyableDatasetImpl; -import gobblin.data.management.copy.prioritization.PrioritizedCopyableDataset; -import gobblin.util.request_allocation.PushDownRequestor; +import org.apache.gobblin.data.management.copy.CopyConfiguration; +import org.apache.gobblin.data.management.copy.CopyEntity; +import org.apache.gobblin.data.management.copy.CopyableDataset; +import org.apache.gobblin.data.management.copy.CopyableDatasetBase; +import org.apache.gobblin.data.management.copy.IterableCopyableDataset; +import org.apache.gobblin.data.management.copy.IterableCopyableDatasetImpl; +import org.apache.gobblin.data.management.copy.prioritization.PrioritizedCopyableDataset; +import org.apache.gobblin.util.request_allocation.PushDownRequestor; import javax.annotation.Nullable; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/partition/File.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/partition/File.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/partition/File.java index bb45b9b..b4461b8 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/partition/File.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/partition/File.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.partition; +package org.apache.gobblin.data.management.partition; 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/partition/FileSet.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/partition/FileSet.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/partition/FileSet.java index 8fd711d..e22873c 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/partition/FileSet.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/partition/FileSet.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.partition; +package org.apache.gobblin.data.management.partition; import lombok.AccessLevel; import lombok.Builder; @@ -37,11 +37,11 @@ import com.google.common.base.Preconditions; import com.google.common.collect.ImmutableList; import com.google.common.collect.Lists; -import gobblin.data.management.copy.CopyEntity; -import gobblin.data.management.copy.CopyableFile; -import gobblin.dataset.Dataset; -import gobblin.util.request_allocation.Request; -import gobblin.util.request_allocation.Requestor; +import org.apache.gobblin.data.management.copy.CopyEntity; +import org.apache.gobblin.data.management.copy.CopyableFile; +import org.apache.gobblin.dataset.Dataset; +import org.apache.gobblin.util.request_allocation.Request; +import org.apache.gobblin.util.request_allocation.Requestor; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/partition/FileSetResourceEstimator.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/partition/FileSetResourceEstimator.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/partition/FileSetResourceEstimator.java index d5693f4..8ced2b2 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/partition/FileSetResourceEstimator.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/partition/FileSetResourceEstimator.java @@ -15,15 +15,15 @@ * limitations under the License. */ -package gobblin.data.management.partition; +package org.apache.gobblin.data.management.partition; import com.typesafe.config.Config; -import gobblin.data.management.copy.CopyEntity; -import gobblin.data.management.copy.CopyResourcePool; -import gobblin.util.request_allocation.ResourceEstimator; -import gobblin.util.request_allocation.ResourcePool; -import gobblin.util.request_allocation.ResourceRequirement; +import org.apache.gobblin.data.management.copy.CopyEntity; +import org.apache.gobblin.data.management.copy.CopyResourcePool; +import org.apache.gobblin.util.request_allocation.ResourceEstimator; +import org.apache.gobblin.util.request_allocation.ResourcePool; +import org.apache.gobblin.util.request_allocation.ResourceRequirement; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/partition/StaticFileSet.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/partition/StaticFileSet.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/partition/StaticFileSet.java index 4eaa25d..da2f3bf 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/partition/StaticFileSet.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/partition/StaticFileSet.java @@ -15,14 +15,14 @@ * limitations under the License. */ -package gobblin.data.management.partition; +package org.apache.gobblin.data.management.partition; import java.io.IOException; import java.util.Collection; import java.util.List; -import gobblin.data.management.copy.CopyEntity; -import gobblin.dataset.Dataset; +import org.apache.gobblin.data.management.copy.CopyEntity; +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/policy/CombineSelectionPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/CombineSelectionPolicy.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/CombineSelectionPolicy.java index 9334caa..e5e0860 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/CombineSelectionPolicy.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/CombineSelectionPolicy.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.policy; +package org.apache.gobblin.data.management.policy; import java.io.IOException; import java.lang.reflect.InvocationTargetException; @@ -39,9 +39,9 @@ import com.google.common.collect.Sets; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.data.management.retention.policy.CombineRetentionPolicy; -import gobblin.data.management.version.DatasetVersion; -import gobblin.util.reflection.GobblinConstructorUtils; +import org.apache.gobblin.data.management.retention.policy.CombineRetentionPolicy; +import org.apache.gobblin.data.management.version.DatasetVersion; +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/policy/EmbeddedRetentionSelectionPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/EmbeddedRetentionSelectionPolicy.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/EmbeddedRetentionSelectionPolicy.java index 5a4ad2f..8eec613 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/EmbeddedRetentionSelectionPolicy.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/EmbeddedRetentionSelectionPolicy.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.policy; +package org.apache.gobblin.data.management.policy; import java.util.Collection; import java.util.List; @@ -22,8 +22,8 @@ import java.util.List; import lombok.AllArgsConstructor; import lombok.ToString; -import gobblin.data.management.retention.policy.RetentionPolicy; -import gobblin.data.management.version.FileSystemDatasetVersion; +import org.apache.gobblin.data.management.retention.policy.RetentionPolicy; +import org.apache.gobblin.data.management.version.FileSystemDatasetVersion; /** * A wrapper {@link VersionSelectionPolicy} that delegates calls to deprecated {@link RetentionPolicy} http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/NewestKSelectionPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/NewestKSelectionPolicy.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/NewestKSelectionPolicy.java index 9f4dfe3..5d25a6b 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/NewestKSelectionPolicy.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/NewestKSelectionPolicy.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.policy; +package org.apache.gobblin.data.management.policy; import java.util.Collection; import java.util.List; @@ -32,7 +32,7 @@ import com.google.common.base.Preconditions; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -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-data-management/src/main/java/org/apache/gobblin/data/management/policy/SelectAfterTimeBasedPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/SelectAfterTimeBasedPolicy.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/SelectAfterTimeBasedPolicy.java index 5d8e276..548fd54 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/SelectAfterTimeBasedPolicy.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/SelectAfterTimeBasedPolicy.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.policy; +package org.apache.gobblin.data.management.policy; import java.util.Properties; @@ -26,9 +26,9 @@ import com.google.common.base.Optional; import com.google.common.base.Preconditions; import com.typesafe.config.Config; -import gobblin.annotation.Alias; -import gobblin.data.management.version.TimestampedDatasetVersion; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.annotation.Alias; +import org.apache.gobblin.data.management.version.TimestampedDatasetVersion; +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/policy/SelectAllPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/SelectAllPolicy.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/SelectAllPolicy.java index 30ed856..255507b 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/SelectAllPolicy.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/SelectAllPolicy.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.policy; +package org.apache.gobblin.data.management.policy; import java.util.Collection; import java.util.List; @@ -23,7 +23,7 @@ import java.util.Properties; import lombok.ToString; -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/policy/SelectBeforeTimeBasedPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/SelectBeforeTimeBasedPolicy.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/SelectBeforeTimeBasedPolicy.java index d5cec66..0a21786 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/SelectBeforeTimeBasedPolicy.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/SelectBeforeTimeBasedPolicy.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.policy; +package org.apache.gobblin.data.management.policy; import java.util.Properties; @@ -26,9 +26,9 @@ import com.google.common.base.Optional; import com.google.common.base.Preconditions; import com.typesafe.config.Config; -import gobblin.annotation.Alias; -import gobblin.data.management.version.TimestampedDatasetVersion; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.annotation.Alias; +import org.apache.gobblin.data.management.version.TimestampedDatasetVersion; +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/policy/SelectBetweenTimeBasedPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/SelectBetweenTimeBasedPolicy.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/SelectBetweenTimeBasedPolicy.java index b0844d8..6cc5547 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/SelectBetweenTimeBasedPolicy.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/SelectBetweenTimeBasedPolicy.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.policy; +package org.apache.gobblin.data.management.policy; import java.util.Collection; import java.util.List; @@ -32,9 +32,9 @@ import com.google.common.collect.Collections2; import com.google.common.collect.Lists; import com.typesafe.config.Config; -import gobblin.annotation.Alias; -import gobblin.data.management.version.FileSystemDatasetVersion; -import gobblin.data.management.version.TimestampedDatasetVersion; +import org.apache.gobblin.annotation.Alias; +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/policy/SelectNothingPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/SelectNothingPolicy.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/SelectNothingPolicy.java index 3752c20..5c7b85e 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/SelectNothingPolicy.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/SelectNothingPolicy.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.policy; +package org.apache.gobblin.data.management.policy; import java.util.Collection; import java.util.List; @@ -25,7 +25,7 @@ import lombok.ToString; import com.google.common.collect.Lists; -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/policy/VersionSelectionPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/VersionSelectionPolicy.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/VersionSelectionPolicy.java index e3aaba3..811c0d4 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/VersionSelectionPolicy.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/VersionSelectionPolicy.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package gobblin.data.management.policy; +package org.apache.gobblin.data.management.policy; import java.util.Collection; import java.util.List; -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-data-management/src/main/java/org/apache/gobblin/data/management/retention/DatasetCleaner.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/DatasetCleaner.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/DatasetCleaner.java index ddf2e6a..d0a0a96 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/DatasetCleaner.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/DatasetCleaner.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.retention; +package org.apache.gobblin.data.management.retention; import java.io.Closeable; import java.io.IOException; @@ -41,21 +41,21 @@ import com.google.common.util.concurrent.Futures; import com.google.common.util.concurrent.ListenableFuture; import com.google.common.util.concurrent.ListeningExecutorService; -import gobblin.util.AzkabanTags; -import gobblin.configuration.State; -import gobblin.data.management.retention.dataset.CleanableDataset; -import gobblin.data.management.retention.profile.MultiCleanableDatasetFinder; -import gobblin.dataset.Dataset; -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.ExecutorsUtils; -import gobblin.util.RateControlledFileSystem; -import gobblin.util.executors.ScalingThreadPoolExecutor; +import org.apache.gobblin.util.AzkabanTags; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.data.management.retention.dataset.CleanableDataset; +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.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.ExecutorsUtils; +import org.apache.gobblin.util.RateControlledFileSystem; +import org.apache.gobblin.util.executors.ScalingThreadPoolExecutor; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/RetentionEvents.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/RetentionEvents.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/RetentionEvents.java index c299a3a..f72aa6b 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/RetentionEvents.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/RetentionEvents.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.data.management.retention; +package org.apache.gobblin.data.management.retention; -import gobblin.data.management.retention.dataset.CleanableDataset; +import org.apache.gobblin.data.management.retention.dataset.CleanableDataset; /** * Holds event names and constants used in events submitted by a retention job. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/action/AccessControlAction.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/action/AccessControlAction.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/action/AccessControlAction.java index 1f4f0a9..701ac30 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/action/AccessControlAction.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/action/AccessControlAction.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.retention.action; +package org.apache.gobblin.data.management.retention.action; import java.io.IOException; import java.util.List; @@ -32,11 +32,11 @@ import com.google.common.annotations.VisibleForTesting; import com.google.common.base.Optional; import com.typesafe.config.Config; -import gobblin.data.management.policy.VersionSelectionPolicy; -import gobblin.data.management.version.DatasetVersion; -import gobblin.data.management.version.FileStatusAware; -import gobblin.data.management.version.FileSystemDatasetVersion; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.data.management.policy.VersionSelectionPolicy; +import org.apache.gobblin.data.management.version.DatasetVersion; +import org.apache.gobblin.data.management.version.FileStatusAware; +import org.apache.gobblin.data.management.version.FileSystemDatasetVersion; +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/action/MultiAccessControlAction.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/action/MultiAccessControlAction.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/action/MultiAccessControlAction.java index 8b8122e..4a7e1d3 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/action/MultiAccessControlAction.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/action/MultiAccessControlAction.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.retention.action; +package org.apache.gobblin.data.management.retention.action; import java.io.IOException; import java.util.List; @@ -26,10 +26,10 @@ import com.google.common.collect.Lists; import com.typesafe.config.Config; import com.typesafe.config.ConfigRenderOptions; -import gobblin.data.management.policy.VersionSelectionPolicy; -import gobblin.data.management.retention.dataset.ConfigurableCleanableDataset; -import gobblin.data.management.version.DatasetVersion; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.data.management.policy.VersionSelectionPolicy; +import org.apache.gobblin.data.management.retention.dataset.ConfigurableCleanableDataset; +import org.apache.gobblin.data.management.version.DatasetVersion; +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/action/RetentionAction.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/action/RetentionAction.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/action/RetentionAction.java index 53cda6c..6f20c7e 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/action/RetentionAction.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/action/RetentionAction.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.retention.action; +package org.apache.gobblin.data.management.retention.action; import java.io.IOException; import java.lang.reflect.InvocationTargetException; @@ -27,16 +27,16 @@ import com.google.common.base.Preconditions; import com.google.common.collect.ImmutableList; import com.typesafe.config.Config; -import gobblin.data.management.dataset.Dataset; -import gobblin.data.management.policy.VersionSelectionPolicy; -import gobblin.data.management.retention.dataset.ConfigurableCleanableDataset; -import gobblin.data.management.retention.dataset.FsCleanableHelper; -import gobblin.data.management.version.DatasetVersion; -import gobblin.data.management.version.finder.VersionFinder; -import gobblin.dataset.DatasetsFinder; -import gobblin.util.ClassAliasResolver; -import gobblin.util.ConfigUtils; -import gobblin.util.reflection.GobblinConstructorUtils; +import org.apache.gobblin.data.management.dataset.Dataset; +import org.apache.gobblin.data.management.policy.VersionSelectionPolicy; +import org.apache.gobblin.data.management.retention.dataset.ConfigurableCleanableDataset; +import org.apache.gobblin.data.management.retention.dataset.FsCleanableHelper; +import org.apache.gobblin.data.management.version.DatasetVersion; +import org.apache.gobblin.data.management.version.finder.VersionFinder; +import org.apache.gobblin.dataset.DatasetsFinder; +import org.apache.gobblin.util.ClassAliasResolver; +import org.apache.gobblin.util.ConfigUtils; +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/dataset/CleanableDataset.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/CleanableDataset.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/CleanableDataset.java index 6a75a07..61b6d6b 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/CleanableDataset.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/CleanableDataset.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package gobblin.data.management.retention.dataset; +package org.apache.gobblin.data.management.retention.dataset; -import gobblin.dataset.Dataset; -import gobblin.dataset.FileSystemDataset; +import org.apache.gobblin.dataset.Dataset; +import org.apache.gobblin.dataset.FileSystemDataset; 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/retention/dataset/CleanableDatasetBase.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/CleanableDatasetBase.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/CleanableDatasetBase.java index 2b625ad..eb08f2b 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/CleanableDatasetBase.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/CleanableDatasetBase.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.retention.dataset; +package org.apache.gobblin.data.management.retention.dataset; import java.io.IOException; import java.util.List; @@ -27,10 +27,10 @@ import org.slf4j.Logger; import com.google.common.collect.ImmutableList; import com.typesafe.config.Config; -import gobblin.data.management.retention.policy.RetentionPolicy; -import gobblin.data.management.version.FileSystemDatasetVersion; -import gobblin.data.management.version.finder.VersionFinder; -import gobblin.dataset.FileSystemDataset; +import org.apache.gobblin.data.management.retention.policy.RetentionPolicy; +import org.apache.gobblin.data.management.version.FileSystemDatasetVersion; +import org.apache.gobblin.data.management.version.finder.VersionFinder; +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/dataset/CleanableHiveDataset.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/CleanableHiveDataset.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/CleanableHiveDataset.java index f29aceb..282a2a6 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/CleanableHiveDataset.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/CleanableHiveDataset.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.retention.dataset; +package org.apache.gobblin.data.management.retention.dataset; import java.io.IOException; import java.lang.reflect.InvocationTargetException; @@ -38,17 +38,17 @@ import com.google.common.collect.Lists; import com.typesafe.config.Config; import com.typesafe.config.ConfigRenderOptions; -import gobblin.data.management.copy.hive.HiveDataset; -import gobblin.data.management.policy.SelectBeforeTimeBasedPolicy; -import gobblin.data.management.policy.VersionSelectionPolicy; -import gobblin.data.management.retention.version.HiveDatasetVersionCleaner; -import gobblin.data.management.version.HiveDatasetVersion; -import gobblin.data.management.version.finder.AbstractHiveDatasetVersionFinder; -import gobblin.data.management.version.finder.DatePartitionHiveVersionFinder; -import gobblin.hive.HiveMetastoreClientPool; -import gobblin.util.AutoReturnableObject; -import gobblin.util.ConfigUtils; -import gobblin.util.reflection.GobblinConstructorUtils; +import org.apache.gobblin.data.management.copy.hive.HiveDataset; +import org.apache.gobblin.data.management.policy.SelectBeforeTimeBasedPolicy; +import org.apache.gobblin.data.management.policy.VersionSelectionPolicy; +import org.apache.gobblin.data.management.retention.version.HiveDatasetVersionCleaner; +import org.apache.gobblin.data.management.version.HiveDatasetVersion; +import org.apache.gobblin.data.management.version.finder.AbstractHiveDatasetVersionFinder; +import org.apache.gobblin.data.management.version.finder.DatePartitionHiveVersionFinder; +import org.apache.gobblin.hive.HiveMetastoreClientPool; +import org.apache.gobblin.util.AutoReturnableObject; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.util.reflection.GobblinConstructorUtils; /** * <p> http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/ConfigurableCleanableDataset.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/ConfigurableCleanableDataset.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/ConfigurableCleanableDataset.java index 53caf16..3a3a160 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/ConfigurableCleanableDataset.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/ConfigurableCleanableDataset.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.retention.dataset; +package org.apache.gobblin.data.management.retention.dataset; import java.io.IOException; import java.lang.reflect.InvocationTargetException; @@ -38,17 +38,17 @@ import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; import com.typesafe.config.ConfigRenderOptions; -import gobblin.data.management.policy.SelectNothingPolicy; -import gobblin.data.management.policy.VersionSelectionPolicy; -import gobblin.data.management.retention.action.MultiAccessControlAction.MultiAccessControlActionFactory; -import gobblin.data.management.retention.action.RetentionAction; -import gobblin.data.management.retention.action.RetentionAction.RetentionActionFactory; -import gobblin.data.management.retention.dataset.MultiVersionCleanableDatasetBase.VersionFinderAndPolicy.VersionFinderAndPolicyBuilder; -import gobblin.data.management.retention.policy.RetentionPolicy; -import gobblin.data.management.version.FileSystemDatasetVersion; -import gobblin.data.management.version.finder.VersionFinder; -import gobblin.util.ConfigUtils; -import gobblin.util.reflection.GobblinConstructorUtils; +import org.apache.gobblin.data.management.policy.SelectNothingPolicy; +import org.apache.gobblin.data.management.policy.VersionSelectionPolicy; +import org.apache.gobblin.data.management.retention.action.MultiAccessControlAction.MultiAccessControlActionFactory; +import org.apache.gobblin.data.management.retention.action.RetentionAction; +import org.apache.gobblin.data.management.retention.action.RetentionAction.RetentionActionFactory; +import org.apache.gobblin.data.management.retention.dataset.MultiVersionCleanableDatasetBase.VersionFinderAndPolicy.VersionFinderAndPolicyBuilder; +import org.apache.gobblin.data.management.retention.policy.RetentionPolicy; +import org.apache.gobblin.data.management.version.FileSystemDatasetVersion; +import org.apache.gobblin.data.management.version.finder.VersionFinder; +import org.apache.gobblin.util.ConfigUtils; +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/dataset/FsCleanableHelper.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/FsCleanableHelper.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/FsCleanableHelper.java index 88597c0..44a6c85 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/FsCleanableHelper.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/FsCleanableHelper.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.retention.dataset; +package org.apache.gobblin.data.management.retention.dataset; import java.io.IOException; import java.util.Arrays; @@ -31,11 +31,11 @@ import org.slf4j.Logger; import com.typesafe.config.Config; -import gobblin.data.management.trash.ProxiedTrash; -import gobblin.data.management.trash.TrashFactory; -import gobblin.data.management.version.FileSystemDatasetVersion; -import gobblin.dataset.FileSystemDataset; -import gobblin.util.PathUtils; +import org.apache.gobblin.data.management.trash.ProxiedTrash; +import org.apache.gobblin.data.management.trash.TrashFactory; +import org.apache.gobblin.data.management.version.FileSystemDatasetVersion; +import org.apache.gobblin.dataset.FileSystemDataset; +import org.apache.gobblin.util.PathUtils; /** * A helper class to delete {@link Path}s of a 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/dataset/ModificationTimeDataset.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/ModificationTimeDataset.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/ModificationTimeDataset.java index 371c6fe..39c18a6 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/ModificationTimeDataset.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/ModificationTimeDataset.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.retention.dataset; +package org.apache.gobblin.data.management.retention.dataset; import java.io.IOException; import java.util.Properties; @@ -25,11 +25,11 @@ import org.apache.hadoop.fs.Path; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import gobblin.data.management.retention.policy.RetentionPolicy; -import gobblin.data.management.retention.policy.TimeBasedRetentionPolicy; -import gobblin.data.management.version.TimestampedDatasetVersion; -import gobblin.data.management.version.finder.ModDateTimeDatasetVersionFinder; -import gobblin.data.management.version.finder.VersionFinder; +import org.apache.gobblin.data.management.retention.policy.RetentionPolicy; +import org.apache.gobblin.data.management.retention.policy.TimeBasedRetentionPolicy; +import org.apache.gobblin.data.management.version.TimestampedDatasetVersion; +import org.apache.gobblin.data.management.version.finder.ModDateTimeDatasetVersionFinder; +import org.apache.gobblin.data.management.version.finder.VersionFinder; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/MultiVersionCleanableDatasetBase.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/MultiVersionCleanableDatasetBase.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/MultiVersionCleanableDatasetBase.java index 5974323..ebd2075 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/MultiVersionCleanableDatasetBase.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/MultiVersionCleanableDatasetBase.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.retention.dataset; +package org.apache.gobblin.data.management.retention.dataset; import java.io.IOException; import java.util.Collection; @@ -37,17 +37,17 @@ import com.google.common.collect.Lists; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.data.management.policy.EmbeddedRetentionSelectionPolicy; -import gobblin.data.management.policy.SelectNothingPolicy; -import gobblin.data.management.policy.VersionSelectionPolicy; -import gobblin.data.management.retention.action.RetentionAction; -import gobblin.data.management.retention.policy.RetentionPolicy; -import gobblin.data.management.trash.ProxiedTrash; -import gobblin.data.management.version.DatasetVersion; -import gobblin.data.management.version.FileSystemDatasetVersion; -import gobblin.data.management.version.finder.VersionFinder; -import gobblin.dataset.FileSystemDataset; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.data.management.policy.EmbeddedRetentionSelectionPolicy; +import org.apache.gobblin.data.management.policy.SelectNothingPolicy; +import org.apache.gobblin.data.management.policy.VersionSelectionPolicy; +import org.apache.gobblin.data.management.retention.action.RetentionAction; +import org.apache.gobblin.data.management.retention.policy.RetentionPolicy; +import org.apache.gobblin.data.management.trash.ProxiedTrash; +import org.apache.gobblin.data.management.version.DatasetVersion; +import org.apache.gobblin.data.management.version.FileSystemDatasetVersion; +import org.apache.gobblin.data.management.version.finder.VersionFinder; +import org.apache.gobblin.dataset.FileSystemDataset; +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/dataset/SnapshotDataset.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/SnapshotDataset.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/SnapshotDataset.java index c456692..476fc79 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/SnapshotDataset.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/SnapshotDataset.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.retention.dataset; +package org.apache.gobblin.data.management.retention.dataset; import java.io.IOException; import java.util.Properties; @@ -25,12 +25,12 @@ import org.apache.hadoop.fs.Path; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import gobblin.data.management.retention.policy.NewestKRetentionPolicy; -import gobblin.data.management.retention.policy.RetentionPolicy; -import gobblin.data.management.retention.version.StringDatasetVersion; -import gobblin.data.management.retention.version.finder.VersionFinder; -import gobblin.data.management.retention.version.finder.WatermarkDatasetVersionFinder; -import gobblin.data.management.version.FileSystemDatasetVersion; +import org.apache.gobblin.data.management.retention.policy.NewestKRetentionPolicy; +import org.apache.gobblin.data.management.retention.policy.RetentionPolicy; +import org.apache.gobblin.data.management.retention.version.StringDatasetVersion; +import org.apache.gobblin.data.management.retention.version.finder.VersionFinder; +import org.apache.gobblin.data.management.retention.version.finder.WatermarkDatasetVersionFinder; +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/dataset/TrackingDataset.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/TrackingDataset.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/TrackingDataset.java index d375909..ede7193 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/TrackingDataset.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/TrackingDataset.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.retention.dataset; +package org.apache.gobblin.data.management.retention.dataset; import java.io.IOException; import java.util.Properties; @@ -25,11 +25,11 @@ import org.apache.hadoop.fs.Path; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import gobblin.data.management.retention.policy.RetentionPolicy; -import gobblin.data.management.retention.policy.TimeBasedRetentionPolicy; -import gobblin.data.management.version.TimestampedDatasetVersion; -import gobblin.data.management.retention.version.finder.DateTimeDatasetVersionFinder; -import gobblin.data.management.version.finder.VersionFinder; +import org.apache.gobblin.data.management.retention.policy.RetentionPolicy; +import org.apache.gobblin.data.management.retention.policy.TimeBasedRetentionPolicy; +import org.apache.gobblin.data.management.version.TimestampedDatasetVersion; +import org.apache.gobblin.data.management.retention.version.finder.DateTimeDatasetVersionFinder; +import org.apache.gobblin.data.management.version.finder.VersionFinder; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/finder/CleanableHiveDatasetFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/finder/CleanableHiveDatasetFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/finder/CleanableHiveDatasetFinder.java index beecd3c..3b4a42e 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/finder/CleanableHiveDatasetFinder.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/finder/CleanableHiveDatasetFinder.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.retention.dataset.finder; +package org.apache.gobblin.data.management.retention.dataset.finder; import java.io.IOException; import java.util.Properties; @@ -24,10 +24,10 @@ import org.apache.hadoop.hive.metastore.api.Table; import com.typesafe.config.Config; -import gobblin.config.client.ConfigClient; -import gobblin.data.management.copy.hive.HiveDatasetFinder; -import gobblin.data.management.retention.dataset.CleanableHiveDataset; -import gobblin.data.management.retention.dataset.ConfigurableCleanableDataset; +import org.apache.gobblin.config.client.ConfigClient; +import org.apache.gobblin.data.management.copy.hive.HiveDatasetFinder; +import org.apache.gobblin.data.management.retention.dataset.CleanableHiveDataset; +import org.apache.gobblin.data.management.retention.dataset.ConfigurableCleanableDataset; public class CleanableHiveDatasetFinder extends HiveDatasetFinder { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/finder/DatasetFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/finder/DatasetFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/finder/DatasetFinder.java index cd9a58a..1ca503b 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/finder/DatasetFinder.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/finder/DatasetFinder.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package gobblin.data.management.retention.dataset.finder; +package org.apache.gobblin.data.management.retention.dataset.finder; -import gobblin.dataset.Dataset; -import gobblin.dataset.DatasetsFinder; +import org.apache.gobblin.dataset.Dataset; +import org.apache.gobblin.dataset.DatasetsFinder; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/CombineRetentionPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/CombineRetentionPolicy.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/CombineRetentionPolicy.java index 7f1ebc2..05f4c7d 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/CombineRetentionPolicy.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/CombineRetentionPolicy.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.retention.policy; +package org.apache.gobblin.data.management.retention.policy; import java.io.IOException; import java.lang.reflect.InvocationTargetException; @@ -36,8 +36,8 @@ import com.google.common.collect.Iterables; import com.google.common.collect.Lists; import com.google.common.collect.Sets; -import gobblin.data.management.retention.DatasetCleaner; -import gobblin.data.management.version.DatasetVersion; +import org.apache.gobblin.data.management.retention.DatasetCleaner; +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/policy/DeleteAllRetentionPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/DeleteAllRetentionPolicy.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/DeleteAllRetentionPolicy.java index 77765bb..cd4bfdf 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/DeleteAllRetentionPolicy.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/DeleteAllRetentionPolicy.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package gobblin.data.management.retention.policy; +package org.apache.gobblin.data.management.retention.policy; import java.util.Collection; import java.util.List; import java.util.Properties; -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/policy/DeleteNothingRetentionPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/DeleteNothingRetentionPolicy.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/DeleteNothingRetentionPolicy.java index 1191d24..12d0be7 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/DeleteNothingRetentionPolicy.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/DeleteNothingRetentionPolicy.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.data.management.retention.policy; +package org.apache.gobblin.data.management.retention.policy; import java.util.Collection; import java.util.List; @@ -23,7 +23,7 @@ import java.util.Properties; import com.google.common.collect.Lists; import com.typesafe.config.Config; -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/policy/NewestKRetentionPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/NewestKRetentionPolicy.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/NewestKRetentionPolicy.java index 317d51d..cb3ce2b 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/NewestKRetentionPolicy.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/NewestKRetentionPolicy.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.retention.policy; +package org.apache.gobblin.data.management.retention.policy; import java.util.Collection; import java.util.List; @@ -27,8 +27,8 @@ import org.slf4j.LoggerFactory; import com.google.common.collect.Lists; import com.typesafe.config.Config; -import gobblin.data.management.retention.DatasetCleaner; -import gobblin.data.management.version.DatasetVersion; +import org.apache.gobblin.data.management.retention.DatasetCleaner; +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/policy/PredicateRetentionPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/PredicateRetentionPolicy.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/PredicateRetentionPolicy.java index d3dafce..1858606 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/PredicateRetentionPolicy.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/PredicateRetentionPolicy.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.retention.policy; +package org.apache.gobblin.data.management.retention.policy; import java.lang.reflect.InvocationTargetException; import java.util.Collection; @@ -27,7 +27,7 @@ import com.google.common.base.Predicates; import com.google.common.collect.Iterables; import com.google.common.collect.Lists; -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/policy/RawDatasetRetentionPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/RawDatasetRetentionPolicy.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/RawDatasetRetentionPolicy.java index 119fe4d..fc24f5a 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/RawDatasetRetentionPolicy.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/RawDatasetRetentionPolicy.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.retention.policy; +package org.apache.gobblin.data.management.retention.policy; import java.io.IOException; import java.util.Collection; @@ -30,9 +30,9 @@ import com.google.common.base.Predicate; import com.google.common.collect.Collections2; import com.google.common.collect.Lists; -import gobblin.annotation.Alpha; -import gobblin.data.management.version.FileSystemDatasetVersion; -import gobblin.util.FileListUtils; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.data.management.version.FileSystemDatasetVersion; +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/retention/policy/RetentionPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/RetentionPolicy.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/RetentionPolicy.java index a6a4e6b..416b112 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/RetentionPolicy.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/RetentionPolicy.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package gobblin.data.management.retention.policy; +package org.apache.gobblin.data.management.retention.policy; import java.util.Collection; import java.util.List; -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-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/TimeBasedRetentionPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/TimeBasedRetentionPolicy.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/TimeBasedRetentionPolicy.java index fb0fcf8..51c8a82 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/TimeBasedRetentionPolicy.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/TimeBasedRetentionPolicy.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.retention.policy; +package org.apache.gobblin.data.management.retention.policy; import java.util.Collection; import java.util.List; @@ -34,10 +34,10 @@ import com.google.common.collect.Collections2; import com.google.common.collect.Lists; import com.typesafe.config.Config; -import gobblin.data.management.retention.DatasetCleaner; -import gobblin.data.management.version.DatasetVersion; -import gobblin.data.management.version.TimestampedDatasetVersion; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.data.management.retention.DatasetCleaner; +import org.apache.gobblin.data.management.version.DatasetVersion; +import org.apache.gobblin.data.management.version.TimestampedDatasetVersion; +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/policy/predicates/WhitelistPredicate.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/predicates/WhitelistPredicate.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/predicates/WhitelistPredicate.java index b08f640..1d6288b 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/predicates/WhitelistPredicate.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/predicates/WhitelistPredicate.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.data.management.retention.policy.predicates; +package org.apache.gobblin.data.management.retention.policy.predicates; import java.util.Properties; import java.util.regex.Pattern; @@ -23,8 +23,8 @@ import java.util.regex.Pattern; import com.google.common.base.Preconditions; import com.google.common.base.Predicate; -import gobblin.data.management.retention.DatasetCleaner; -import gobblin.data.management.retention.version.StringDatasetVersion; +import org.apache.gobblin.data.management.retention.DatasetCleaner; +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/retention/profile/ConfigBasedCleanabledDatasetFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/ConfigBasedCleanabledDatasetFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/ConfigBasedCleanabledDatasetFinder.java index 7dcf0a1..b574c19 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/ConfigBasedCleanabledDatasetFinder.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/ConfigBasedCleanabledDatasetFinder.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 com.google.common.base.Optional; import java.io.IOException; @@ -29,11 +29,11 @@ import org.apache.hadoop.fs.Path; import com.typesafe.config.Config; -import gobblin.dataset.Dataset; -import gobblin.data.management.copy.replication.ConfigBasedDatasetsFinder; -import gobblin.data.management.retention.dataset.ConfigurableCleanableDataset; -import gobblin.config.client.ConfigClient; -import gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.dataset.Dataset; +import org.apache.gobblin.data.management.copy.replication.ConfigBasedDatasetsFinder; +import org.apache.gobblin.data.management.retention.dataset.ConfigurableCleanableDataset; +import org.apache.gobblin.config.client.ConfigClient; +import org.apache.gobblin.configuration.ConfigurationKeys; import lombok.extern.slf4j.Slf4j; 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/ConfigurableGlobDatasetFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/ConfigurableGlobDatasetFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/ConfigurableGlobDatasetFinder.java index 9b5e4a8..f781dcb 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/ConfigurableGlobDatasetFinder.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/ConfigurableGlobDatasetFinder.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; @@ -36,11 +36,11 @@ import com.google.common.collect.Lists; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.data.management.retention.DatasetCleaner; -import gobblin.dataset.Dataset; -import gobblin.dataset.DatasetsFinder; -import gobblin.util.ConfigUtils; -import gobblin.util.PathUtils; +import org.apache.gobblin.data.management.retention.DatasetCleaner; +import org.apache.gobblin.dataset.Dataset; +import org.apache.gobblin.dataset.DatasetsFinder; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.util.PathUtils; /**
