You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gobblin.apache.org by ab...@apache.org on 2017/07/31 07:53:04 UTC
[46/77] [abbrv] incubator-gobblin git commit: Changed JavaDocs
references from gobblin to org.apache.gobblin package
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-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);