gobblin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a...@apache.org
Subject [47/77] [abbrv] incubator-gobblin git commit: Changed JavaDocs references from gobblin to org.apache.gobblin package
Date Mon, 31 Jul 2017 07:53:05 GMT
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 ebd2075..03e56fe 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
@@ -182,7 +182,7 @@ public abstract class MultiVersionCleanableDatasetBase<T extends FileSystemDatas
   @Deprecated
   protected final boolean deleteAsOwner;
   /**
-   * Get {@link gobblin.data.management.retention.policy.RetentionPolicy} to use.
+   * Get {@link org.apache.gobblin.data.management.retention.policy.RetentionPolicy} to use.
    */
   public abstract List<VersionFinderAndPolicy<T>> getVersionFindersAndPolicies();
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 476fc79..5755ee1 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
@@ -36,8 +36,8 @@ import org.apache.gobblin.data.management.version.FileSystemDatasetVersion;
 /**
  * {@link CleanableDatasetBase} for snapshot datasets.
  *
- * Uses a {@link gobblin.data.management.retention.version.finder.WatermarkDatasetVersionFinder} and a
- * {@link gobblin.data.management.retention.policy.NewestKRetentionPolicy}.
+ * Uses a {@link org.apache.gobblin.data.management.retention.version.finder.WatermarkDatasetVersionFinder} and a
+ * {@link org.apache.gobblin.data.management.retention.policy.NewestKRetentionPolicy}.
  */
 public class SnapshotDataset extends CleanableDatasetBase<FileSystemDatasetVersion> {
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 ede7193..379d66f 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
@@ -35,8 +35,8 @@ import org.apache.gobblin.data.management.version.finder.VersionFinder;
 /**
  * {@link CleanableDatasetBase} for tracking data.
  *
- * Uses a {@link gobblin.data.management.retention.version.finder.DateTimeDatasetVersionFinder} and a
- * {@link gobblin.data.management.retention.policy.TimeBasedRetentionPolicy}.
+ * Uses a {@link org.apache.gobblin.data.management.retention.version.finder.DateTimeDatasetVersionFinder} and a
+ * {@link org.apache.gobblin.data.management.retention.policy.TimeBasedRetentionPolicy}.
  */
 public class TrackingDataset extends CleanableDatasetBase<TimestampedDatasetVersion> {
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 05f4c7d..38c1d9c 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
@@ -41,7 +41,7 @@ import org.apache.gobblin.data.management.version.DatasetVersion;
 
 
 /**
- * Implementation of {@link gobblin.data.management.retention.policy.RetentionPolicy} that allows combining different
+ * Implementation of {@link org.apache.gobblin.data.management.retention.policy.RetentionPolicy} that allows combining different
  * policies through a union or intersect operation. It will combine the delete sets from each sub-policy using the
  * specified operation.
  *

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 fc24f5a..e536d97 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
@@ -36,7 +36,7 @@ import org.apache.gobblin.util.FileListUtils;
 
 
 /**
- * An abstract {@link RetentionPolicy} for {@link gobblin.data.management.retention.dataset.RawDataset}.
+ * An abstract {@link RetentionPolicy} for {@link org.apache.gobblin.data.management.retention.dataset.RawDataset}.
  *
  * This class embeds another {@link RetentionPolicy}. In {@link #listDeletableVersions(List)} it applies the
  * embedded {@link RetentionPolicy}'s predicate, as well as {@link #listQualifiedRawFileSystemDatasetVersions(Collection)}.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 416b112..4628d69 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
@@ -25,8 +25,8 @@ import org.apache.gobblin.data.management.version.DatasetVersion;
 
 /**
  * Retention policy around versions of a dataset. Specifies which versions of a dataset should be deleted by
- * {@link gobblin.data.management.retention.DatasetCleaner}.
- * @param <T> {@link gobblin.data.management.retention.version.DatasetVersion} accepted by this policy.
+ * {@link org.apache.gobblin.data.management.retention.DatasetCleaner}.
+ * @param <T> {@link org.apache.gobblin.data.management.retention.version.DatasetVersion} accepted by this policy.
  */
 public interface RetentionPolicy<T extends DatasetVersion> {
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 1d6288b..435e8a5 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
@@ -28,7 +28,7 @@ import org.apache.gobblin.data.management.retention.version.StringDatasetVersion
 
 
 /**
- * {@link com.google.common.base.Predicate} for {@link gobblin.data.management.retention.policy.PredicateRetentionPolicy}
+ * {@link com.google.common.base.Predicate} for {@link org.apache.gobblin.data.management.retention.policy.PredicateRetentionPolicy}
  * that passes versions matching a user supplied regular expression. (i.e. versions matching the regex will not be
  * deleted).
  */

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 f781dcb..df27f9f 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
@@ -45,7 +45,7 @@ import org.apache.gobblin.util.PathUtils;
 
 /**
  * A configurable {@link DatasetsFinder} that looks for
- * {@link gobblin.data.management.retention.dataset.CleanableDataset}s using a glob pattern.
+ * {@link org.apache.gobblin.data.management.retention.dataset.CleanableDataset}s using a glob pattern.
  */
 public abstract class ConfigurableGlobDatasetFinder<T extends Dataset> implements DatasetsFinder<T> {
 
@@ -115,9 +115,9 @@ public abstract class ConfigurableGlobDatasetFinder<T extends Dataset> implement
   }
 
   /**
-   * Finds all directories satisfying the input glob pattern, and creates a {@link gobblin.data.management.retention.dataset.CleanableDataset}
+   * Finds all directories satisfying the input glob pattern, and creates a {@link org.apache.gobblin.data.management.retention.dataset.CleanableDataset}
    * for each one using {@link #datasetAtPath}.
-   * @return List of {@link gobblin.data.management.retention.dataset.CleanableDataset}s in the file system.
+   * @return List of {@link org.apache.gobblin.data.management.retention.dataset.CleanableDataset}s in the file system.
    * @throws IOException
    */
   @Override
@@ -155,10 +155,10 @@ public abstract class ConfigurableGlobDatasetFinder<T extends Dataset> implement
   }
 
   /**
-   * Creates a {@link gobblin.data.management.retention.dataset.CleanableDataset} from a path. The default implementation
-   * creates a {@link gobblin.data.management.retention.dataset.ConfigurableCleanableDataset}.
+   * Creates a {@link org.apache.gobblin.data.management.retention.dataset.CleanableDataset} from a path. The default implementation
+   * creates a {@link org.apache.gobblin.data.management.retention.dataset.ConfigurableCleanableDataset}.
    * @param path {@link org.apache.hadoop.fs.Path} where dataset is located.
-   * @return {@link gobblin.data.management.retention.dataset.CleanableDataset} at that path.
+   * @return {@link org.apache.gobblin.data.management.retention.dataset.CleanableDataset} at that path.
    * @throws IOException
    */
   public abstract T datasetAtPath(Path path) throws IOException;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 e1a96ed..c34a90c 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
@@ -27,7 +27,7 @@ import org.apache.gobblin.data.management.retention.dataset.ModificationTimeData
 
 
 /**
- * {@link gobblin.dataset.DatasetsFinder} for {@link ModificationTimeDataset}s.
+ * {@link org.apache.gobblin.dataset.DatasetsFinder} for {@link ModificationTimeDataset}s.
  *
  * Modification time datasets will be cleaned by the modification timestamps of the datasets that match
  * 'gobblin.retention.dataset.pattern'.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 1cbc604..479799c 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
@@ -36,9 +36,9 @@ import org.apache.gobblin.util.RateControlledFileSystem;
 
 
 /**
- * A wrapper of {@link gobblin.data.management.retention.profile.ConfigurableGlobDatasetFinder} that looks for
- * {@link gobblin.data.management.retention.dataset.Dataset}s with {@link org.apache.hadoop.fs.FileSystem}s
- * {@link gobblin.data.management.retention.dataset.CleanableDataset}s with {@link org.apache.hadoop.fs.FileSystem}s
+ * A wrapper of {@link org.apache.gobblin.data.management.retention.profile.ConfigurableGlobDatasetFinder} that looks for
+ * {@link org.apache.gobblin.data.management.retention.dataset.Dataset}s with {@link org.apache.hadoop.fs.FileSystem}s
+ * {@link org.apache.gobblin.data.management.retention.dataset.CleanableDataset}s with {@link org.apache.hadoop.fs.FileSystem}s
  * proxied as the owner of each dataset.
  */
 public class ProxyableDatasetProfile extends ConfigurableGlobDatasetFinder {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 1ed92db..b8875aa 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
@@ -28,7 +28,7 @@ import org.apache.gobblin.dataset.Dataset;
 
 
 /**
- * {@link gobblin.dataset.DatasetsFinder} for snapshot datasets.
+ * {@link org.apache.gobblin.dataset.DatasetsFinder} for snapshot datasets.
  *
  * <p>
  *   Snapshot datasets are datasets where each version is a snapshot/full-dump of a dataset (e.g. a database).

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 fceca48..6033919 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
@@ -30,7 +30,7 @@ import org.apache.gobblin.data.management.retention.version.finder.DateTimeDatas
 
 
 /**
- * {@link gobblin.dataset.DatasetsFinder} for tracking datasets.
+ * {@link org.apache.gobblin.dataset.DatasetsFinder} for tracking datasets.
  *
  * <p>
  *   Tracking datasets are datasets where each data point represents a timestamped action, and the records are

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 7884c93..768e145 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
@@ -26,7 +26,7 @@ import org.apache.gobblin.data.management.version.FileSystemDatasetVersion;
 
 /**
  * @deprecated
- * Extends {@link gobblin.data.management.version.FileSystemDatasetVersion}.
+ * Extends {@link org.apache.gobblin.data.management.version.FileSystemDatasetVersion}.
  */
 @Deprecated
 public interface DatasetVersion extends FileSystemDatasetVersion {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 e36bff7..25c8668 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
@@ -29,8 +29,8 @@ import lombok.Data;
 
 /**
  * @deprecated
- * Extends {@link gobblin.data.management.version.FileStatusDatasetVersion} and implements
- * {@link gobblin.data.management.retention.version.DatasetVersion}.
+ * Extends {@link org.apache.gobblin.data.management.version.FileStatusDatasetVersion} and implements
+ * {@link org.apache.gobblin.data.management.retention.version.DatasetVersion}.
  */
 @Data
 @Deprecated

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 194c04d..1c93b59 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
@@ -24,8 +24,8 @@ import org.apache.hadoop.fs.Path;
 
 /**
  * @deprecated
- * Dataset version extends {@link gobblin.data.management.version.StringDatasetVersion} and implements
- * {@link gobblin.data.management.retention.version.DatasetVersion}.
+ * Dataset version extends {@link org.apache.gobblin.data.management.version.StringDatasetVersion} and implements
+ * {@link org.apache.gobblin.data.management.retention.version.DatasetVersion}.
  */
 @Deprecated
 public class StringDatasetVersion extends gobblin.data.management.version.StringDatasetVersion implements

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 a25cab9..7960694 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
@@ -29,8 +29,8 @@ import com.google.common.collect.Lists;
 
 /**
  * @deprecated
- * Extends {@link gobblin.data.management.version.TimestampedDatasetVersion} and implements
- * {@link gobblin.data.management.retention.version.DatasetVersion}.
+ * Extends {@link org.apache.gobblin.data.management.version.TimestampedDatasetVersion} and implements
+ * {@link org.apache.gobblin.data.management.retention.version.DatasetVersion}.
  */
 @Deprecated
 public class TimestampedDatasetVersion extends gobblin.data.management.version.TimestampedDatasetVersion implements

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 0c05215..8a78d85 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
@@ -32,7 +32,7 @@ import org.apache.gobblin.data.management.retention.version.TimestampedDatasetVe
 
 /**
  * @deprecated
- * See javadoc for {@link gobblin.data.management.version.finder.DateTimeDatasetVersionFinder}.
+ * See javadoc for {@link org.apache.gobblin.data.management.version.finder.DateTimeDatasetVersionFinder}.
  */
 @Deprecated
 public class DateTimeDatasetVersionFinder extends DatasetVersionFinder<TimestampedDatasetVersion> {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 a5e2750..2963fdb 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
@@ -30,7 +30,7 @@ import org.apache.gobblin.dataset.Dataset;
 
 /**
  * @deprecated
- * See javadoc for {@link gobblin.data.management.version.finder.FileLevelTimestampVersionFinder}.
+ * See javadoc for {@link org.apache.gobblin.data.management.version.finder.FileLevelTimestampVersionFinder}.
  */
 @Deprecated
 public class FileLevelTimestampVersionFinder implements VersionFinder<TimestampedDatasetVersion> {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 ec9d866..aded4b2 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
@@ -27,7 +27,7 @@ import org.apache.gobblin.data.management.retention.version.TimestampedDatasetVe
 
 /**
  * @deprecated
- * See javadoc for {@link gobblin.data.management.version.finder.GlobModTimeDatasetVersionFinder}.
+ * See javadoc for {@link org.apache.gobblin.data.management.version.finder.GlobModTimeDatasetVersionFinder}.
  */
 @Deprecated
 public class GlobModTimeDatasetVersionFinder extends DatasetVersionFinder<TimestampedDatasetVersion> {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 028ed66..f1e5de8 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
@@ -30,7 +30,7 @@ import org.apache.gobblin.dataset.Dataset;
 
 /**
  * @deprecated
- * See javadoc for {@link gobblin.data.management.version.finder.ModDateTimeDatasetVersionFinder}.
+ * See javadoc for {@link org.apache.gobblin.data.management.version.finder.ModDateTimeDatasetVersionFinder}.
  */
 @Deprecated
 public class ModDateTimeDatasetVersionFinder implements VersionFinder<TimestampedDatasetVersion> {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 d53ce6c..ddb5985 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
@@ -35,7 +35,7 @@ import org.apache.gobblin.dataset.FileSystemDataset;
 
 /**
  * @deprecated
- * See javadoc for {@link gobblin.data.management.version.finder.SingleVersionFinder}.
+ * See javadoc for {@link org.apache.gobblin.data.management.version.finder.SingleVersionFinder}.
  */
 @Deprecated
 public class SingleVersionFinder implements VersionFinder<FileStatusDatasetVersion> {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 10b2511..bd9ba12 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
@@ -28,7 +28,7 @@ import org.apache.hadoop.fs.Path;
 
 /**
  * @deprecated
- * See javadoc for {@link gobblin.data.management.version.finder.UnixTimestampVersionFinder}.
+ * See javadoc for {@link org.apache.gobblin.data.management.version.finder.UnixTimestampVersionFinder}.
  */
 @Deprecated
 public class UnixTimestampVersionFinder extends DatasetVersionFinder<TimestampedDatasetVersion> {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 60c6cb5..80e8c14 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
@@ -30,7 +30,7 @@ import org.apache.gobblin.data.management.retention.version.StringDatasetVersion
 
 /**
  * @deprecated
- * See javadoc for {@link gobblin.data.management.version.finder.WatermarkDatasetVersionFinder}.
+ * See javadoc for {@link org.apache.gobblin.data.management.version.finder.WatermarkDatasetVersionFinder}.
  */
 @Slf4j
 @Deprecated

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 ca8c7cf..756ddc2 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
@@ -27,7 +27,7 @@ import org.apache.gobblin.util.ProxiedFileSystemCache;
 
 
 /**
- * {@link gobblin.data.management.trash.ProxiedTrash} implementation that immediately deletes
+ * {@link org.apache.gobblin.data.management.trash.ProxiedTrash} implementation that immediately deletes
  * {@link org.apache.hadoop.fs.Path}s instead of moving them to trash.
  */
 public class ImmediateDeletionTrash extends ProxiedTrash {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 58aed6a..42244e6 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
@@ -30,8 +30,8 @@ import com.google.common.collect.Lists;
 
 
 /**
- * Mock version of {@link gobblin.data.management.trash.ProxiedTrash} for simulating deletions. Can also be used as
- * a mock for {@link gobblin.data.management.trash.Trash}.
+ * Mock version of {@link org.apache.gobblin.data.management.trash.ProxiedTrash} for simulating deletions. Can also be used as
+ * a mock for {@link org.apache.gobblin.data.management.trash.Trash}.
  */
 public class MockTrash extends ProxiedTrash {
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 cbf6423..f3fa552 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
@@ -23,7 +23,7 @@ import org.apache.hadoop.fs.FileStatus;
 
 
 /**
- * Noop implementation of {@link gobblin.data.management.trash.SnapshotCleanupPolicy}.
+ * Noop implementation of {@link org.apache.gobblin.data.management.trash.SnapshotCleanupPolicy}.
  */
 public class NoopSnapshotCleanupPolicy implements SnapshotCleanupPolicy {
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 2453c16..fc21d81 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
@@ -38,8 +38,8 @@ import org.apache.gobblin.util.ProxiedFileSystemCache;
 
 
 /**
- * An implementation of {@link gobblin.data.management.trash.Trash} that allows deleting files as different users.
- * Uses {@link gobblin.util.ProxiedFileSystemCache} to proxy as different users.
+ * An implementation of {@link org.apache.gobblin.data.management.trash.Trash} that allows deleting files as different users.
+ * Uses {@link org.apache.gobblin.util.ProxiedFileSystemCache} to proxy as different users.
  */
 public class ProxiedTrash extends Trash implements GobblinProxiedTrash {
 
@@ -137,9 +137,9 @@ public class ProxiedTrash extends Trash implements GobblinProxiedTrash {
   }
 
   /**
-   * Get {@link gobblin.data.management.trash.Trash} instance for the specified user.
-   * @param user user for whom {@link gobblin.data.management.trash.Trash} should be generated.
-   * @return {@link gobblin.data.management.trash.Trash} as generated by proxied user.
+   * Get {@link org.apache.gobblin.data.management.trash.Trash} instance for the specified user.
+   * @param user user for whom {@link org.apache.gobblin.data.management.trash.Trash} should be generated.
+   * @return {@link org.apache.gobblin.data.management.trash.Trash} as generated by proxied user.
    * @throws IOException
    */
   protected Trash getUserTrash(final String user) throws IOException {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 a84317e..c91c3ec 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
@@ -20,7 +20,7 @@ package org.apache.gobblin.data.management.trash;
 import org.apache.hadoop.fs.FileStatus;
 
 /**
- * Policy for determining whether a {@link gobblin.data.management.trash.Trash} snapshot should be deleted.
+ * Policy for determining whether a {@link org.apache.gobblin.data.management.trash.Trash} snapshot should be deleted.
  */
 public interface SnapshotCleanupPolicy {
   /**
@@ -31,7 +31,7 @@ public interface SnapshotCleanupPolicy {
    * </p>
    *
    * @param snapshot {@link org.apache.hadoop.fs.FileStatus} of candidate snapshot for deletion.
-   * @param trash {@link gobblin.data.management.trash.Trash} object that called this method.
+   * @param trash {@link org.apache.gobblin.data.management.trash.Trash} object that called this method.
    * @return true if the snapshot should be deleted permanently.
    */
   boolean shouldDeleteSnapshot(FileStatus snapshot, Trash trash);

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 864c147..47bcd84 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
@@ -49,8 +49,8 @@ public class TestTrash extends MockTrash {
   private static final String DELAY_TICKS_KEY = "gobblin.trash.test.delays.ticks";
 
   /**
-   * Creates {@link java.util.Properties} that will generate a {@link gobblin.data.management.trash.TestTrash} when
-   * using {@link gobblin.data.management.trash.TrashFactory}.
+   * Creates {@link java.util.Properties} that will generate a {@link org.apache.gobblin.data.management.trash.TestTrash} when
+   * using {@link org.apache.gobblin.data.management.trash.TrashFactory}.
    */
   public static Properties propertiesForTestTrash() {
     Properties properties = new Properties();

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 caf95d0..5207839 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
@@ -137,7 +137,7 @@ public class Trash implements GobblinTrash {
   private final SnapshotCleanupPolicy snapshotCleanupPolicy;
 
   /**
-   * @deprecated Use {@link gobblin.data.management.trash.TrashFactory}.
+   * @deprecated Use {@link org.apache.gobblin.data.management.trash.TrashFactory}.
    */
   @Deprecated
   public Trash(FileSystem fs) throws IOException {
@@ -145,7 +145,7 @@ public class Trash implements GobblinTrash {
   }
 
   /**
-   * @deprecated Use {@link gobblin.data.management.trash.TrashFactory}.
+   * @deprecated Use {@link org.apache.gobblin.data.management.trash.TrashFactory}.
    */
   @Deprecated
   public Trash(FileSystem fs, Properties props) throws IOException {
@@ -237,11 +237,11 @@ public class Trash implements GobblinTrash {
   }
 
   /**
-   * For each existing trash snapshot, uses a {@link gobblin.data.management.trash.SnapshotCleanupPolicy} to determine whether
+   * For each existing trash snapshot, uses a {@link org.apache.gobblin.data.management.trash.SnapshotCleanupPolicy} to determine whether
    * the snapshot should be deleted. If so, delete it permanently.
    *
    * <p>
-   *   Each existing snapshot will be passed to {@link gobblin.data.management.trash.SnapshotCleanupPolicy#shouldDeleteSnapshot}
+   *   Each existing snapshot will be passed to {@link org.apache.gobblin.data.management.trash.SnapshotCleanupPolicy#shouldDeleteSnapshot}
    *   from oldest to newest, and will be deleted if the method returns true.
    * </p>
    *

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 79aa677..6af0970 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
@@ -27,11 +27,11 @@ import org.slf4j.LoggerFactory;
 
 
 /**
- * Factory for creating {@link gobblin.data.management.trash.Trash} instance. Will automatically use
- * {@link gobblin.data.management.trash.TestTrash} if {@link #TRASH_TEST} is true,
- * {@link gobblin.data.management.trash.MockTrash} if {@link #SIMULATE} is true,
- * and {@link gobblin.data.management.trash.ImmediateDeletionTrash} if {@link #SKIP_TRASH} is true.
- * Otherwise, it will use {@link gobblin.data.management.trash.ProxiedTrash} or {@link gobblin.data.management.trash.Trash}.
+ * Factory for creating {@link org.apache.gobblin.data.management.trash.Trash} instance. Will automatically use
+ * {@link org.apache.gobblin.data.management.trash.TestTrash} if {@link #TRASH_TEST} is true,
+ * {@link org.apache.gobblin.data.management.trash.MockTrash} if {@link #SIMULATE} is true,
+ * and {@link org.apache.gobblin.data.management.trash.ImmediateDeletionTrash} if {@link #SKIP_TRASH} is true.
+ * Otherwise, it will use {@link org.apache.gobblin.data.management.trash.ProxiedTrash} or {@link org.apache.gobblin.data.management.trash.Trash}.
  */
 public class TrashFactory {
 
@@ -50,11 +50,11 @@ public class TrashFactory {
   }
 
   /**
-   * Creates a {@link gobblin.data.management.trash.Trash} instance.
+   * Creates a {@link org.apache.gobblin.data.management.trash.Trash} instance.
    * @param fs {@link org.apache.hadoop.fs.FileSystem} where trash is located.
    * @param props {@link java.util.Properties} used to generate trash.
    * @param user $USER tokens in the trash path will be replaced by this string.
-   * @return instance of {@link gobblin.data.management.trash.Trash}.
+   * @return instance of {@link org.apache.gobblin.data.management.trash.Trash}.
    * @throws IOException
    */
   public static Trash createTrash(FileSystem fs, Properties props, String user)
@@ -83,11 +83,11 @@ public class TrashFactory {
   }
 
   /**
-   * Creates a {@link gobblin.data.management.trash.ProxiedTrash} instance.
+   * Creates a {@link org.apache.gobblin.data.management.trash.ProxiedTrash} instance.
    * @param fs {@link org.apache.hadoop.fs.FileSystem} where trash is located.
    * @param props {@link java.util.Properties} used to generate trash.
    * @param user $USER tokens in the trash path will be replaced by this string.
-   * @return instance of {@link gobblin.data.management.trash.ProxiedTrash}.
+   * @return instance of {@link org.apache.gobblin.data.management.trash.ProxiedTrash}.
    * @throws IOException
    */
   public static ProxiedTrash createProxiedTrash(FileSystem fs, Properties props, String user)

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 fac432d..2b25d5a 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
@@ -28,7 +28,7 @@ import lombok.Data;
 
 
 /**
- * Implementation of {@link gobblin.data.management.version.DatasetVersion} that uses a single path per
+ * Implementation of {@link org.apache.gobblin.data.management.version.DatasetVersion} that uses a single path per
  * version and stores the {@link org.apache.hadoop.fs.FileStatus} of that path.
  */
 @Data

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 33719af..cfa71d5 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
@@ -29,7 +29,7 @@ import lombok.Getter;
 
 
 /**
- * {@link gobblin.data.management.version.DatasetVersion} based on a timestamp.
+ * {@link org.apache.gobblin.data.management.version.DatasetVersion} based on a timestamp.
  */
 @Getter
 public class TimestampedDatasetVersion implements FileSystemDatasetVersion {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 12fcf9f..a3b3641 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
@@ -43,7 +43,7 @@ import org.apache.gobblin.util.PathUtils;
  * Provides a callback {@link AbstractDatasetVersionFinder#getDatasetVersion(Path, FileStatus)} which subclasses need to
  * implement.
  *
- * @param <T> Type of {@link gobblin.data.management.version.FileSystemDatasetVersion} expected from this class.
+ * @param <T> Type of {@link org.apache.gobblin.data.management.version.FileSystemDatasetVersion} expected from this class.
  */
 public abstract class AbstractDatasetVersionFinder<T extends FileSystemDatasetVersion> implements VersionFinder<T> {
 
@@ -60,10 +60,10 @@ public abstract class AbstractDatasetVersionFinder<T extends FileSystemDatasetVe
   /**
    * Find dataset versions in the input {@link org.apache.hadoop.fs.Path}. Dataset versions are subdirectories of the
    * input {@link org.apache.hadoop.fs.Path} representing a single manageable unit in the dataset.
-   * See {@link gobblin.data.management.retention.DatasetCleaner} for more information.
+   * See {@link org.apache.gobblin.data.management.retention.DatasetCleaner} for more information.
    *
    * @param dataset {@link org.apache.hadoop.fs.Path} to directory containing all versions of a dataset.
-   * @return Map of {@link gobblin.data.management.version.DatasetVersion} and {@link org.apache.hadoop.fs.FileStatus}
+   * @return Map of {@link org.apache.gobblin.data.management.version.DatasetVersion} and {@link org.apache.hadoop.fs.FileStatus}
    *        for each dataset version found.
    * @throws IOException
    */
@@ -100,11 +100,11 @@ public abstract class AbstractDatasetVersionFinder<T extends FileSystemDatasetVe
   public abstract Path globVersionPattern();
 
   /**
-   * Create a {@link gobblin.data.management.version.DatasetVersion} with <code>versionFileStatus</code> and a path
+   * Create a {@link org.apache.gobblin.data.management.version.DatasetVersion} with <code>versionFileStatus</code> and a path
    * relative to the dataset.
    * @param pathRelativeToDatasetRoot {@link org.apache.hadoop.fs.Path} of dataset version relative to dataset root.
    * @param versionFileStatus {@link FileStatus} of the dataset version.
-   * @return {@link gobblin.data.management.version.DatasetVersion} for that {@link FileStatus}.
+   * @return {@link org.apache.gobblin.data.management.version.DatasetVersion} for that {@link FileStatus}.
    */
   public abstract T getDatasetVersion(Path pathRelativeToDatasetRoot, FileStatus versionFileStatus);
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 ba38584..765d83a 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
@@ -37,7 +37,7 @@ import org.apache.gobblin.dataset.FileSystemDataset;
  * Use {@link AbstractDatasetVersionFinder#getDatasetVersion(Path, FileStatus)} if you need a callback with {@link FileStatus}
  * of the version.
  *
- * @param <T> Type of {@link gobblin.data.management.version.FileSystemDatasetVersion} expected from this class.
+ * @param <T> Type of {@link org.apache.gobblin.data.management.version.FileSystemDatasetVersion} expected from this class.
  */
 public abstract class DatasetVersionFinder<T extends FileSystemDatasetVersion> extends AbstractDatasetVersionFinder<T>
     implements VersionFinder<T> {
@@ -56,10 +56,10 @@ public abstract class DatasetVersionFinder<T extends FileSystemDatasetVersion> e
   }
 
   /**
-   * Parse {@link gobblin.data.management.version.DatasetVersion} from the path of a dataset version.
+   * Parse {@link org.apache.gobblin.data.management.version.DatasetVersion} from the path of a dataset version.
    * @param pathRelativeToDatasetRoot {@link org.apache.hadoop.fs.Path} of dataset version relative to dataset root.
    * @param fullPath full {@link org.apache.hadoop.fs.Path} of the dataset version.
-   * @return {@link gobblin.data.management.version.DatasetVersion} for that path.
+   * @return {@link org.apache.gobblin.data.management.version.DatasetVersion} for that path.
    */
   public abstract T getDatasetVersion(Path pathRelativeToDatasetRoot, Path fullPath);
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 7a2fc92..73acfe5 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
@@ -40,7 +40,7 @@ import org.apache.gobblin.data.management.version.TimestampedDatasetVersion;
 
 
 /**
- * {@link gobblin.data.management.version.finder.DatasetVersionFinder} for datasets based on path timestamps.
+ * {@link org.apache.gobblin.data.management.version.finder.DatasetVersionFinder} for datasets based on path timestamps.
  * Uses a datetime pattern to find dataset versions from the dataset path
  * and parse the {@link org.joda.time.DateTime} representing the version.
  */

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/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 f688813..4641c0e 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
@@ -40,10 +40,10 @@ import org.apache.gobblin.util.FileListUtils;
 
 
 /**
- * {@link gobblin.data.management.version.finder.VersionFinder} that uses the most nested file,
+ * {@link org.apache.gobblin.data.management.version.finder.VersionFinder} that uses the most nested file,
  * or directory if no file exists, level modifiedTimestamp under the datasetRoot path to find
- * {@link gobblin.data.management.version.FileSystemDatasetVersion}s, and represents each version as
- * {@link gobblin.data.management.version.TimestampedDatasetVersion} using the file level path
+ * {@link org.apache.gobblin.data.management.version.FileSystemDatasetVersion}s, and represents each version as
+ * {@link org.apache.gobblin.data.management.version.TimestampedDatasetVersion} using the file level path
  * and modifiedTimestamp.
  */
 public class FileLevelTimestampVersionFinder implements VersionFinder<TimestampedDatasetVersion> {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/converter/HiveAvroToOrcConverterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/converter/HiveAvroToOrcConverterTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/converter/HiveAvroToOrcConverterTest.java
index 6732b48..7e38841 100644
--- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/converter/HiveAvroToOrcConverterTest.java
+++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/conversion/hive/converter/HiveAvroToOrcConverterTest.java
@@ -189,7 +189,7 @@ public class HiveAvroToOrcConverterTest {
 
   @Test
   /***
-   * More comprehensive tests for WhiteBlackList are in: {@link gobblin.data.management.copy.hive.WhitelistBlacklistTest}
+   * More comprehensive tests for WhiteBlackList are in: {@link org.apache.gobblin.data.management.copy.hive.WhitelistBlacklistTest}
    */
   public void hiveViewRegistrationWhiteBlackListTest() throws Exception {
     WorkUnitState wus = ConversionHiveTestUtils.createWus("dbName", "tableName", 0);

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-docs/metrics/Implementing-New-Reporters.md
----------------------------------------------------------------------
diff --git a/gobblin-docs/metrics/Implementing-New-Reporters.md b/gobblin-docs/metrics/Implementing-New-Reporters.md
index 22a2e5b..42be354 100644
--- a/gobblin-docs/metrics/Implementing-New-Reporters.md
+++ b/gobblin-docs/metrics/Implementing-New-Reporters.md
@@ -39,7 +39,7 @@ class MyReporter extends EventReporter {
      * Returns a new {@link MyReporter.Builder} for {@link MyReporter}.
      * Will automatically add all Context tags to the reporter.
      *
-     * @param context the {@link gobblin.metrics.MetricContext} to report
+     * @param context the {@link org.apache.gobblin.metrics.MetricContext} to report
      * @return MyReporter builder
      */
     public static BuilderImpl forContext(MetricContext context) {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-example/src/main/java/org/apache/gobblin/example/simplejson/SimpleJsonSource.java
----------------------------------------------------------------------
diff --git a/gobblin-example/src/main/java/org/apache/gobblin/example/simplejson/SimpleJsonSource.java b/gobblin-example/src/main/java/org/apache/gobblin/example/simplejson/SimpleJsonSource.java
index bb8c495..66ab49c 100644
--- a/gobblin-example/src/main/java/org/apache/gobblin/example/simplejson/SimpleJsonSource.java
+++ b/gobblin-example/src/main/java/org/apache/gobblin/example/simplejson/SimpleJsonSource.java
@@ -36,7 +36,7 @@ import org.apache.gobblin.source.workunit.WorkUnit;
  * An implementation of {@link Source} for the simple JSON example.
  *
  * <p>
- *   This source creates one {@link gobblin.source.workunit.WorkUnit}
+ *   This source creates one {@link org.apache.gobblin.source.workunit.WorkUnit}
  *   for each file to pull and uses the {@link SimpleJsonExtractor} to pull the data.
  * </p>
  *

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/WikipediaConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/WikipediaConverter.java b/gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/WikipediaConverter.java
index 9ba71b7..6639bd1 100644
--- a/gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/WikipediaConverter.java
+++ b/gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/WikipediaConverter.java
@@ -34,7 +34,7 @@ import org.apache.gobblin.converter.ToAvroConverterBase;
 
 
 /**
- * An implementation of {@link gobblin.converter.Converter} for the Wikipedia example.
+ * An implementation of {@link org.apache.gobblin.converter.Converter} for the Wikipedia example.
  *
  *<p>
  *   This converter converts the input string schema into an Avro {@link org.apache.avro.Schema}

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/WikipediaSource.java
----------------------------------------------------------------------
diff --git a/gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/WikipediaSource.java b/gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/WikipediaSource.java
index 8e41796..a122035 100644
--- a/gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/WikipediaSource.java
+++ b/gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/WikipediaSource.java
@@ -47,7 +47,7 @@ import org.apache.gobblin.source.workunit.Extract.TableType;
  * An implementation of {@link Source} for the Wikipedia example.
  *
  * <p>
- *   This source creates a {@link gobblin.source.workunit.WorkUnit}, and uses
+ *   This source creates a {@link org.apache.gobblin.source.workunit.WorkUnit}, and uses
  *   {@link WikipediaExtractor} to pull the data from Wikipedia.
  * </p>
  *

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HivePartition.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HivePartition.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HivePartition.java
index 11bdbc5..b6ba9fd 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HivePartition.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HivePartition.java
@@ -30,11 +30,11 @@ import lombok.Getter;
  * A class that represents a Hive partition.
  *
  * <p>
- *   This class is used in {@link gobblin.hive.spec.HiveSpec} instead of Hive's
+ *   This class is used in {@link org.apache.gobblin.hive.spec.HiveSpec} instead of Hive's
  *   {@link org.apache.hadoop.hive.metastore.api.Partition} class to minimize the dependency on the hive-metastore API
  *   (since it is unstable and may go through backward incompatible changes). {@link HivePartition} and Hive's
  *   {@link org.apache.hadoop.hive.metastore.api.Partition} can be converted to each other using
- *   {@link gobblin.hive.metastore.HiveMetaStoreUtils}.
+ *   {@link org.apache.gobblin.hive.metastore.HiveMetaStoreUtils}.
  * </p>
  *
  * @author Ziyang Liu

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegistrationUnit.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegistrationUnit.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegistrationUnit.java
index 4e82dc6..8995a4b 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegistrationUnit.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegistrationUnit.java
@@ -161,7 +161,7 @@ public class HiveRegistrationUnit {
    * Set a table/partition parameter.
    *
    * <p>
-   *   When using {@link gobblin.hive.metastore.HiveMetaStoreBasedRegister}, since it internally use
+   *   When using {@link org.apache.gobblin.hive.metastore.HiveMetaStoreBasedRegister}, since it internally use
    *   {@link org.apache.hadoop.hive.metastore.api.Table} and {@link org.apache.hadoop.hive.metastore.api.Partition}
    *   which distinguishes between table/partition parameters, storage descriptor parameters, and serde parameters,
    *   one may need to distinguish them when constructing a {@link HiveRegistrationUnit} by using
@@ -179,7 +179,7 @@ public class HiveRegistrationUnit {
    * Set a storage parameter for a table/partition.
    *
    * <p>
-   *   When using {@link gobblin.hive.metastore.HiveMetaStoreBasedRegister}, since it internally use
+   *   When using {@link org.apache.gobblin.hive.metastore.HiveMetaStoreBasedRegister}, since it internally use
    *   {@link org.apache.hadoop.hive.metastore.api.Table} and {@link org.apache.hadoop.hive.metastore.api.Partition}
    *   which distinguishes between table/partition parameters, storage descriptor parameters, and serde parameters,
    *   one may need to distinguish them when constructing a {@link HiveRegistrationUnit} by using
@@ -197,7 +197,7 @@ public class HiveRegistrationUnit {
    * Set a serde parameter for a table/partition.
    *
    * <p>
-   *   When using {@link gobblin.hive.metastore.HiveMetaStoreBasedRegister}, since it internally use
+   *   When using {@link org.apache.gobblin.hive.metastore.HiveMetaStoreBasedRegister}, since it internally use
    *   {@link org.apache.hadoop.hive.metastore.api.Table} and {@link org.apache.hadoop.hive.metastore.api.Partition}
    *   which distinguishes between table/partition parameters, storage descriptor parameters, and serde parameters,
    *   one may need to distinguish them when constructing a {@link HiveRegistrationUnit} by using
@@ -215,7 +215,7 @@ public class HiveRegistrationUnit {
    * Set table/partition parameters.
    *
    * <p>
-   *   When using {@link gobblin.hive.metastore.HiveMetaStoreBasedRegister}, since it internally use
+   *   When using {@link org.apache.gobblin.hive.metastore.HiveMetaStoreBasedRegister}, since it internally use
    *   {@link org.apache.hadoop.hive.metastore.api.Table} and {@link org.apache.hadoop.hive.metastore.api.Partition}
    *   which distinguishes between table/partition parameters, storage descriptor parameters, and serde parameters,
    *   one may need to distinguish them when constructing a {@link HiveRegistrationUnit} by using
@@ -234,7 +234,7 @@ public class HiveRegistrationUnit {
    * Set storage parameters for a table/partition.
    *
    * <p>
-   *   When using {@link gobblin.hive.metastore.HiveMetaStoreBasedRegister}, since it internally use
+   *   When using {@link org.apache.gobblin.hive.metastore.HiveMetaStoreBasedRegister}, since it internally use
    *   {@link org.apache.hadoop.hive.metastore.api.Table} and {@link org.apache.hadoop.hive.metastore.api.Partition}
    *   which distinguishes between table/partition parameters, storage descriptor parameters, and serde parameters,
    *   one may need to distinguish them when constructing a {@link HiveRegistrationUnit} by using
@@ -253,7 +253,7 @@ public class HiveRegistrationUnit {
    * Set serde parameters for a table/partition.
    *
    * <p>
-   *   When using {@link gobblin.hive.metastore.HiveMetaStoreBasedRegister}, since it internally use
+   *   When using {@link org.apache.gobblin.hive.metastore.HiveMetaStoreBasedRegister}, since it internally use
    *   {@link org.apache.hadoop.hive.metastore.api.Table} and {@link org.apache.hadoop.hive.metastore.api.Partition}
    *   which distinguishes between table/partition parameters, storage descriptor parameters, and serde parameters,
    *   one may need to distinguish them when constructing a {@link HiveRegistrationUnit} by using

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveTable.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveTable.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveTable.java
index 9029ebd..6ba2a91 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveTable.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveTable.java
@@ -34,11 +34,11 @@ import lombok.ToString;
  * A class that represents a Hive table.
  *
  * <p>
- *   This class is used in {@link gobblin.hive.spec.HiveSpec} instead of Hive's
+ *   This class is used in {@link org.apache.gobblin.hive.spec.HiveSpec} instead of Hive's
  *   {@link org.apache.hadoop.hive.metastore.api.Table} class to minimize the dependency on the hive-metastore API
  *   (since it is unstable and may go through backward incompatible changes). {@link HiveTable} and Hive's
  *   {@link org.apache.hadoop.hive.metastore.api.Table} can be converted to each other using
- *   {@link gobblin.hive.metastore.HiveMetaStoreUtils}.
+ *   {@link org.apache.gobblin.hive.metastore.HiveMetaStoreUtils}.
  * </p>
  *
  * @author Ziyang Liu

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/policy/HiveRegistrationPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/policy/HiveRegistrationPolicy.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/policy/HiveRegistrationPolicy.java
index cca4da0..0248c42 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/policy/HiveRegistrationPolicy.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/policy/HiveRegistrationPolicy.java
@@ -35,7 +35,7 @@ import org.apache.gobblin.hive.spec.HiveSpec;
 public interface HiveRegistrationPolicy {
 
   /**
-   * Get a collection of {@link HiveSpec}s for a {@link Path}, which can be used by {@link gobblin.hive.HiveRegister}
+   * Get a collection of {@link HiveSpec}s for a {@link Path}, which can be used by {@link org.apache.gobblin.hive.HiveRegister}
    * to register the given {@link Path}.
    */
   public Collection<HiveSpec> getHiveSpecs(Path path) throws IOException;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/policy/HiveSnapshotRegistrationPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/policy/HiveSnapshotRegistrationPolicy.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/policy/HiveSnapshotRegistrationPolicy.java
index fe02df5..5a051d2 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/policy/HiveSnapshotRegistrationPolicy.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/policy/HiveSnapshotRegistrationPolicy.java
@@ -41,7 +41,7 @@ import org.apache.gobblin.hive.spec.SimpleHiveSpec;
 
 
 /**
- * A {@link gobblin.hive.policy.HiveRegistrationPolicy} for registering snapshots.
+ * A {@link org.apache.gobblin.hive.policy.HiveRegistrationPolicy} for registering snapshots.
  *
  * @author Ziyang Liu
  */

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/JobHistoryDataSourceProvider.java
----------------------------------------------------------------------
diff --git a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/JobHistoryDataSourceProvider.java b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/JobHistoryDataSourceProvider.java
index 13a398f..dba8488 100644
--- a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/JobHistoryDataSourceProvider.java
+++ b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/JobHistoryDataSourceProvider.java
@@ -27,7 +27,7 @@ import org.apache.gobblin.password.PasswordManager;
 
 
 /**
- * This class extends {@link gobblin.util.jdbc.DataSourceProvider} with its own property keys.
+ * This class extends {@link org.apache.gobblin.util.jdbc.DataSourceProvider} with its own property keys.
  */
 public class JobHistoryDataSourceProvider extends gobblin.util.jdbc.DataSourceProvider {
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/util/StateStoreCleaner.java
----------------------------------------------------------------------
diff --git a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/util/StateStoreCleaner.java b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/util/StateStoreCleaner.java
index 5e125a5..c1c3a0b 100644
--- a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/util/StateStoreCleaner.java
+++ b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/util/StateStoreCleaner.java
@@ -50,7 +50,7 @@ import org.apache.gobblin.util.ExecutorsUtils;
 
 
 /**
- * A utility class for cleaning up old state store files created by {@link gobblin.metastore.FsStateStore}
+ * A utility class for cleaning up old state store files created by {@link org.apache.gobblin.metastore.FsStateStore}
  * based on a configured retention.
  * @deprecated Please use Gobblin-retention instead: http://gobblin.readthedocs.io/en/latest/data-management/Gobblin-Retention/.
  *

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareHistogram.java
----------------------------------------------------------------------
diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareHistogram.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareHistogram.java
index 94b3615..680cb3b 100644
--- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareHistogram.java
+++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareHistogram.java
@@ -26,7 +26,7 @@ import org.apache.gobblin.metrics.metric.InnerMetric;
 
 
 /**
- * A type of {@link com.codahale.metrics.Histogram} that are aware of their {@link gobblin.metrics.MetricContext}
+ * A type of {@link com.codahale.metrics.Histogram} that are aware of their {@link org.apache.gobblin.metrics.MetricContext}
  * and can have associated {@link Tag}s.
  *
  * <p>

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareMeter.java
----------------------------------------------------------------------
diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareMeter.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareMeter.java
index 13de0b6..cec0bc2 100644
--- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareMeter.java
+++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareMeter.java
@@ -25,7 +25,7 @@ import lombok.experimental.Delegate;
 
 
 /**
- * A type of {@link com.codahale.metrics.Meter}s that are aware of their {@link gobblin.metrics.MetricContext}
+ * A type of {@link com.codahale.metrics.Meter}s that are aware of their {@link org.apache.gobblin.metrics.MetricContext}
  * and can have associated {@link Tag}s.
  *
  * <p>

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareTimer.java
----------------------------------------------------------------------
diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareTimer.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareTimer.java
index 25c81dd..33d68ed 100644
--- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareTimer.java
+++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/ContextAwareTimer.java
@@ -25,7 +25,7 @@ import lombok.experimental.Delegate;
 
 
 /**
- * A type of {@link com.codahale.metrics.Timer}s that are aware of their {@link gobblin.metrics.MetricContext}
+ * A type of {@link com.codahale.metrics.Timer}s that are aware of their {@link org.apache.gobblin.metrics.MetricContext}
  * and can have associated {@link Tag}s.
  *
  * <p>

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerMetricContext.java
----------------------------------------------------------------------
diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerMetricContext.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerMetricContext.java
index ac7e7e3..70502ec 100644
--- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerMetricContext.java
+++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerMetricContext.java
@@ -144,9 +144,9 @@ public class InnerMetricContext extends MetricRegistry implements ReportableCont
   }
 
   /**
-   * Get a view of the child {@link gobblin.metrics.MetricContext}s as a {@link com.google.common.collect.ImmutableMap}.
+   * Get a view of the child {@link org.apache.gobblin.metrics.MetricContext}s as a {@link com.google.common.collect.ImmutableMap}.
    * @return {@link com.google.common.collect.ImmutableMap} of
-   *      child {@link gobblin.metrics.MetricContext}s keyed by their names.
+   *      child {@link org.apache.gobblin.metrics.MetricContext}s keyed by their names.
    */
   @Override
   public Map<String, MetricContext> getChildContextsAsMap() {
@@ -274,7 +274,7 @@ public class InnerMetricContext extends MetricRegistry implements ReportableCont
   }
 
   /**
-   * Register a {@link gobblin.metrics.ContextAwareMetric} under its own name.
+   * Register a {@link org.apache.gobblin.metrics.ContextAwareMetric} under its own name.
    */
   public <T extends ContextAwareMetric> T register(T metric) throws IllegalArgumentException {
     return register(metric.getName(), metric);

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/MetricContext.java
----------------------------------------------------------------------
diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/MetricContext.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/MetricContext.java
index 7552876..e3dd939 100644
--- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/MetricContext.java
+++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/MetricContext.java
@@ -162,9 +162,9 @@ public class MetricContext extends MetricRegistry implements ReportableContext,
   }
 
   /**
-   * Get a view of the child {@link gobblin.metrics.MetricContext}s as a {@link com.google.common.collect.ImmutableMap}.
+   * Get a view of the child {@link org.apache.gobblin.metrics.MetricContext}s as a {@link com.google.common.collect.ImmutableMap}.
    * @return {@link com.google.common.collect.ImmutableMap} of
-   *      child {@link gobblin.metrics.MetricContext}s keyed by their names.
+   *      child {@link org.apache.gobblin.metrics.MetricContext}s keyed by their names.
    */
   public Map<String, MetricContext> getChildContextsAsMap() {
     return this.innerMetricContext.getChildContextsAsMap();
@@ -184,8 +184,8 @@ public class MetricContext extends MetricRegistry implements ReportableContext,
   }
 
   /**
-   * Submit {@link gobblin.metrics.GobblinTrackingEvent} to all notification listeners attached to this or any
-   * ancestor {@link gobblin.metrics.MetricContext}s. The argument for this method is mutated by the method, so it
+   * Submit {@link org.apache.gobblin.metrics.GobblinTrackingEvent} to all notification listeners attached to this or any
+   * ancestor {@link org.apache.gobblin.metrics.MetricContext}s. The argument for this method is mutated by the method, so it
    * should not be reused by the caller.
    *
    * @param nonReusableEvent {@link GobblinTrackingEvent} to submit. This object will be mutated by the method,
@@ -405,7 +405,7 @@ public class MetricContext extends MetricRegistry implements ReportableContext,
   }
 
   /**
-   * Register a {@link gobblin.metrics.ContextAwareMetric} under its own name.
+   * Register a {@link org.apache.gobblin.metrics.ContextAwareMetric} under its own name.
    */
   public <T extends ContextAwareMetric> T register(T metric) throws IllegalArgumentException {
     return register(metric.getName(), metric);
@@ -563,9 +563,9 @@ public class MetricContext extends MetricRegistry implements ReportableContext,
   }
 
   /**
-   * Add a target for {@link gobblin.metrics.notification.Notification}s.
+   * Add a target for {@link org.apache.gobblin.metrics.notification.Notification}s.
    * @param target A {@link com.google.common.base.Function} that will be run every time
-   *               there is a new {@link gobblin.metrics.notification.Notification} in this context.
+   *               there is a new {@link org.apache.gobblin.metrics.notification.Notification} in this context.
    * @return a key for this notification target. Can be used to remove the notification target later.
    */
   public UUID addNotificationTarget(Function<Notification, Void> target) {
@@ -590,7 +590,7 @@ public class MetricContext extends MetricRegistry implements ReportableContext,
 
   /**
    * Send a notification to all targets of this context and to the parent of this context.
-   * @param notification {@link gobblin.metrics.notification.Notification} to send.
+   * @param notification {@link org.apache.gobblin.metrics.notification.Notification} to send.
    */
   public void sendNotification(final Notification notification) {
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/MetricNames.java
----------------------------------------------------------------------
diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/MetricNames.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/MetricNames.java
index f2c58d3..2187dd8 100644
--- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/MetricNames.java
+++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/MetricNames.java
@@ -67,43 +67,43 @@ public class MetricNames {
   }
 
   /**
-   * {@link gobblin.writer.DataWriter} metrics.
+   * {@link org.apache.gobblin.writer.DataWriter} metrics.
    */
   public static class DataWriterMetrics {
 
     /**
      * A {@link com.codahale.metrics.Meter} measuring the number of records
-     * given to a {@link gobblin.writer.DataWriter}. This does not count retries.
+     * given to a {@link org.apache.gobblin.writer.DataWriter}. This does not count retries.
      */
     public static final String RECORDS_IN_METER = "gobblin.writer.records.in";
 
     /**
      * A {@link com.codahale.metrics.Meter} measuring the number of records attempted
-     * to be written by a {@link gobblin.writer.DataWriter}. This includes retries.
+     * to be written by a {@link org.apache.gobblin.writer.DataWriter}. This includes retries.
      */
     public static final String RECORDS_ATTEMPTED_METER = "gobblin.writer.records.attempted";
 
     /**
      * A {@link com.codahale.metrics.Meter} measuring the number of successful write operations performed by a
-     * {@link gobblin.writer.DataWriter}.
+     * {@link org.apache.gobblin.writer.DataWriter}.
      */
     public static final String SUCCESSFUL_WRITES_METER = "gobblin.writer.successful.writes";
 
     /**
      * A {@link com.codahale.metrics.Meter} measuring the number of failed write operations performed by a
-     * {@link gobblin.writer.DataWriter}.
+     * {@link org.apache.gobblin.writer.DataWriter}.
      */
     public static final String FAILED_WRITES_METER = "gobblin.writer.failed.writes";
 
     /**
-     * A {@link com.codahale.metrics.Meter} measuring the number records written by a {@link gobblin.writer.DataWriter}
-     * as reported by its {@link gobblin.writer.DataWriter#recordsWritten()} method.
+     * A {@link com.codahale.metrics.Meter} measuring the number records written by a {@link org.apache.gobblin.writer.DataWriter}
+     * as reported by its {@link org.apache.gobblin.writer.DataWriter#recordsWritten()} method.
      */
     public static final String RECORDS_WRITTEN_METER = "gobblin.writer.records.written";
 
     /**
-     * A {@link com.codahale.metrics.Meter} measuring the number bytes written by a {@link gobblin.writer.DataWriter} as
-     * reported by its {@link gobblin.writer.DataWriter#bytesWritten()} method.
+     * A {@link com.codahale.metrics.Meter} measuring the number bytes written by a {@link org.apache.gobblin.writer.DataWriter} as
+     * reported by its {@link org.apache.gobblin.writer.DataWriter#bytesWritten()} method.
      */
     public static final String BYTES_WRITTEN_METER = "gobblin.writer.bytes.written";
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/Tag.java
----------------------------------------------------------------------
diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/Tag.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/Tag.java
index 341408d..3ce4c79 100644
--- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/Tag.java
+++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/Tag.java
@@ -51,7 +51,7 @@ public class Tag<T> extends AbstractMap.SimpleEntry<String, T> {
    * </p>
    *
    * @param tagKeyValue String of the form "key:value".
-   * @return {@link gobblin.metrics.Tag} parsed from input.
+   * @return {@link org.apache.gobblin.metrics.Tag} parsed from input.
    */
   public static Tag<String> fromString(String tagKeyValue) {
     List<String> splitKeyValue = Splitter.on(KEY_VALUE_SEPARATOR).limit(2).omitEmptyStrings().splitToList(tagKeyValue);

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/broker/SubTaggedMetricContextKey.java
----------------------------------------------------------------------
diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/broker/SubTaggedMetricContextKey.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/broker/SubTaggedMetricContextKey.java
index cad2317..efd9af7 100644
--- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/broker/SubTaggedMetricContextKey.java
+++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/broker/SubTaggedMetricContextKey.java
@@ -21,12 +21,12 @@ import com.google.common.collect.ImmutableMap;
 
 
 /**
- * A {@link gobblin.broker.iface.SharedResourceKey} for {@link MetricContextFactory}. While {@link MetricContextKey}
- * creates a {@link gobblin.metrics.MetricContext} with keys extracted from the broker configuration, this factory creates
- * a {@link gobblin.metrics.MetricContext} which is a child of the former context, and which has tags and names specified
+ * A {@link org.apache.gobblin.broker.iface.SharedResourceKey} for {@link MetricContextFactory}. While {@link MetricContextKey}
+ * creates a {@link org.apache.gobblin.metrics.MetricContext} with keys extracted from the broker configuration, this factory creates
+ * a {@link org.apache.gobblin.metrics.MetricContext} which is a child of the former context, and which has tags and names specified
  * in the key.
  *
- * This key is useful when a construct needs to acquire a variety of tagged {@link gobblin.metrics.MetricContext} with
+ * This key is useful when a construct needs to acquire a variety of tagged {@link org.apache.gobblin.metrics.MetricContext} with
  * different tags.
  */
 public class SubTaggedMetricContextKey extends MetricContextKey {


Mime
View raw message