gobblin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a...@apache.org
Subject [46/77] [abbrv] incubator-gobblin git commit: Changed JavaDocs references from gobblin to org.apache.gobblin package
Date Mon, 31 Jul 2017 07:53:04 GMT
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);


Mime
View raw message