gobblin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a...@apache.org
Subject [24/77] [abbrv] incubator-gobblin git commit: Updated package names, imports and shell scripts
Date Mon, 31 Jul 2017 07:52:42 GMT
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;
 
 
 /**


Mime
View raw message