Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 1DE01200CEC for ; Mon, 31 Jul 2017 09:52:35 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 1C2151649E5; Mon, 31 Jul 2017 07:52:35 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 96D741649A9 for ; Mon, 31 Jul 2017 09:52:32 +0200 (CEST) Received: (qmail 18945 invoked by uid 500); 31 Jul 2017 07:52:31 -0000 Mailing-List: contact commits-help@gobblin.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@gobblin.incubator.apache.org Delivered-To: mailing list commits@gobblin.incubator.apache.org Received: (qmail 16797 invoked by uid 99); 31 Jul 2017 07:52:24 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 31 Jul 2017 07:52:24 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 313C5F3341; Mon, 31 Jul 2017 07:52:20 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: abti@apache.org To: commits@gobblin.apache.org Date: Mon, 31 Jul 2017 07:53:05 -0000 Message-Id: <58a8c78d541842dfacdcb8e004959fee@git.apache.org> In-Reply-To: <50c2ce484ba041a294296078b24418ae@git.apache.org> References: <50c2ce484ba041a294296078b24418ae@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [47/77] [abbrv] incubator-gobblin git commit: Changed JavaDocs references from gobblin to org.apache.gobblin package archived-at: Mon, 31 Jul 2017 07:52:35 -0000 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> 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 { 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 { 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 {@link gobblin.data.management.retention.version.DatasetVersion} accepted by this policy. + * {@link org.apache.gobblin.data.management.retention.DatasetCleaner}. + * @param {@link org.apache.gobblin.data.management.retention.version.DatasetVersion} accepted by this policy. */ public interface RetentionPolicy { 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 implements DatasetsFinder { @@ -115,9 +115,9 @@ public abstract class ConfigurableGlobDatasetFinder 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 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. * *

* 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. * *

* 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 { 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 { 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 { 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 { 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 { 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 { 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 { *

* * @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. * *

- * 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. *

* 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 Type of {@link gobblin.data.management.version.FileSystemDatasetVersion} expected from this class. + * @param Type of {@link org.apache.gobblin.data.management.version.FileSystemDatasetVersion} expected from this class. */ public abstract class AbstractDatasetVersionFinder implements VersionFinder { @@ -60,10 +60,10 @@ public abstract class AbstractDatasetVersionFinderversionFileStatus and a path + * Create a {@link org.apache.gobblin.data.management.version.DatasetVersion} with versionFileStatus 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 Type of {@link gobblin.data.management.version.FileSystemDatasetVersion} expected from this class. + * @param Type of {@link org.apache.gobblin.data.management.version.FileSystemDatasetVersion} expected from this class. */ public abstract class DatasetVersionFinder extends AbstractDatasetVersionFinder implements VersionFinder { @@ -56,10 +56,10 @@ public abstract class DatasetVersionFinder 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 { 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. * *

- * 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. *

* 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. * *

* 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. * *

- * 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. *

* 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. * *

- * 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}. *

* * @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. * *

- * 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. * *

- * 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. * *

- * 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. * *

- * 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. * *

- * 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. * *

- * 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. * *

- * 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}. *

* * @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 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. * *

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. * *

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. * *

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 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 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 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 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 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 extends AbstractMap.SimpleEntry { *

* * @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 fromString(String tagKeyValue) { List 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 {