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/context/NameConflictException.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/NameConflictException.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/NameConflictException.java index 2788a7e..1a59ca7 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/NameConflictException.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/NameConflictException.java @@ -21,8 +21,8 @@ import java.io.IOException; /** - * Thrown when a {@link gobblin.metrics.MetricContext} cannot be created as a child of a second - * {@link gobblin.metrics.MetricContext} because the parent already has a {@link gobblin.metrics.MetricContext} with + * Thrown when a {@link org.apache.gobblin.metrics.MetricContext} cannot be created as a child of a second + * {@link org.apache.gobblin.metrics.MetricContext} because the parent already has a {@link org.apache.gobblin.metrics.MetricContext} with * that name. */ public class NameConflictException extends IOException {
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/context/ReportableContext.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/ReportableContext.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/ReportableContext.java index 3e58c9d..e5fcd55 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/ReportableContext.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/ReportableContext.java @@ -34,8 +34,8 @@ import org.apache.gobblin.metrics.MetricContext; import org.apache.gobblin.metrics.Tag; /** - * Interface for a context that can be reported (e.g. {@link gobblin.metrics.InnerMetricContext}, - * {@link gobblin.metrics.MetricContext}). + * Interface for a context that can be reported (e.g. {@link org.apache.gobblin.metrics.InnerMetricContext}, + * {@link org.apache.gobblin.metrics.MetricContext}). */ public interface ReportableContext { @@ -57,9 +57,9 @@ public interface ReportableContext { public Optional<? extends ReportableContext> getParent(); /** - * 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, ? extends ReportableContext> getChildContextsAsMap(); 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/context/filter/ContextFilter.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/filter/ContextFilter.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/filter/ContextFilter.java index b85ac87..592c19c 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/filter/ContextFilter.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/context/filter/ContextFilter.java @@ -24,7 +24,7 @@ import org.apache.gobblin.metrics.MetricContext; /** - * Filter for selecting {@link MetricContext}s to report by a {@link gobblin.metrics.reporter.ContextAwareReporter}. + * Filter for selecting {@link MetricContext}s to report by a {@link org.apache.gobblin.metrics.reporter.ContextAwareReporter}. */ public interface ContextFilter { @@ -42,11 +42,11 @@ public interface ContextFilter { public boolean matches(MetricContext metricContext); /** - * This method is called by a {@link gobblin.metrics.reporter.ContextAwareReporter} when a {@link MetricContext} + * This method is called by a {@link org.apache.gobblin.metrics.reporter.ContextAwareReporter} when a {@link MetricContext} * that it used to report is cleaned. Every cleaned {@link MetricContext} is a leaf of the tree. In some circumstances, * after removing the {@link MetricContext} it is necessary to start reporting the parent (for example, if we * are reporting leaves, and the parent is a new leaf). This method is called to determine if the - * {@link gobblin.metrics.reporter.ContextAwareReporter} should start reporting the parent of the input + * {@link org.apache.gobblin.metrics.reporter.ContextAwareReporter} should start reporting the parent of the input * {@link InnerMetricContext}. * * @param removedMetricContext {@link InnerMetricContext} backing up the newly removed {@link MetricContext}. 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/event/EventSubmitter.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/event/EventSubmitter.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/event/EventSubmitter.java index c8f4aa5..34258ba 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/event/EventSubmitter.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/event/EventSubmitter.java @@ -30,7 +30,7 @@ import lombok.Getter; /** - * Wrapper around Avro {@link gobblin.metrics.GobblinTrackingEvent.Builder} simplifying handling {@link gobblin.metrics.GobblinTrackingEvent}s. + * Wrapper around Avro {@link org.apache.gobblin.metrics.GobblinTrackingEvent.Builder} simplifying handling {@link org.apache.gobblin.metrics.GobblinTrackingEvent}s. * * <p> * Instances of this class are immutable. Calling set* methods returns a copy of the calling instance. @@ -83,7 +83,7 @@ public class EventSubmitter { } /** - * Submits the {@link gobblin.metrics.GobblinTrackingEvent} to the {@link gobblin.metrics.MetricContext}. + * Submits the {@link org.apache.gobblin.metrics.GobblinTrackingEvent} to the {@link org.apache.gobblin.metrics.MetricContext}. * @param name Name of the event. */ public void submit(String name) { @@ -100,7 +100,7 @@ public class EventSubmitter { } /** - * Submits the {@link gobblin.metrics.GobblinTrackingEvent} to the {@link gobblin.metrics.MetricContext}. + * Submits the {@link org.apache.gobblin.metrics.GobblinTrackingEvent} to the {@link org.apache.gobblin.metrics.MetricContext}. * @param name Name of the event. * @param metadataEls List of keys and values for metadata of the form key1, value2, key2, value2, ... */ @@ -126,7 +126,7 @@ public class EventSubmitter { } /** - * Submits the {@link gobblin.metrics.GobblinTrackingEvent} to the {@link gobblin.metrics.MetricContext}. + * Submits the {@link org.apache.gobblin.metrics.GobblinTrackingEvent} to the {@link org.apache.gobblin.metrics.MetricContext}. * @param name Name of the event. * @param additionalMetadata Additional metadata to be added to the event. */ @@ -152,9 +152,9 @@ public class EventSubmitter { } /** - * Get a {@link gobblin.metrics.event.TimingEvent} attached to this {@link gobblin.metrics.event.EventSubmitter}. - * @param name Name of the {@link gobblin.metrics.GobblinTrackingEvent} that will be generated. - * @return a {@link gobblin.metrics.event.TimingEvent}. + * Get a {@link org.apache.gobblin.metrics.event.TimingEvent} attached to this {@link org.apache.gobblin.metrics.event.EventSubmitter}. + * @param name Name of the {@link org.apache.gobblin.metrics.GobblinTrackingEvent} that will be generated. + * @return a {@link org.apache.gobblin.metrics.event.TimingEvent}. */ public TimingEvent getTimingEvent(String name) { return new TimingEvent(this, name); 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/event/TimingEvent.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/event/TimingEvent.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/event/TimingEvent.java index a598348..a7ad821 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/event/TimingEvent.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/event/TimingEvent.java @@ -23,7 +23,7 @@ import com.google.common.collect.Maps; /** * Event to time actions in the program. Automatically reports start time, end time, and duration from the time - * the {@link gobblin.metrics.event.TimingEvent} was created to the time {@link #stop} is called. + * the {@link org.apache.gobblin.metrics.event.TimingEvent} was created to the time {@link #stop} is called. */ public class TimingEvent { 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/notification/EventNotification.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/notification/EventNotification.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/notification/EventNotification.java index 764bc72..e370bf0 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/notification/EventNotification.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/notification/EventNotification.java @@ -21,7 +21,7 @@ import org.apache.gobblin.metrics.GobblinTrackingEvent; /** - * Notification wrapping a {@link gobblin.metrics.GobblinTrackingEvent}. + * Notification wrapping a {@link org.apache.gobblin.metrics.GobblinTrackingEvent}. */ public class EventNotification implements Notification { private final GobblinTrackingEvent event; 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/notification/MetricContextCleanupNotification.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/notification/MetricContextCleanupNotification.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/notification/MetricContextCleanupNotification.java index aa426d2..077532b 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/notification/MetricContextCleanupNotification.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/notification/MetricContextCleanupNotification.java @@ -23,9 +23,9 @@ import org.apache.gobblin.metrics.InnerMetricContext; /** - * {@link Notification} that a {@link gobblin.metrics.MetricContext} has been garbage collected. Contains the - * {@link InnerMetricContext} associated which still includes {@link gobblin.metrics.Metric}s and - * {@link gobblin.metrics.Tag}s. + * {@link Notification} that a {@link org.apache.gobblin.metrics.MetricContext} has been garbage collected. Contains the + * {@link InnerMetricContext} associated which still includes {@link org.apache.gobblin.metrics.Metric}s and + * {@link org.apache.gobblin.metrics.Tag}s. */ @Data public class MetricContextCleanupNotification implements 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/notification/NewMetricContextNotification.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/notification/NewMetricContextNotification.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/notification/NewMetricContextNotification.java index 5294975..44de48c 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/notification/NewMetricContextNotification.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/notification/NewMetricContextNotification.java @@ -25,7 +25,7 @@ import org.apache.gobblin.metrics.MetricContext; /** - * {@link Notification} that a new {@link gobblin.metrics.MetricContext} has been created. Contains the + * {@link Notification} that a new {@link org.apache.gobblin.metrics.MetricContext} has been created. Contains the * new {@link MetricContext}. */ @AllArgsConstructor 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/notification/Notification.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/notification/Notification.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/notification/Notification.java index 15e83da..70a2384 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/notification/Notification.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/notification/Notification.java @@ -19,7 +19,7 @@ package org.apache.gobblin.metrics.notification; /** * Generic interface for notifications. - * See for example {@link gobblin.metrics.MetricContext#sendNotification}. + * See for example {@link org.apache.gobblin.metrics.MetricContext#sendNotification}. */ public interface 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/reporter/ConfiguredScheduledReporter.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/ConfiguredScheduledReporter.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/ConfiguredScheduledReporter.java index 26a9ab1..7f85e3b 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/ConfiguredScheduledReporter.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/ConfiguredScheduledReporter.java @@ -147,7 +147,7 @@ public abstract class ConfiguredScheduledReporter extends ScheduledReporter { /** * Add tags - * @param tags additional {@link gobblin.metrics.Tag}s for the reporter. + * @param tags additional {@link org.apache.gobblin.metrics.Tag}s for the reporter. * @return {@code this} */ public T withTags(Map<String, String> tags) { @@ -157,7 +157,7 @@ public abstract class ConfiguredScheduledReporter extends ScheduledReporter { /** * Add tags. - * @param tags List of {@link gobblin.metrics.Tag} + * @param tags List of {@link org.apache.gobblin.metrics.Tag} * @return {@code this} */ public T withTags(List<Tag<?>> tags) { 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/reporter/ContextAwareReporter.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/ContextAwareReporter.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/ContextAwareReporter.java index 0eb4eb3..8504680 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/ContextAwareReporter.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/ContextAwareReporter.java @@ -47,7 +47,7 @@ import org.apache.gobblin.metrics.notification.Notification; /** * Base {@link Reporter} for gobblin metrics. Automatically handles {@link MetricContext} selection, - * {@link gobblin.metrics.Metric} filtering, and changes to reporting on {@link MetricContext} life cycle. + * {@link org.apache.gobblin.metrics.Metric} filtering, and changes to reporting on {@link MetricContext} life cycle. * * <p> * The lifecycle of a {@link ContextAwareReporter} fully managed by the {@link RootMetricContext} is: 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/reporter/ContextAwareScheduledReporter.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/ContextAwareScheduledReporter.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/ContextAwareScheduledReporter.java index 2f005df..181d27a 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/ContextAwareScheduledReporter.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/ContextAwareScheduledReporter.java @@ -35,7 +35,7 @@ import org.apache.gobblin.metrics.MetricContext; /** * A custom {@link com.codahale.metrics.ScheduledReporter} that is aware of the - * {@link gobblin.metrics.MetricContext} it is associated to. + * {@link org.apache.gobblin.metrics.MetricContext} it is associated to. * * @author Yinan Li */ @@ -86,12 +86,12 @@ public abstract class ContextAwareScheduledReporter extends ScheduledReporter { * * <p> * The metric names (the keys in the given {@link SortedMap}s) may or may not include the - * {@link gobblin.metrics.Tag}s of the {@link MetricContext} depending on if the {@link MetricContext} is + * {@link org.apache.gobblin.metrics.Tag}s of the {@link MetricContext} depending on if the {@link MetricContext} is * configured to report fully-qualified metric names or not using the method * {@link MetricContext.Builder#reportFullyQualifiedNames(boolean)}. It is up to the * implementation of this method to decide on whether to include the name of the - * {@link MetricContext} (given by {@link MetricContext#getName()}) and the {@link gobblin.metrics.Tag}s - * of individual {@link gobblin.metrics.ContextAwareMetric}s when reporting them. + * {@link MetricContext} (given by {@link MetricContext#getName()}) and the {@link org.apache.gobblin.metrics.Tag}s + * of individual {@link org.apache.gobblin.metrics.ContextAwareMetric}s when reporting them. * </p> * * @param gauges all of the gauges in the {@link MetricContext} 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/reporter/EventReporter.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/EventReporter.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/EventReporter.java index d93e4a6..498ad58 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/EventReporter.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/EventReporter.java @@ -60,7 +60,7 @@ import static org.apache.gobblin.metrics.event.JobEvent.METADATA_JOB_ID; import static org.apache.gobblin.metrics.event.TaskEvent.METADATA_TASK_ID; /** - * Abstract class for reporting {@link gobblin.metrics.GobblinTrackingEvent}s at a fixed schedule. + * Abstract class for reporting {@link org.apache.gobblin.metrics.GobblinTrackingEvent}s at a fixed schedule. * * <p> * Subclasses should implement {@link #reportEventQueue} to emit the events to the sink. Events will only be @@ -105,9 +105,9 @@ public abstract class EventReporter extends ScheduledReporter implements Closeab } /** - * Callback used by the {@link gobblin.metrics.MetricContext} to notify the object of a new - * {@link gobblin.metrics.GobblinTrackingEvent}. - * @param notification {@link gobblin.metrics.notification.Notification} to process. + * Callback used by the {@link org.apache.gobblin.metrics.MetricContext} to notify the object of a new + * {@link org.apache.gobblin.metrics.GobblinTrackingEvent}. + * @param notification {@link org.apache.gobblin.metrics.notification.Notification} to process. */ public void notificationCallback(Notification notification) { if (notification instanceof EventNotification) { @@ -116,8 +116,8 @@ public abstract class EventReporter extends ScheduledReporter implements Closeab } /** - * Add {@link gobblin.metrics.GobblinTrackingEvent} to the events queue. - * @param event {@link gobblin.metrics.GobblinTrackingEvent} to add to queue. + * Add {@link org.apache.gobblin.metrics.GobblinTrackingEvent} to the events queue. + * @param event {@link org.apache.gobblin.metrics.GobblinTrackingEvent} to add to queue. */ public void addEventToReportingQueue(GobblinTrackingEvent event) { if (this.reportingQueue.size() > QUEUE_CAPACITY * 2 / 3) { @@ -135,7 +135,7 @@ public abstract class EventReporter extends ScheduledReporter implements Closeab } /** - * Report all {@link gobblin.metrics.GobblinTrackingEvent}s in the queue. + * Report all {@link org.apache.gobblin.metrics.GobblinTrackingEvent}s in the queue. */ @Override public void report() { @@ -143,8 +143,8 @@ public abstract class EventReporter extends ScheduledReporter implements Closeab } /** - * Emit all {@link gobblin.metrics.GobblinTrackingEvent} in queue. - * @param queue {@link java.util.Queue} containing {@link gobblin.metrics.GobblinTrackingEvent}s that should be emitted. + * Emit all {@link org.apache.gobblin.metrics.GobblinTrackingEvent} in queue. + * @param queue {@link java.util.Queue} containing {@link org.apache.gobblin.metrics.GobblinTrackingEvent}s that should be emitted. */ public abstract void reportEventQueue(Queue<GobblinTrackingEvent> queue); 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/reporter/MetricReportReporter.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/MetricReportReporter.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/MetricReportReporter.java index 59508f2..75dea54 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/MetricReportReporter.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/MetricReportReporter.java @@ -47,7 +47,7 @@ import org.apache.gobblin.metrics.MetricReport; /** - * Scheduled reporter based on {@link gobblin.metrics.MetricReport}. + * Scheduled reporter based on {@link org.apache.gobblin.metrics.MetricReport}. * * <p> * This class will generate a metric report, and call {@link #emitReport} to actually emit the metrics. @@ -145,7 +145,7 @@ public abstract class MetricReportReporter extends ConfiguredScheduledReporter { } /** - * Emit the {@link gobblin.metrics.MetricReport} to the metrics sink. + * Emit the {@link org.apache.gobblin.metrics.MetricReport} to the metrics sink. * * @param report metric report to emit. */ @@ -156,7 +156,7 @@ public abstract class MetricReportReporter extends ConfiguredScheduledReporter { * * @param name name of the {@link com.codahale.metrics.Gauge}. * @param gauge instance of {@link com.codahale.metrics.Gauge} to serialize. - * @return a list of {@link gobblin.metrics.Metric}. + * @return a list of {@link org.apache.gobblin.metrics.Metric}. */ protected List<Metric> serializeGauge(String name, Gauge gauge) { List<Metric> metrics = Lists.newArrayList(); @@ -173,7 +173,7 @@ public abstract class MetricReportReporter extends ConfiguredScheduledReporter { * * @param name name of the {@link com.codahale.metrics.Counter}. * @param counter instance of {@link com.codahale.metrics.Counter} to serialize. - * @return a list of {@link gobblin.metrics.Metric}. + * @return a list of {@link org.apache.gobblin.metrics.Metric}. */ protected List<Metric> serializeCounter(String name, Counting counter) { return Lists.newArrayList( @@ -186,7 +186,7 @@ public abstract class MetricReportReporter extends ConfiguredScheduledReporter { * * @param name name of the {@link com.codahale.metrics.Metered}. * @param meter instance of {@link com.codahale.metrics.Metered} to serialize. - * @return a list of {@link gobblin.metrics.Metric}. + * @return a list of {@link org.apache.gobblin.metrics.Metric}. */ protected List<Metric> serializeMetered(String name, Metered meter) { return Lists.newArrayList( @@ -203,7 +203,7 @@ public abstract class MetricReportReporter extends ConfiguredScheduledReporter { * * @param name name of the {@link com.codahale.metrics.Snapshot}. * @param snapshot instance of {@link com.codahale.metrics.Snapshot} to serialize. - * @return a list of {@link gobblin.metrics.Metric}. + * @return a list of {@link org.apache.gobblin.metrics.Metric}. */ protected List<Metric> serializeSnapshot(String name, Snapshot snapshot) { return Lists.newArrayList( @@ -219,12 +219,12 @@ public abstract class MetricReportReporter extends ConfiguredScheduledReporter { } /** - * Convert single value into list of {@link gobblin.metrics.Metric}. + * Convert single value into list of {@link org.apache.gobblin.metrics.Metric}. * * @param name name of the metric. * @param value value of the metric. * @param path suffixes to more precisely identify the meaning of the reported value - * @return a Singleton list of {@link gobblin.metrics.Metric}. + * @return a Singleton list of {@link org.apache.gobblin.metrics.Metric}. */ protected List<Metric> serializeSingleValue(String name, Number value, String... path) { return Lists.newArrayList( @@ -238,7 +238,7 @@ public abstract class MetricReportReporter extends ConfiguredScheduledReporter { * @param name name of the metric * @param value value of the metric to report * @param path additional suffixes to further identify the meaning of the reported value - * @return a {@link gobblin.metrics.Metric}. + * @return a {@link org.apache.gobblin.metrics.Metric}. */ protected Metric serializeValue(String name, Number value, String... path) { return new Metric(MetricRegistry.name(name, path), value.doubleValue()); 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/reporter/OutputStreamEventReporter.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/OutputStreamEventReporter.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/OutputStreamEventReporter.java index 44d7aed..e0415fe 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/OutputStreamEventReporter.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/OutputStreamEventReporter.java @@ -40,7 +40,7 @@ import org.apache.gobblin.metrics.reporter.util.NoopSchemaVersionWriter; /** - * {@link gobblin.metrics.reporter.EventReporter} that writes {@link gobblin.metrics.GobblinTrackingEvent}s to an + * {@link org.apache.gobblin.metrics.reporter.EventReporter} that writes {@link org.apache.gobblin.metrics.GobblinTrackingEvent}s to an * {@link java.io.OutputStream}. */ public class OutputStreamEventReporter extends EventReporter { @@ -100,10 +100,10 @@ public class OutputStreamEventReporter extends EventReporter { } /** - * Returns a new {@link gobblin.metrics.kafka.KafkaEventReporter.Builder} for {@link gobblin.metrics.kafka.KafkaEventReporter}. + * Returns a new {@link org.apache.gobblin.metrics.kafka.KafkaEventReporter.Builder} for {@link org.apache.gobblin.metrics.kafka.KafkaEventReporter}. * 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 KafkaReporter builder */ public static Builder<? extends Builder> forContext(MetricContext context) { 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/reporter/RecursiveScheduledMetricReporter.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/RecursiveScheduledMetricReporter.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/RecursiveScheduledMetricReporter.java index b25c561..e758cd4 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/RecursiveScheduledMetricReporter.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/RecursiveScheduledMetricReporter.java @@ -35,7 +35,7 @@ import org.apache.gobblin.metrics.MetricContext; /** - * Reports the metrics of a {@link gobblin.metrics.MetricContext} following a schedule. + * Reports the metrics of a {@link org.apache.gobblin.metrics.MetricContext} following a schedule. */ public abstract class RecursiveScheduledMetricReporter extends RecursiveScheduledReporter { 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/reporter/RecursiveScheduledReporter.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/RecursiveScheduledReporter.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/RecursiveScheduledReporter.java index f612736..f9f74d8 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/RecursiveScheduledReporter.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/RecursiveScheduledReporter.java @@ -51,7 +51,7 @@ public abstract class RecursiveScheduledReporter extends ScheduledReporter { } /** - * Report a {@link com.codahale.metrics.MetricRegistry}. If the input is a {@link gobblin.metrics.MetricContext} + * Report a {@link com.codahale.metrics.MetricRegistry}. If the input is a {@link org.apache.gobblin.metrics.MetricContext} * it will also report all of its children recursively. * @param registry MetricRegistry to report. */ 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/reporter/util/AvroBinarySerializer.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/util/AvroBinarySerializer.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/util/AvroBinarySerializer.java index 977c036..3b5a669 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/util/AvroBinarySerializer.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/util/AvroBinarySerializer.java @@ -26,7 +26,7 @@ import org.apache.avro.io.EncoderFactory; import org.apache.avro.specific.SpecificRecord; /** - * {@link gobblin.metrics.reporter.util.AvroSerializer} that serializes into binary. + * {@link org.apache.gobblin.metrics.reporter.util.AvroSerializer} that serializes into binary. */ public class AvroBinarySerializer<T extends SpecificRecord> extends AvroSerializer<T> { 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/reporter/util/AvroJsonSerializer.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/util/AvroJsonSerializer.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/util/AvroJsonSerializer.java index 4866ed9..c05c814 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/util/AvroJsonSerializer.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/util/AvroJsonSerializer.java @@ -27,7 +27,7 @@ import org.apache.avro.specific.SpecificRecord; /** - * {@link gobblin.metrics.reporter.util.AvroSerializer} that serializes into JSON. + * {@link org.apache.gobblin.metrics.reporter.util.AvroSerializer} that serializes into JSON. */ public class AvroJsonSerializer<T extends SpecificRecord> extends AvroSerializer<T> { 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/reporter/util/AvroSerializer.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/util/AvroSerializer.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/util/AvroSerializer.java index 8d70157..21e550b 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/util/AvroSerializer.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/util/AvroSerializer.java @@ -62,8 +62,8 @@ public abstract class AvroSerializer<T extends SpecificRecord> implements Closea } /** - * Change the {@link gobblin.metrics.reporter.util.SchemaVersionWriter} used by this serializer. - * @param schemaVersionWriter new {@link gobblin.metrics.reporter.util.SchemaVersionWriter} to use. + * Change the {@link org.apache.gobblin.metrics.reporter.util.SchemaVersionWriter} used by this serializer. + * @param schemaVersionWriter new {@link org.apache.gobblin.metrics.reporter.util.SchemaVersionWriter} to use. */ public synchronized void setSchemaVersionWriter(SchemaVersionWriter schemaVersionWriter) { this.schemaVersionWriter = schemaVersionWriter; @@ -78,7 +78,7 @@ public abstract class AvroSerializer<T extends SpecificRecord> implements Closea protected abstract Encoder getEncoder(Schema schema, OutputStream outputStream) throws IOException; /** - * Converts a {@link gobblin.metrics.MetricReport} to bytes to send through Kafka. + * Converts a {@link org.apache.gobblin.metrics.MetricReport} to bytes to send through Kafka. * * <p> * Actual serialized record will be prepended with a schema version generated by {@link #schemaVersionWriter}. 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/reporter/util/EventUtils.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/util/EventUtils.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/util/EventUtils.java index 14ad49f..af2869b 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/util/EventUtils.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/util/EventUtils.java @@ -32,7 +32,7 @@ import org.apache.gobblin.metrics.GobblinTrackingEvent; /** - * Utilities for {@link gobblin.metrics.MetricReport}. + * Utilities for {@link org.apache.gobblin.metrics.MetricReport}. */ public class EventUtils { @@ -40,7 +40,7 @@ public class EventUtils { private static Optional<SpecificDatumReader<GobblinTrackingEvent>> reader = Optional.absent(); /** - * Parses a {@link gobblin.metrics.MetricReport} from a byte array representing a json input. + * Parses a {@link org.apache.gobblin.metrics.MetricReport} from a byte array representing a json input. * @param reuse MetricReport to reuse. * @param bytes Input bytes. * @return MetricReport. @@ -75,7 +75,7 @@ public class EventUtils { } /** - * Parses a {@link gobblin.metrics.MetricReport} from a byte array Avro serialization. + * Parses a {@link org.apache.gobblin.metrics.MetricReport} from a byte array Avro serialization. * @param reuse MetricReport to reuse. * @param bytes Input bytes. * @return MetricReport. 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/reporter/util/MetricReportUtils.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/util/MetricReportUtils.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/util/MetricReportUtils.java index 4574bc3..34727fe 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/util/MetricReportUtils.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/util/MetricReportUtils.java @@ -32,7 +32,7 @@ import org.apache.gobblin.metrics.MetricReport; /** - * Utilities for {@link gobblin.metrics.MetricReport}. + * Utilities for {@link org.apache.gobblin.metrics.MetricReport}. */ public class MetricReportUtils { @@ -40,7 +40,7 @@ public class MetricReportUtils { private static Optional<SpecificDatumReader<MetricReport>> READER = Optional.absent(); /** - * Parses a {@link gobblin.metrics.MetricReport} from a byte array representing a json input. + * Parses a {@link org.apache.gobblin.metrics.MetricReport} from a byte array representing a json input. * @param reuse MetricReport to reuse. * @param bytes Input bytes. * @return MetricReport. @@ -76,7 +76,7 @@ public class MetricReportUtils { } /** - * Parses a {@link gobblin.metrics.MetricReport} from a byte array Avro serialization. + * Parses a {@link org.apache.gobblin.metrics.MetricReport} from a byte array Avro serialization. * @param reuse MetricReport to reuse. * @param bytes Input bytes. * @return MetricReport. 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/reporter/util/NoopSchemaVersionWriter.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/util/NoopSchemaVersionWriter.java b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/util/NoopSchemaVersionWriter.java index 11ff620..32021d0 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/util/NoopSchemaVersionWriter.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/util/NoopSchemaVersionWriter.java @@ -27,7 +27,7 @@ import org.apache.gobblin.annotation.Alias; /** - * Implementation of {@link gobblin.metrics.reporter.util.SchemaVersionWriter} that does not write anything to + * Implementation of {@link org.apache.gobblin.metrics.reporter.util.SchemaVersionWriter} that does not write anything to * {@link java.io.DataOutputStream}. */ @Alias(value = "NOOP") http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-metrics-libs/gobblin-metrics-base/src/test/java/org/apache/gobblin/metrics/MetricContextTest.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/test/java/org/apache/gobblin/metrics/MetricContextTest.java b/gobblin-metrics-libs/gobblin-metrics-base/src/test/java/org/apache/gobblin/metrics/MetricContextTest.java index 4a1ba1e..f80688a 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/test/java/org/apache/gobblin/metrics/MetricContextTest.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/test/java/org/apache/gobblin/metrics/MetricContextTest.java @@ -48,7 +48,7 @@ import org.apache.gobblin.metrics.reporter.ContextAwareScheduledReporter; * <p> * This test class also tests classes {@link ContextAwareCounter}, {@link ContextAwareMeter}, * {@link ContextAwareHistogram}, {@link ContextAwareTimer}, {@link ContextAwareGauge}, - * {@link gobblin.metrics.reporter.ContextAwareScheduledReporter}, and {@link TagBasedMetricFilter}. + * {@link org.apache.gobblin.metrics.reporter.ContextAwareScheduledReporter}, and {@link TagBasedMetricFilter}. * </p> * * @author Yinan Li http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-metrics-libs/gobblin-metrics-base/src/test/java/org/apache/gobblin/metrics/RootMetricContextTest.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/test/java/org/apache/gobblin/metrics/RootMetricContextTest.java b/gobblin-metrics-libs/gobblin-metrics-base/src/test/java/org/apache/gobblin/metrics/RootMetricContextTest.java index 156e974..b532677 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/test/java/org/apache/gobblin/metrics/RootMetricContextTest.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/test/java/org/apache/gobblin/metrics/RootMetricContextTest.java @@ -41,7 +41,7 @@ import org.apache.gobblin.metrics.test.ContextStoreReporter; /** - * Tests for {@link gobblin.metrics.RootMetricContext} + * Tests for {@link org.apache.gobblin.metrics.RootMetricContext} */ public class RootMetricContextTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-metrics-libs/gobblin-metrics-base/src/test/java/org/apache/gobblin/metrics/performance/PerformanceUtils.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/test/java/org/apache/gobblin/metrics/performance/PerformanceUtils.java b/gobblin-metrics-libs/gobblin-metrics-base/src/test/java/org/apache/gobblin/metrics/performance/PerformanceUtils.java index 52909e0..665e5f7 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/test/java/org/apache/gobblin/metrics/performance/PerformanceUtils.java +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/test/java/org/apache/gobblin/metrics/performance/PerformanceUtils.java @@ -56,8 +56,8 @@ public class PerformanceUtils { * </p> * * @param threads Number of threads to spawn. Each thread will have an {@link Incrementer} and update metrics. - * @param depth Depth of the {@link gobblin.metrics.MetricContext} tree. - * @param forkAtDepth If multiple threads, each thread has its own {@link gobblin.metrics.MetricContext}. This + * @param depth Depth of the {@link org.apache.gobblin.metrics.MetricContext} tree. + * @param forkAtDepth If multiple threads, each thread has its own {@link org.apache.gobblin.metrics.MetricContext}. This * parameter sets the first level in the tree where the per-thread MetricContexts branch off. * @param counters Number of counters to generate per thread. * @param meters Number of meters to generate per thread. @@ -149,13 +149,13 @@ public class PerformanceUtils { } /** - * Runs a single performance test. Creates a {@link gobblin.metrics.MetricContext} tree, spawns a number of threads, + * Runs a single performance test. Creates a {@link org.apache.gobblin.metrics.MetricContext} tree, spawns a number of threads, * uses and {@link Incrementer} to update the metrics repeatedly, then determines the achieved QPS in number * of iterations of {@link Incrementer} per second. * * @param threads Number of threads to spawn. Each thread will have an {@link Incrementer} and update metrics. - * @param depth Depth of the {@link gobblin.metrics.MetricContext} tree. - * @param forkAtDepth If multiple threads, each thread has its own {@link gobblin.metrics.MetricContext}. This + * @param depth Depth of the {@link org.apache.gobblin.metrics.MetricContext} tree. + * @param forkAtDepth If multiple threads, each thread has its own {@link org.apache.gobblin.metrics.MetricContext}. This * parameter sets the first level in the tree where the per-thread MetricContexts branch off. * @param counters Number of counters to generate per thread. * @param meters Number of meters to generate per thread. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-metrics-libs/gobblin-metrics/src/main/java/org/apache/gobblin/metrics/GobblinMetrics.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics/src/main/java/org/apache/gobblin/metrics/GobblinMetrics.java b/gobblin-metrics-libs/gobblin-metrics/src/main/java/org/apache/gobblin/metrics/GobblinMetrics.java index 6dcd477..4b0a815 100644 --- a/gobblin-metrics-libs/gobblin-metrics/src/main/java/org/apache/gobblin/metrics/GobblinMetrics.java +++ b/gobblin-metrics-libs/gobblin-metrics/src/main/java/org/apache/gobblin/metrics/GobblinMetrics.java @@ -164,13 +164,13 @@ public class GobblinMetrics { } /** - * Add a {@link List} of {@link Tag}s to a {@link gobblin.configuration.State} with key {@link #METRICS_STATE_CUSTOM_TAGS}. + * Add a {@link List} of {@link Tag}s to a {@link org.apache.gobblin.configuration.State} with key {@link #METRICS_STATE_CUSTOM_TAGS}. * * <p> - * {@link gobblin.metrics.Tag}s under this key can later be parsed using the method {@link #getCustomTagsFromState}. + * {@link org.apache.gobblin.metrics.Tag}s under this key can later be parsed using the method {@link #getCustomTagsFromState}. * </p> * - * @param state {@link gobblin.configuration.State} state to add the tag to. + * @param state {@link org.apache.gobblin.configuration.State} state to add the tag to. * @param tags list of {@link Tag}s to add. */ public static void addCustomTagToState(State state, List<? extends Tag<?>> tags) { @@ -180,13 +180,13 @@ public class GobblinMetrics { } /** - * Add a {@link Tag} to a {@link gobblin.configuration.State} with key {@link #METRICS_STATE_CUSTOM_TAGS}. + * Add a {@link Tag} to a {@link org.apache.gobblin.configuration.State} with key {@link #METRICS_STATE_CUSTOM_TAGS}. * * <p> - * {@link gobblin.metrics.Tag}s under this key can later be parsed using the method {@link #getCustomTagsFromState}. + * {@link org.apache.gobblin.metrics.Tag}s under this key can later be parsed using the method {@link #getCustomTagsFromState}. * </p> * - * @param state {@link gobblin.configuration.State} state to add the tag to. + * @param state {@link org.apache.gobblin.configuration.State} state to add the tag to. * @param tag {@link Tag} to add. */ public static void addCustomTagToState(State state, Tag<?> tag) { @@ -201,7 +201,7 @@ public class GobblinMetrics { * * <p> * The {@link Properties} passed can be used to build a {@link State}. - * {@link gobblin.metrics.Tag}s under this key can later be parsed using the method {@link #getCustomTagsFromState}. + * {@link org.apache.gobblin.metrics.Tag}s under this key can later be parsed using the method {@link #getCustomTagsFromState}. * </p> * * @param properties {@link Properties} to add the tag to. @@ -219,7 +219,7 @@ public class GobblinMetrics { * * <p> * The {@link Properties} passed can be used to build a {@link State}. - * {@link gobblin.metrics.Tag}s under this key can later be parsed using the method {@link #getCustomTagsFromState}. + * {@link org.apache.gobblin.metrics.Tag}s under this key can later be parsed using the method {@link #getCustomTagsFromState}. * </p> * * @param properties {@link Properties} to add the tag to. @@ -232,10 +232,10 @@ public class GobblinMetrics { } /** - * Parse custom {@link gobblin.metrics.Tag}s from property {@link #METRICS_STATE_CUSTOM_TAGS} - * in the input {@link gobblin.configuration.State}. - * @param state {@link gobblin.configuration.State} possibly containing custom tags. - * @return List of {@link gobblin.metrics.Tag} parsed from input. + * Parse custom {@link org.apache.gobblin.metrics.Tag}s from property {@link #METRICS_STATE_CUSTOM_TAGS} + * in the input {@link org.apache.gobblin.configuration.State}. + * @param state {@link org.apache.gobblin.configuration.State} possibly containing custom tags. + * @return List of {@link org.apache.gobblin.metrics.Tag} parsed from input. */ public static List<Tag<?>> getCustomTagsFromState(State state) { List<Tag<?>> tags = Lists.newArrayList(); @@ -673,7 +673,7 @@ public class GobblinMetrics { /** * Build scheduled metrics reporters by reflection from the property - * {@link gobblin.configuration.ConfigurationKeys#METRICS_CUSTOM_BUILDERS}. This allows users to specify custom + * {@link org.apache.gobblin.configuration.ConfigurationKeys#METRICS_CUSTOM_BUILDERS}. This allows users to specify custom * reporters for Gobblin runtime without having to modify the code. */ private void buildCustomMetricReporters(Properties properties) { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-metrics-libs/gobblin-metrics/src/main/java/org/apache/gobblin/metrics/GobblinMetricsRegistry.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics/src/main/java/org/apache/gobblin/metrics/GobblinMetricsRegistry.java b/gobblin-metrics-libs/gobblin-metrics/src/main/java/org/apache/gobblin/metrics/GobblinMetricsRegistry.java index 76a8c0f..d50a0bc 100644 --- a/gobblin-metrics-libs/gobblin-metrics/src/main/java/org/apache/gobblin/metrics/GobblinMetricsRegistry.java +++ b/gobblin-metrics-libs/gobblin-metrics/src/main/java/org/apache/gobblin/metrics/GobblinMetricsRegistry.java @@ -117,9 +117,9 @@ public class GobblinMetricsRegistry { /** * <p> - * Creates {@link gobblin.metrics.MetricContext}. Tries to read the name of the parent context + * Creates {@link org.apache.gobblin.metrics.MetricContext}. Tries to read the name of the parent context * from key "metrics.context.name" at state, and tries to get the parent context by name from - * the {@link gobblin.metrics.MetricContext} registry (the parent context must be registered). + * the {@link org.apache.gobblin.metrics.MetricContext} registry (the parent context must be registered). * </p> * * <p> http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-metrics-libs/gobblin-metrics/src/test/java/org/apache/gobblin/metrics/reporter/ScheduledReporterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics/src/test/java/org/apache/gobblin/metrics/reporter/ScheduledReporterTest.java b/gobblin-metrics-libs/gobblin-metrics/src/test/java/org/apache/gobblin/metrics/reporter/ScheduledReporterTest.java index 0a61b3a..1c862dc 100644 --- a/gobblin-metrics-libs/gobblin-metrics/src/test/java/org/apache/gobblin/metrics/reporter/ScheduledReporterTest.java +++ b/gobblin-metrics-libs/gobblin-metrics/src/test/java/org/apache/gobblin/metrics/reporter/ScheduledReporterTest.java @@ -39,7 +39,7 @@ import org.apache.gobblin.util.ConfigUtils; /** - * Test for {@link gobblin.metrics.reporter.ScheduledReporter} + * Test for {@link org.apache.gobblin.metrics.reporter.ScheduledReporter} */ public class ScheduledReporterTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanJobLauncher.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanJobLauncher.java b/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanJobLauncher.java index 4aff1df..bdbb04f 100644 --- a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanJobLauncher.java +++ b/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanJobLauncher.java @@ -70,7 +70,7 @@ import static org.apache.hadoop.security.UserGroupInformation.HADOOP_TOKEN_FILE_ * A utility class for launching a Gobblin Hadoop MR job through Azkaban. * * <p> - * By default, this class will use the {@link gobblin.runtime.mapreduce.MRJobLauncher} to launch and run + * By default, this class will use the {@link org.apache.gobblin.runtime.mapreduce.MRJobLauncher} to launch and run * the Gobblin job unless a different job launcher type is explicitly specified in the job configuration * using {@link ConfigurationKeys#JOB_LAUNCHER_TYPE_KEY}. * </p> http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/retention/DatasetCleanerJob.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/retention/DatasetCleanerJob.java b/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/retention/DatasetCleanerJob.java index f69f54c..c4a18cc 100644 --- a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/retention/DatasetCleanerJob.java +++ b/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/retention/DatasetCleanerJob.java @@ -30,7 +30,7 @@ import azkaban.utils.Props; /** - * Job to run {@link gobblin.data.management.retention.DatasetCleanerNew} job in Azkaban or Hadoop. + * Job to run {@link org.apache.gobblin.data.management.retention.DatasetCleanerNew} job in Azkaban or Hadoop. */ public class DatasetCleanerJob extends AbstractJob implements Tool { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/ComplianceRestoreJob.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/ComplianceRestoreJob.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/ComplianceRestoreJob.java index 8f3d516..7280c42 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/ComplianceRestoreJob.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/ComplianceRestoreJob.java @@ -48,7 +48,7 @@ import org.apache.gobblin.util.reflection.GobblinConstructorUtils; /** - * Job for restoring {@link gobblin.compliance.HivePartitionDataset} from the backups + * Job for restoring {@link org.apache.gobblin.compliance.HivePartitionDataset} from the backups * * @author adsharma */ http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/RestorableHivePartitionDataset.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/RestorableHivePartitionDataset.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/RestorableHivePartitionDataset.java index 8d4eb9b..ae7a6d9 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/RestorableHivePartitionDataset.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/RestorableHivePartitionDataset.java @@ -47,7 +47,7 @@ import org.apache.gobblin.util.reflection.GobblinConstructorUtils; /** * A Restorable {@link HivePartitionDataset}. It restores a given {@link HivePartitionDataset} with a - * {@link gobblin.compliance.HivePartitionVersion} based on {@link RestorePolicy} + * {@link org.apache.gobblin.compliance.HivePartitionVersion} based on {@link RestorePolicy} * * @author adsharma */ http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-modules/gobblin-crypto/src/main/java/org/apache/gobblin/converter/SerializedRecordToEncryptedSerializedRecordConverterBase.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-crypto/src/main/java/org/apache/gobblin/converter/SerializedRecordToEncryptedSerializedRecordConverterBase.java b/gobblin-modules/gobblin-crypto/src/main/java/org/apache/gobblin/converter/SerializedRecordToEncryptedSerializedRecordConverterBase.java index 0f0b8ca..fee7887 100644 --- a/gobblin-modules/gobblin-crypto/src/main/java/org/apache/gobblin/converter/SerializedRecordToEncryptedSerializedRecordConverterBase.java +++ b/gobblin-modules/gobblin-crypto/src/main/java/org/apache/gobblin/converter/SerializedRecordToEncryptedSerializedRecordConverterBase.java @@ -31,7 +31,7 @@ import org.apache.gobblin.type.RecordWithMetadata; /** - * A converter that converts a {@link gobblin.type.SerializedRecordWithMetadata} to a {@link gobblin.type.SerializedRecordWithMetadata} + * A converter that converts a {@link org.apache.gobblin.type.SerializedRecordWithMetadata} to a {@link org.apache.gobblin.type.SerializedRecordWithMetadata} * where the serialized bytes represent encrypted data. The encryption algorithm used will be appended to the * Transfer-Encoding of the new record. */ http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-modules/gobblin-eventhub/src/main/java/org/apache/gobblin/eventhub/EventhubMetricNames.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-eventhub/src/main/java/org/apache/gobblin/eventhub/EventhubMetricNames.java b/gobblin-modules/gobblin-eventhub/src/main/java/org/apache/gobblin/eventhub/EventhubMetricNames.java index 9671b65..2abcac0 100644 --- a/gobblin-modules/gobblin-eventhub/src/main/java/org/apache/gobblin/eventhub/EventhubMetricNames.java +++ b/gobblin-modules/gobblin-eventhub/src/main/java/org/apache/gobblin/eventhub/EventhubMetricNames.java @@ -9,22 +9,22 @@ public class EventhubMetricNames { /** * A {@link com.codahale.metrics.Meter} measuring the number of records attempted - * to be written by a {@link gobblin.eventhub.writer.EventhubDataWriter}. This includes retries. + * to be written by a {@link org.apache.gobblin.eventhub.writer.EventhubDataWriter}. This includes retries. */ public static final String RECORDS_ATTEMPTED_METER = "eventhub.writer.records.attempted"; /** - * A {@link com.codahale.metrics.Meter} measuring the number records written by a {@link gobblin.eventhub.writer.EventhubDataWriter} + * A {@link com.codahale.metrics.Meter} measuring the number records written by a {@link org.apache.gobblin.eventhub.writer.EventhubDataWriter} */ public static final String RECORDS_SUCCESS_METER = "eventhub.writer.records.success"; /** A {@link com.codahale.metrics.Meter} measuring the number of records - * given to a {@link gobblin.eventhub.writer.EventhubDataWriter}. This does not count retries. + * given to a {@link org.apache.gobblin.eventhub.writer.EventhubDataWriter}. This does not count retries. */ public static final String RECORDS_FAILED_METER = "eventhub.writer.records.failed"; /** - * A {@link com.codahale.metrics.Meter} measuring the number bytes written by a {@link gobblin.eventhub.writer.EventhubDataWriter} as + * A {@link com.codahale.metrics.Meter} measuring the number bytes written by a {@link org.apache.gobblin.eventhub.writer.EventhubDataWriter} as */ public static final String BYTES_WRITTEN_METER = "eventhub.writer.bytes.written"; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/KafkaReportingFormats.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/KafkaReportingFormats.java b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/KafkaReportingFormats.java index 0fcac22..5f47121 100644 --- a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/KafkaReportingFormats.java +++ b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/KafkaReportingFormats.java @@ -36,10 +36,10 @@ public enum KafkaReportingFormats { JSON; /** - * Get a {@link gobblin.metrics.kafka.KafkaReporter.Builder} for this reporting format. + * Get a {@link org.apache.gobblin.metrics.kafka.KafkaReporter.Builder} for this reporting format. * * @param properties {@link java.util.Properties} containing information to build reporters. - * @return {@link gobblin.metrics.kafka.KafkaReporter.Builder}. + * @return {@link org.apache.gobblin.metrics.kafka.KafkaReporter.Builder}. */ public KafkaReporter.Builder<?> metricReporterBuilder(Properties properties) { switch (this) { @@ -59,10 +59,10 @@ public enum KafkaReportingFormats { } /** - * Get a {@link gobblin.metrics.kafka.KafkaEventReporter.Builder} for this reporting format. - * @param context {@link gobblin.metrics.MetricContext} that should be reported. + * Get a {@link org.apache.gobblin.metrics.kafka.KafkaEventReporter.Builder} for this reporting format. + * @param context {@link org.apache.gobblin.metrics.MetricContext} that should be reported. * @param properties {@link java.util.Properties} containing information to build reporters. - * @return {@link gobblin.metrics.kafka.KafkaEventReporter.Builder}. + * @return {@link org.apache.gobblin.metrics.kafka.KafkaEventReporter.Builder}. */ public KafkaEventReporter.Builder<?> eventReporterBuilder(MetricContext context, Properties properties) { switch (this) { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroEventReporter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroEventReporter.java b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroEventReporter.java index c01cbc9..5d35c87 100644 --- a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroEventReporter.java +++ b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroEventReporter.java @@ -32,7 +32,7 @@ import org.apache.gobblin.metrics.reporter.util.SchemaVersionWriter; /** - * {@link gobblin.metrics.reporter.EventReporter} that emits events to Kafka as serialized Avro records. + * {@link org.apache.gobblin.metrics.reporter.EventReporter} that emits events to Kafka as serialized Avro records. */ public class KafkaAvroEventReporter extends KafkaEventReporter { @@ -55,7 +55,7 @@ public class KafkaAvroEventReporter extends KafkaEventReporter { /** * Returns a new {@link KafkaAvroEventReporter.Builder} for {@link KafkaAvroEventReporter}. * - * @param context the {@link gobblin.metrics.MetricContext} to report + * @param context the {@link org.apache.gobblin.metrics.MetricContext} to report * @return KafkaAvroReporter builder * @deprecated this method is bugged. Use {@link KafkaAvroEventReporter.Factory#forContext} instead. */ @@ -79,7 +79,7 @@ public class KafkaAvroEventReporter extends KafkaEventReporter { /** * Returns a new {@link KafkaAvroEventReporter.Builder} for {@link KafkaAvroEventReporter}. * - * @param context the {@link gobblin.metrics.MetricContext} to report + * @param context the {@link org.apache.gobblin.metrics.MetricContext} to report * @return KafkaAvroReporter builder */ public static KafkaAvroEventReporter.BuilderImpl forContext(MetricContext context) { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroReporter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroReporter.java b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroReporter.java index 7a04358..96b0127 100644 --- a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroReporter.java +++ b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroReporter.java @@ -58,7 +58,7 @@ public class KafkaAvroReporter extends KafkaReporter { } /** - * A static factory class for obtaining new {@link gobblin.metrics.kafka.KafkaAvroReporter.Builder}s + * A static factory class for obtaining new {@link org.apache.gobblin.metrics.kafka.KafkaAvroReporter.Builder}s * * @see gobblin.metrics.kafka.KafkaAvroReporter.Builder */ http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaEventReporter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaEventReporter.java b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaEventReporter.java index bb4f9f0..c23294a 100644 --- a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaEventReporter.java +++ b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaEventReporter.java @@ -34,7 +34,7 @@ import org.apache.gobblin.metrics.reporter.util.SchemaVersionWriter; /** - * Reports {@link gobblin.metrics.GobblinTrackingEvent} to a Kafka topic serialized as JSON. + * Reports {@link org.apache.gobblin.metrics.GobblinTrackingEvent} to a Kafka topic serialized as JSON. */ public class KafkaEventReporter extends EventReporter { @@ -78,7 +78,7 @@ public class KafkaEventReporter extends EventReporter { * Returns a new {@link KafkaEventReporter.Builder} for {@link KafkaEventReporter}. * 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 KafkaReporter builder * @deprecated this method is bugged. Use {@link KafkaEventReporter.Factory#forContext} instead. */ @@ -103,7 +103,7 @@ public class KafkaEventReporter extends EventReporter { * Returns a new {@link KafkaEventReporter.Builder} for {@link KafkaEventReporter}. * 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 KafkaReporter builder */ public static BuilderImpl forContext(MetricContext context) { @@ -127,7 +127,7 @@ public class KafkaEventReporter extends EventReporter { } /** - * Set {@link gobblin.metrics.kafka.KafkaPusher} to use. + * Set {@link org.apache.gobblin.metrics.kafka.KafkaPusher} to use. */ public T withKafkaPusher(KafkaPusher pusher) { this.kafkaPusher = Optional.of(pusher); http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaReporter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaReporter.java b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaReporter.java index add315b..4c6abe4 100644 --- a/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaReporter.java +++ b/gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaReporter.java @@ -82,7 +82,7 @@ public class KafkaReporter extends MetricReportReporter { } /** - * A static factory class for obtaining new {@link gobblin.metrics.kafka.KafkaReporter.Builder}s + * A static factory class for obtaining new {@link org.apache.gobblin.metrics.kafka.KafkaReporter.Builder}s * * @see gobblin.metrics.kafka.KafkaReporter.Builder */ @@ -118,7 +118,7 @@ public class KafkaReporter extends MetricReportReporter { } /** - * Set {@link gobblin.metrics.kafka.KafkaPusher} to use. + * Set {@link org.apache.gobblin.metrics.kafka.KafkaPusher} to use. */ public T withKafkaPusher(KafkaPusher pusher) { this.kafkaPusher = Optional.of(pusher); http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaPusherTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaPusherTest.java b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaPusherTest.java index 551a0f3..325f023 100644 --- a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaPusherTest.java +++ b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaPusherTest.java @@ -30,7 +30,7 @@ import org.apache.gobblin.metrics.kafka.KafkaPusher; /** - * Test {@link gobblin.metrics.kafka.KafkaPusher}. + * Test {@link org.apache.gobblin.metrics.kafka.KafkaPusher}. */ public class KafkaPusherTest extends KafkaTestBase { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/MockKafkaPusher.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/MockKafkaPusher.java b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/MockKafkaPusher.java index 8c3f04f..948bcce 100644 --- a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/MockKafkaPusher.java +++ b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/MockKafkaPusher.java @@ -31,7 +31,7 @@ import org.apache.gobblin.metrics.kafka.ProducerCloseable; /** - * Mock instance of {@link gobblin.metrics.kafka.KafkaPusher} used for testing. + * Mock instance of {@link org.apache.gobblin.metrics.kafka.KafkaPusher} used for testing. */ public class MockKafkaPusher extends KafkaPusher { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/serialize/MD5Digest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/serialize/MD5Digest.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/serialize/MD5Digest.java index 0f5a28e..b9df3a1 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/serialize/MD5Digest.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/serialize/MD5Digest.java @@ -28,7 +28,7 @@ import com.google.common.base.Preconditions; /** * A holder for an MD5Digest * Allows for conversion between the human-readable String version and the serializable byte[] version. - * Used by the {@link gobblin.kafka.schemareg.LiKafkaSchemaRegistry} + * Used by the {@link org.apache.gobblin.kafka.schemareg.LiKafkaSchemaRegistry} */ public class MD5Digest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/writer/KafkaWriterMetricNames.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/writer/KafkaWriterMetricNames.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/writer/KafkaWriterMetricNames.java index 067b96f..debc097 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/writer/KafkaWriterMetricNames.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/writer/KafkaWriterMetricNames.java @@ -23,19 +23,19 @@ package org.apache.gobblin.kafka.writer; public class KafkaWriterMetricNames { /** * A {@link com.codahale.metrics.Meter} measuring the number of records sent to - * a {@link gobblin.kafka.writer.KafkaDataWriter}. + * a {@link org.apache.gobblin.kafka.writer.KafkaDataWriter}. */ public static final String RECORDS_PRODUCED_METER = "gobblin.writer.kafka.records.produced"; /** * A {@link com.codahale.metrics.Meter} measuring the number of records that failed to be written by - * {@link gobblin.kafka.writer.KafkaDataWriter}. + * {@link org.apache.gobblin.kafka.writer.KafkaDataWriter}. */ public static final String RECORDS_FAILED_METER = "gobblin.writer.kafka.records.failed"; /** * A {@link com.codahale.metrics.Meter} measuring the number of records that were successfully written by - * {@link gobblin.kafka.writer.KafkaDataWriter}. + * {@link org.apache.gobblin.kafka.writer.KafkaDataWriter}. */ public static final String RECORDS_SUCCESS_METER = "gobblin.writer.kafka.records.success"; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/reporter/util/SchemaRegistryVersionWriter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/reporter/util/SchemaRegistryVersionWriter.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/reporter/util/SchemaRegistryVersionWriter.java index 62439dc..bffd612 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/reporter/util/SchemaRegistryVersionWriter.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/reporter/util/SchemaRegistryVersionWriter.java @@ -37,8 +37,8 @@ import org.apache.gobblin.util.ConfigUtils; /** - * Implementation of {@link gobblin.metrics.reporter.util.SchemaVersionWriter} that uses a - * {@link gobblin.metrics.kafka.KafkaAvroSchemaRegistry} to get Schema version identifier and write it to + * Implementation of {@link org.apache.gobblin.metrics.reporter.util.SchemaVersionWriter} that uses a + * {@link org.apache.gobblin.metrics.kafka.KafkaAvroSchemaRegistry} to get Schema version identifier and write it to * {@link java.io.DataOutputStream}. */ public class SchemaRegistryVersionWriter implements SchemaVersionWriter<Schema> { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSource.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSource.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSource.java index ec4bed5..af735d1 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSource.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSource.java @@ -77,7 +77,7 @@ import static java.util.stream.Collectors.toSet; /** - * A {@link gobblin.source.Source} implementation for Kafka source. + * A {@link org.apache.gobblin.source.Source} implementation for Kafka source. * * @author Ziyang Liu */ http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/MultiLongWatermark.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/MultiLongWatermark.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/MultiLongWatermark.java index 0f35db0..bc35cc3 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/MultiLongWatermark.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/MultiLongWatermark.java @@ -30,7 +30,7 @@ import org.apache.gobblin.source.extractor.Watermark; /** - * A {@link gobblin.source.extractor.Watermark} that holds multiple long values. + * A {@link org.apache.gobblin.source.extractor.Watermark} that holds multiple long values. * * @author Ziyang Liu */ http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphiteEventReporter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphiteEventReporter.java b/gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphiteEventReporter.java index ab9d3dc..e6b6d66 100644 --- a/gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphiteEventReporter.java +++ b/gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphiteEventReporter.java @@ -41,7 +41,7 @@ import static org.apache.gobblin.metrics.event.TimingEvent.METADATA_DURATION; /** * - * {@link gobblin.metrics.reporter.EventReporter} that emits {@link gobblin.metrics.GobblinTrackingEvent} events + * {@link org.apache.gobblin.metrics.reporter.EventReporter} that emits {@link org.apache.gobblin.metrics.GobblinTrackingEvent} events * as timestamped name - value pairs through the Graphite protocol * * @author Lorand Bendig @@ -142,7 +142,7 @@ public class GraphiteEventReporter extends EventReporter { * Returns a new {@link GraphiteEventReporter.Builder} for {@link GraphiteEventReporter}. * 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 GraphiteEventReporter builder * @deprecated this method is bugged. Use {@link GraphiteEventReporter.Factory#forContext} instead. */ @@ -168,7 +168,7 @@ public class GraphiteEventReporter extends EventReporter { * Returns a new {@link GraphiteEventReporter.Builder} for {@link GraphiteEventReporter}. * 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 GraphiteEventReporter builder */ public static BuilderImpl forContext(MetricContext context) { @@ -195,7 +195,7 @@ public class GraphiteEventReporter extends EventReporter { } /** - * Set {@link gobblin.metrics.graphite.GraphitePusher} to use. + * Set {@link org.apache.gobblin.metrics.graphite.GraphitePusher} to use. */ public T withGraphitePusher(GraphitePusher pusher) { this.graphitePusher = Optional.of(pusher); @@ -203,7 +203,7 @@ public class GraphiteEventReporter extends EventReporter { } /** - * Set connection parameters for the {@link gobblin.metrics.graphite.GraphitePusher} creation + * Set connection parameters for the {@link org.apache.gobblin.metrics.graphite.GraphitePusher} creation */ public T withConnection(String hostname, int port) { this.hostname = hostname; @@ -217,7 +217,7 @@ public class GraphiteEventReporter extends EventReporter { } /** - * Set {@link gobblin.metrics.graphite.GraphiteConnectionType} to use. + * Set {@link org.apache.gobblin.metrics.graphite.GraphiteConnectionType} to use. */ public T withConnectionType(GraphiteConnectionType connectionType) { this.connectionType = connectionType; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphiteReporter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphiteReporter.java b/gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphiteReporter.java index 5170524..d038cdf 100644 --- a/gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphiteReporter.java +++ b/gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphiteReporter.java @@ -65,7 +65,7 @@ public class GraphiteReporter extends ConfiguredScheduledReporter { } /** - * A static factory class for obtaining new {@link gobblin.metrics.graphite.GraphiteReporter.Builder}s + * A static factory class for obtaining new {@link org.apache.gobblin.metrics.graphite.GraphiteReporter.Builder}s * * @see gobblin.metrics.graphite.GraphiteReporter.Builder */ @@ -106,7 +106,7 @@ public class GraphiteReporter extends ConfiguredScheduledReporter { } /** - * Set {@link gobblin.metrics.graphite.GraphitePusher} to use. + * Set {@link org.apache.gobblin.metrics.graphite.GraphitePusher} to use. */ public T withGraphitePusher(GraphitePusher pusher) { this.graphitePusher = Optional.of(pusher); @@ -114,7 +114,7 @@ public class GraphiteReporter extends ConfiguredScheduledReporter { } /** - * Set connection parameters for the {@link gobblin.metrics.graphite.GraphitePusher} creation + * Set connection parameters for the {@link org.apache.gobblin.metrics.graphite.GraphitePusher} creation */ public T withConnection(String hostname, int port) { this.hostname = hostname; @@ -123,7 +123,7 @@ public class GraphiteReporter extends ConfiguredScheduledReporter { } /** - * Set {@link gobblin.metrics.graphite.GraphiteConnectionType} to use. + * Set {@link org.apache.gobblin.metrics.graphite.GraphiteConnectionType} to use. */ public T withConnectionType(GraphiteConnectionType connectionType) { this.connectionType = connectionType; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-modules/gobblin-metrics-graphite/src/test/java/org/apache/gobblin/metrics/graphite/TestGraphiteSender.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metrics-graphite/src/test/java/org/apache/gobblin/metrics/graphite/TestGraphiteSender.java b/gobblin-modules/gobblin-metrics-graphite/src/test/java/org/apache/gobblin/metrics/graphite/TestGraphiteSender.java index a09f0ce..8d61b43 100644 --- a/gobblin-modules/gobblin-metrics-graphite/src/test/java/org/apache/gobblin/metrics/graphite/TestGraphiteSender.java +++ b/gobblin-modules/gobblin-metrics-graphite/src/test/java/org/apache/gobblin/metrics/graphite/TestGraphiteSender.java @@ -70,7 +70,7 @@ public class TestGraphiteSender implements GraphiteSender { * Get a metric with a given name. * * @param name metric name - * @return a {@link gobblin.metrics.TimestampedValue} + * @return a {@link org.apache.gobblin.metrics.TimestampedValue} */ public TimestampedValue getMetric(String name) { return this.data.get(name);
