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