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:53:05 UTC
[47/77] [abbrv] incubator-gobblin git commit: Changed JavaDocs
references from gobblin to org.apache.gobblin package
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 {