gobblin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a...@apache.org
Subject [45/77] [abbrv] incubator-gobblin git commit: Changed JavaDocs references from gobblin to org.apache.gobblin package
Date Mon, 31 Jul 2017 07:53:03 GMT
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-modules/gobblin-metrics-hadoop/src/main/java/org/apache/gobblin/metrics/hadoop/HadoopCounterReporter.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/gobblin-metrics-hadoop/src/main/java/org/apache/gobblin/metrics/hadoop/HadoopCounterReporter.java b/gobblin-modules/gobblin-metrics-hadoop/src/main/java/org/apache/gobblin/metrics/hadoop/HadoopCounterReporter.java
index d70507c..4f7f47b 100644
--- a/gobblin-modules/gobblin-metrics-hadoop/src/main/java/org/apache/gobblin/metrics/hadoop/HadoopCounterReporter.java
+++ b/gobblin-modules/gobblin-metrics-hadoop/src/main/java/org/apache/gobblin/metrics/hadoop/HadoopCounterReporter.java
@@ -28,7 +28,7 @@ import org.apache.gobblin.metrics.MetricContext;
 
 
 /**
- * An implementation of {@link gobblin.metrics.reporter.ContextAwareScheduledReporter} that reports
+ * An implementation of {@link org.apache.gobblin.metrics.reporter.ContextAwareScheduledReporter} that reports
  * applicable metrics as Hadoop counters using a {@link org.apache.hadoop.mapred.Reporter}.
  *
  * @author Yinan Li
@@ -54,23 +54,23 @@ public class HadoopCounterReporter extends AbstractHadoopCounterReporter {
   }
 
   /**
-   * Create a new {@link gobblin.metrics.hadoop.HadoopCounterReporter.Builder} that
+   * Create a new {@link org.apache.gobblin.metrics.hadoop.HadoopCounterReporter.Builder} that
    * uses the simple name of {@link HadoopCounterReporter} as the reporter name.
    *
    * @param reporter a {@link org.apache.hadoop.mapred.Reporter} used to access Hadoop counters
-   * @return a new {@link gobblin.metrics.hadoop.HadoopCounterReporter.Builder}
+   * @return a new {@link org.apache.gobblin.metrics.hadoop.HadoopCounterReporter.Builder}
    */
   public static Builder builder(Reporter reporter) {
     return builder(HadoopCounterReporter.class.getName(), reporter);
   }
 
   /**
-   * Create a new {@link gobblin.metrics.hadoop.HadoopCounterReporter.Builder} that
+   * Create a new {@link org.apache.gobblin.metrics.hadoop.HadoopCounterReporter.Builder} that
    * uses a given reporter name.
    *
    * @param name the given reporter name
    * @param reporter a {@link org.apache.hadoop.mapred.Reporter} used to access Hadoop counters
-   * @return a new {@link gobblin.metrics.hadoop.HadoopCounterReporter.Builder}
+   * @return a new {@link org.apache.gobblin.metrics.hadoop.HadoopCounterReporter.Builder}
    */
   public static Builder builder(String name, Reporter reporter) {
     return new Builder(name, reporter);

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-modules/gobblin-metrics-hadoop/src/main/java/org/apache/gobblin/metrics/hadoop/NewAPIHadoopCounterReporter.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/gobblin-metrics-hadoop/src/main/java/org/apache/gobblin/metrics/hadoop/NewAPIHadoopCounterReporter.java b/gobblin-modules/gobblin-metrics-hadoop/src/main/java/org/apache/gobblin/metrics/hadoop/NewAPIHadoopCounterReporter.java
index b17bb2d..54c1ead 100644
--- a/gobblin-modules/gobblin-metrics-hadoop/src/main/java/org/apache/gobblin/metrics/hadoop/NewAPIHadoopCounterReporter.java
+++ b/gobblin-modules/gobblin-metrics-hadoop/src/main/java/org/apache/gobblin/metrics/hadoop/NewAPIHadoopCounterReporter.java
@@ -28,7 +28,7 @@ import org.apache.gobblin.metrics.MetricContext;
 
 
 /**
- * An implementation of {@link gobblin.metrics.reporter.ContextAwareScheduledReporter} that reports applicable
+ * An implementation of {@link org.apache.gobblin.metrics.reporter.ContextAwareScheduledReporter} that reports applicable
  * metrics as Hadoop counters using a {@link org.apache.hadoop.mapreduce.TaskInputOutputContext}.
  *
  * @param <KI> the input key type of {@code hadoopContext}
@@ -59,7 +59,7 @@ public class NewAPIHadoopCounterReporter<KI, VI, KO, VO> extends AbstractHadoopC
   }
 
   /**
-   * Create a new {@link gobblin.metrics.hadoop.NewAPIHadoopCounterReporter.Builder}
+   * Create a new {@link org.apache.gobblin.metrics.hadoop.NewAPIHadoopCounterReporter.Builder}
    * that uses the simple name of {@link NewAPIHadoopCounterReporter} as the reporter name.
    *
    * @param hadoopContext a {@link org.apache.hadoop.mapreduce.TaskInputOutputContext}
@@ -68,7 +68,7 @@ public class NewAPIHadoopCounterReporter<KI, VI, KO, VO> extends AbstractHadoopC
    * @param <VI> the input value type of {@code hadoopContext}
    * @param <KO> the output key type of {@code hadoopContext}
    * @param <VO> the output value type of {@code hadoopContext}
-   * @return a new {@link gobblin.metrics.hadoop.NewAPIHadoopCounterReporter.Builder}
+   * @return a new {@link org.apache.gobblin.metrics.hadoop.NewAPIHadoopCounterReporter.Builder}
    */
   public static <KI, VI, KO, VO> Builder<KI, VI, KO, VO> builder(
       TaskInputOutputContext<KI, VI, KO, VO> hadoopContext) {
@@ -76,7 +76,7 @@ public class NewAPIHadoopCounterReporter<KI, VI, KO, VO> extends AbstractHadoopC
   }
 
   /**
-   * Create a new {@link gobblin.metrics.hadoop.NewAPIHadoopCounterReporter.Builder}
+   * Create a new {@link org.apache.gobblin.metrics.hadoop.NewAPIHadoopCounterReporter.Builder}
    * that uses a given reporter name.
    *
    * @param name the given reporter name
@@ -86,7 +86,7 @@ public class NewAPIHadoopCounterReporter<KI, VI, KO, VO> extends AbstractHadoopC
    * @param <VI> the input value type of {@code hadoopContext}
    * @param <KO> the output key type of {@code hadoopContext}
    * @param <VO> the output value type of {@code hadoopContext}
-   * @return a new {@link gobblin.metrics.hadoop.NewAPIHadoopCounterReporter.Builder}
+   * @return a new {@link org.apache.gobblin.metrics.hadoop.NewAPIHadoopCounterReporter.Builder}
    */
   public static <KI, VI, KO, VO> Builder<KI, VI, KO, VO> builder(String name,
       TaskInputOutputContext<KI, VI, KO, VO> hadoopContext) {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb/InfluxDBEventReporter.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb/InfluxDBEventReporter.java b/gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb/InfluxDBEventReporter.java
index 79382d9..d00d482 100644
--- a/gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb/InfluxDBEventReporter.java
+++ b/gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb/InfluxDBEventReporter.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 to InfluxDB
  *
  * @author Lorand Bendig
@@ -128,7 +128,7 @@ public class InfluxDBEventReporter extends EventReporter {
    * Returns a new {@link InfluxDBEventReporter.Builder} for {@link InfluxDBEventReporter}.
    * 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 InfluxDBEventReporter builder
    * @deprecated this method is bugged. Use {@link InfluxDBEventReporter.Factory#forContext} instead.
    */
@@ -154,7 +154,7 @@ public class InfluxDBEventReporter extends EventReporter {
      * Returns a new {@link InfluxDBEventReporter.Builder} for {@link InfluxDBEventReporter}.
      * 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 InfluxDBEventReporter builder
      */
     public static BuilderImpl forContext(MetricContext context) {
@@ -182,7 +182,7 @@ public class InfluxDBEventReporter extends EventReporter {
     }
 
     /**
-     * Set {@link gobblin.metrics.influxdb.InfluxDBPusher} to use.
+     * Set {@link org.apache.gobblin.metrics.influxdb.InfluxDBPusher} to use.
      */
     public T withInfluxDBPusher(InfluxDBPusher pusher) {
       this.influxDBPusher = Optional.of(pusher);
@@ -190,7 +190,7 @@ public class InfluxDBEventReporter extends EventReporter {
     }
 
     /**
-     * Set connection parameters for the {@link gobblin.metrics.influxdb.InfluxDBPusher} creation
+     * Set connection parameters for the {@link org.apache.gobblin.metrics.influxdb.InfluxDBPusher} creation
      */
     public T withConnection(String url, String username, String password, String database) {
       this.url = url;
@@ -201,7 +201,7 @@ public class InfluxDBEventReporter extends EventReporter {
     }
 
     /**
-     * Set {@link gobblin.metrics.influxdb.InfluxDBConnectionType} to use.
+     * Set {@link org.apache.gobblin.metrics.influxdb.InfluxDBConnectionType} to use.
      */
     public T withConnectionType(InfluxDBConnectionType connectionType) {
       this.connectionType = connectionType;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb/InfluxDBReporter.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb/InfluxDBReporter.java b/gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb/InfluxDBReporter.java
index b2a8c13..952b16f 100644
--- a/gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb/InfluxDBReporter.java
+++ b/gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb/InfluxDBReporter.java
@@ -72,7 +72,7 @@ public class InfluxDBReporter extends ConfiguredScheduledReporter {
   }
 
   /**
-   * A static factory class for obtaining new {@link gobblin.metrics.influxdb.InfluxDBReporter.Builder}s
+   * A static factory class for obtaining new {@link org.apache.gobblin.metrics.influxdb.InfluxDBReporter.Builder}s
    *
    * @see gobblin.metrics.influxdb.InfluxDBReporter.Builder
    */
@@ -115,7 +115,7 @@ public class InfluxDBReporter extends ConfiguredScheduledReporter {
     }
 
     /**
-     * Set {@link gobblin.metrics.influxdb.InfluxDBPusher} to use.
+     * Set {@link org.apache.gobblin.metrics.influxdb.InfluxDBPusher} to use.
      */
     public T withInfluxDBPusher(InfluxDBPusher pusher) {
       this.influxDBPusher = Optional.of(pusher);
@@ -123,7 +123,7 @@ public class InfluxDBReporter extends ConfiguredScheduledReporter {
     }
 
     /**
-     * Set connection parameters for the {@link gobblin.metrics.influxdb.InfluxDBPusher} creation
+     * Set connection parameters for the {@link org.apache.gobblin.metrics.influxdb.InfluxDBPusher} creation
      */
     public T withConnection(String url, String username, String password, String database) {
       this.url = url;
@@ -134,7 +134,7 @@ public class InfluxDBReporter extends ConfiguredScheduledReporter {
     }
 
     /**
-     * Set {@link gobblin.metrics.influxdb.InfluxDBConnectionType} to use.
+     * Set {@link org.apache.gobblin.metrics.influxdb.InfluxDBConnectionType} to use.
      */
     public T withConnectionType(InfluxDBConnectionType connectionType) {
       this.connectionType = connectionType;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-modules/gobblin-metrics-influxdb/src/test/java/org/apache/gobblin/metrics/influxdb/TestInfluxDB.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/gobblin-metrics-influxdb/src/test/java/org/apache/gobblin/metrics/influxdb/TestInfluxDB.java b/gobblin-modules/gobblin-metrics-influxdb/src/test/java/org/apache/gobblin/metrics/influxdb/TestInfluxDB.java
index 30bfed1..c02aab2 100644
--- a/gobblin-modules/gobblin-metrics-influxdb/src/test/java/org/apache/gobblin/metrics/influxdb/TestInfluxDB.java
+++ b/gobblin-modules/gobblin-metrics-influxdb/src/test/java/org/apache/gobblin/metrics/influxdb/TestInfluxDB.java
@@ -133,7 +133,7 @@ public class TestInfluxDB implements InfluxDB {
    * 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);

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-rest-service/gobblin-rest-client/src/main/java/org/apache/gobblin/rest/JobExecutionInfoClient.java
----------------------------------------------------------------------
diff --git a/gobblin-rest-service/gobblin-rest-client/src/main/java/org/apache/gobblin/rest/JobExecutionInfoClient.java b/gobblin-rest-service/gobblin-rest-client/src/main/java/org/apache/gobblin/rest/JobExecutionInfoClient.java
index 7993fc0..571534d 100644
--- a/gobblin-rest-service/gobblin-rest-client/src/main/java/org/apache/gobblin/rest/JobExecutionInfoClient.java
+++ b/gobblin-rest-service/gobblin-rest-client/src/main/java/org/apache/gobblin/rest/JobExecutionInfoClient.java
@@ -58,10 +58,10 @@ public class JobExecutionInfoClient implements Closeable {
   }
 
   /**
-   * Get a {@link gobblin.rest.JobExecutionQueryResult} for a {@link gobblin.rest.JobExecutionQuery}.
+   * Get a {@link org.apache.gobblin.rest.JobExecutionQueryResult} for a {@link org.apache.gobblin.rest.JobExecutionQuery}.
    *
-   * @param query a {@link gobblin.rest.JobExecutionQuery}
-   * @return a {@link gobblin.rest.JobExecutionQueryResult}
+   * @param query a {@link org.apache.gobblin.rest.JobExecutionQuery}
+   * @return a {@link org.apache.gobblin.rest.JobExecutionQueryResult}
    * @throws RemoteInvocationException
    */
   public JobExecutionQueryResult get(JobExecutionQuery query)

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-rest-service/gobblin-rest-server/src/test/java/org/apache/gobblin/rest/JobExecutionInfoServerTest.java
----------------------------------------------------------------------
diff --git a/gobblin-rest-service/gobblin-rest-server/src/test/java/org/apache/gobblin/rest/JobExecutionInfoServerTest.java b/gobblin-rest-service/gobblin-rest-server/src/test/java/org/apache/gobblin/rest/JobExecutionInfoServerTest.java
index a97b030..c3c38f4 100644
--- a/gobblin-rest-service/gobblin-rest-server/src/test/java/org/apache/gobblin/rest/JobExecutionInfoServerTest.java
+++ b/gobblin-rest-service/gobblin-rest-server/src/test/java/org/apache/gobblin/rest/JobExecutionInfoServerTest.java
@@ -43,12 +43,12 @@ import org.apache.gobblin.metastore.testing.TestMetastoreDatabaseFactory;
 
 
 /**
- * Unit tests for {@link gobblin.rest.JobExecutionInfoServer}.
+ * Unit tests for {@link org.apache.gobblin.rest.JobExecutionInfoServer}.
  *
  * <p>
- *     This test case uses {@link gobblin.rest.JobExecutionInfoClient} to talk to the
- *     {@link gobblin.rest.JobExecutionInfoServer}, which runs the Rest.li resource
- *     {@link gobblin.rest.JobExecutionInfoResource}. So this test case is also testing
+ *     This test case uses {@link org.apache.gobblin.rest.JobExecutionInfoClient} to talk to the
+ *     {@link org.apache.gobblin.rest.JobExecutionInfoServer}, which runs the Rest.li resource
+ *     {@link org.apache.gobblin.rest.JobExecutionInfoResource}. So this test case is also testing
  *     those classes.
  * </p>
  *

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowStatusResource.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowStatusResource.java b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowStatusResource.java
index a8ba987..62d3737 100644
--- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowStatusResource.java
+++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowStatusResource.java
@@ -90,9 +90,9 @@ public class FlowStatusResource extends ComplexKeyResourceTemplate<FlowStatusId,
   }
 
   /**
-   * Forms a {@link gobblin.service.FlowStatus} from a {@link gobblin.service.monitoring.FlowStatus}
+   * Forms a {@link org.apache.gobblin.service.FlowStatus} from a {@link org.apache.gobblin.service.monitoring.FlowStatus}
    * @param monitoringFlowStatus
-   * @return a {@link gobblin.service.FlowStatus} converted from a {@link gobblin.service.monitoring.FlowStatus}
+   * @return a {@link org.apache.gobblin.service.FlowStatus} converted from a {@link org.apache.gobblin.service.monitoring.FlowStatus}
    */
   private FlowStatus convertFlowStatus(gobblin.service.monitoring.FlowStatus monitoringFlowStatus) {
     if (monitoringFlowStatus == null) {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/RestliLimiterFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/RestliLimiterFactory.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/RestliLimiterFactory.java
index 66f1889..1e5a4c9 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/RestliLimiterFactory.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/RestliLimiterFactory.java
@@ -39,7 +39,7 @@ import lombok.extern.slf4j.Slf4j;
 
 
 /**
- * A {@link gobblin.util.limiter.broker.SharedLimiterFactory} that creates {@link RestliServiceBasedLimiter}s. It
+ * A {@link org.apache.gobblin.util.limiter.broker.SharedLimiterFactory} that creates {@link RestliServiceBasedLimiter}s. It
  * automatically acquires a {@link RestClient} from the broker for restli service name {@link #RESTLI_SERVICE_NAME}.
  */
 @Slf4j

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ConfigClientBasedPolicyFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ConfigClientBasedPolicyFactory.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ConfigClientBasedPolicyFactory.java
index 1d310a3..03dd27a 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ConfigClientBasedPolicyFactory.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ConfigClientBasedPolicyFactory.java
@@ -33,7 +33,7 @@ import org.apache.gobblin.util.limiter.broker.SharedLimiterKey;
 
 
 /**
- * A {@link gobblin.restli.throttling.ThrottlingPolicyFactory.SpecificPolicyFactory} that looks up policies using a
+ * A {@link org.apache.gobblin.restli.throttling.ThrottlingPolicyFactory.SpecificPolicyFactory} that looks up policies using a
  * {@link ConfigClient}.
  *
  * The config store prefix should be specified at key {@link #CONFIG_KEY_URI_PREFIX_KEY}

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/URIMetadata.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/URIMetadata.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/URIMetadata.java
index 1b3986e..1a50cc2 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/URIMetadata.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/URIMetadata.java
@@ -24,7 +24,7 @@ import lombok.Getter;
 
 
 /**
- * A {@link gobblin.restli.throttling.LeaderFinder.Metadata} that contains the {@link URI} of the process.
+ * A {@link org.apache.gobblin.restli.throttling.LeaderFinder.Metadata} that contains the {@link URI} of the process.
  */
 @AllArgsConstructor
 public class URIMetadata implements LeaderFinder.Metadata {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ZookeeperLeaderElection.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ZookeeperLeaderElection.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ZookeeperLeaderElection.java
index 7a645b7..3df28ff 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ZookeeperLeaderElection.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ZookeeperLeaderElection.java
@@ -65,7 +65,7 @@ public class ZookeeperLeaderElection<T extends LeaderFinder.Metadata> extends Ab
   /**
    * @param zkConnectString Zookeeper connect string.
    * @param clusterName Cluster name. Processes in the same cluster are identified by the cluster name.
-   * @param localMetadata {@link gobblin.restli.throttling.LeaderFinder.Metadata} for the local process.
+   * @param localMetadata {@link org.apache.gobblin.restli.throttling.LeaderFinder.Metadata} for the local process.
    * @throws IOException
    */
   public ZookeeperLeaderElection(String zkConnectString, String clusterName, T localMetadata) throws IOException {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/AbstractTaskStateTracker.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/AbstractTaskStateTracker.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/AbstractTaskStateTracker.java
index c9a0581..50ae851 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/AbstractTaskStateTracker.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/AbstractTaskStateTracker.java
@@ -95,7 +95,7 @@ public abstract class AbstractTaskStateTracker extends AbstractIdleService imple
   /**
    * A base class providing a default implementation for updating task metrics.
    *
-   * @deprecated see {@link gobblin.instrumented.writer.InstrumentedDataWriterBase}.
+   * @deprecated see {@link org.apache.gobblin.instrumented.writer.InstrumentedDataWriterBase}.
    */
   @Deprecated
   protected class TaskMetricsUpdater implements Runnable {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/BaseLimiterType.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/BaseLimiterType.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/BaseLimiterType.java
index 3ebd0f4..f88627c 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/BaseLimiterType.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/BaseLimiterType.java
@@ -18,7 +18,7 @@
 package org.apache.gobblin.runtime;
 
 /**
- * @deprecated This class has been moved to {@link gobblin.util.limiter.BaseLimiterType}.
+ * @deprecated This class has been moved to {@link org.apache.gobblin.util.limiter.BaseLimiterType}.
  */
 @Deprecated
 public enum BaseLimiterType {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/CheckpointableWatermarkState.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/CheckpointableWatermarkState.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/CheckpointableWatermarkState.java
index c96b2ff..af64323 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/CheckpointableWatermarkState.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/CheckpointableWatermarkState.java
@@ -27,7 +27,7 @@ import org.apache.gobblin.source.extractor.CheckpointableWatermark;
 
 /**
  * Making {@link CheckpointableWatermark} look like {@link State} so it can be
- * stored in a {@link gobblin.metastore.StateStore}.
+ * stored in a {@link org.apache.gobblin.metastore.StateStore}.
  */
 public class CheckpointableWatermarkState extends State {
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/CountBasedLimiter.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/CountBasedLimiter.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/CountBasedLimiter.java
index 29edfdb..f3187b0 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/CountBasedLimiter.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/CountBasedLimiter.java
@@ -21,7 +21,7 @@ package org.apache.gobblin.runtime;
 /**
  * {@inheritDoc}
  *
- * @deprecated This class has been moved to {@link gobblin.util.limiter.CountBasedLimiter}.
+ * @deprecated This class has been moved to {@link org.apache.gobblin.util.limiter.CountBasedLimiter}.
  */
 @Deprecated
 public class CountBasedLimiter extends gobblin.util.limiter.CountBasedLimiter {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/DefaultLimiterFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/DefaultLimiterFactory.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/DefaultLimiterFactory.java
index 97ea9b5..82d41cb 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/DefaultLimiterFactory.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/DefaultLimiterFactory.java
@@ -20,7 +20,7 @@ package org.apache.gobblin.runtime;
 /**
  * {@inheritDoc}
  *
- * @deprecated This class has been moved to {@link gobblin.util.limiter.DefaultLimiterFactory}.
+ * @deprecated This class has been moved to {@link org.apache.gobblin.util.limiter.DefaultLimiterFactory}.
  */
 @Deprecated
 public class DefaultLimiterFactory extends gobblin.util.limiter.DefaultLimiterFactory {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/ForkBranchMismatchException.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/ForkBranchMismatchException.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/ForkBranchMismatchException.java
index 998d4b7..14d8109 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/ForkBranchMismatchException.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/ForkBranchMismatchException.java
@@ -19,7 +19,7 @@ package org.apache.gobblin.runtime;
 
 /**
  * A type of {@link java.lang.Exception}s thrown when the number of schemas or
- * data records returned by a {@link gobblin.fork.ForkOperator}
+ * data records returned by a {@link org.apache.gobblin.fork.ForkOperator}
  * is not equal to the number of declared branches.
  *
  * @author Yinan Li

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/JobState.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/JobState.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/JobState.java
index 8584368..3bd3006 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/JobState.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/JobState.java
@@ -69,7 +69,7 @@ public class JobState extends SourceState {
 
   /**
    * An enumeration of possible job states, which are identical to
-   * {@link gobblin.configuration.WorkUnitState.WorkingState}
+   * {@link org.apache.gobblin.configuration.WorkUnitState.WorkingState}
    * in terms of naming.
    *
    * <p> Status state diagram:

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/Limiter.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/Limiter.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/Limiter.java
index 0f8540a..5184365 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/Limiter.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/Limiter.java
@@ -21,7 +21,7 @@ package org.apache.gobblin.runtime;
 /**
  * {@inheritDoc}
  *
- * @deprecated This class has been moved to {@link gobblin.util.limiter.Limiter}.
+ * @deprecated This class has been moved to {@link org.apache.gobblin.util.limiter.Limiter}.
  */
 @Deprecated
 public interface Limiter extends gobblin.util.limiter.Limiter {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/LimitingExtractorDecorator.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/LimitingExtractorDecorator.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/LimitingExtractorDecorator.java
index d05a60e..8d5b0d9 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/LimitingExtractorDecorator.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/LimitingExtractorDecorator.java
@@ -85,7 +85,7 @@ public class LimitingExtractorDecorator<S, D> implements Extractor<S, D>, Decora
   /**
    * Compose meta data when limiter fails to acquire permit
    * The meta data key list is passed from source layer
-   * A prefix matching is used because some work unit {@link gobblin.source.workunit.MultiWorkUnit} have packing strategy, which
+   * A prefix matching is used because some work unit {@link org.apache.gobblin.source.workunit.MultiWorkUnit} have packing strategy, which
    * can append additional string after the key name
    *
    * @return String map representing all the meta data need to report. Return null if no meta data was found.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/NonRefillableLimiter.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/NonRefillableLimiter.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/NonRefillableLimiter.java
index a8d149d..9361c75 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/NonRefillableLimiter.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/NonRefillableLimiter.java
@@ -21,7 +21,7 @@ package org.apache.gobblin.runtime;
 /**
  * {@inheritDoc}
  *
- * @deprecated This class has been moved to {@link gobblin.util.limiter.NonRefillableLimiter}.
+ * @deprecated This class has been moved to {@link org.apache.gobblin.util.limiter.NonRefillableLimiter}.
  */
 @Deprecated
 public abstract class NonRefillableLimiter extends gobblin.util.limiter.NonRefillableLimiter {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/PoolBasedLimiter.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/PoolBasedLimiter.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/PoolBasedLimiter.java
index 11c4b61..b73c3c0 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/PoolBasedLimiter.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/PoolBasedLimiter.java
@@ -21,7 +21,7 @@ package org.apache.gobblin.runtime;
 /**
  * {@inheritDoc}
  *
- * @deprecated This class has been moved to {@link gobblin.util.limiter.PoolBasedLimiter}.
+ * @deprecated This class has been moved to {@link org.apache.gobblin.util.limiter.PoolBasedLimiter}.
  */
 @Deprecated
 public class PoolBasedLimiter extends gobblin.util.limiter.PoolBasedLimiter {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/RateBasedLimiter.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/RateBasedLimiter.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/RateBasedLimiter.java
index 6075fba..c2b4c9a 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/RateBasedLimiter.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/RateBasedLimiter.java
@@ -23,7 +23,7 @@ import java.util.concurrent.TimeUnit;
 /**
  * {@inheritDoc}
  *
- * @deprecated This class has been moved to {@link gobblin.util.limiter.RateBasedLimiter}.
+ * @deprecated This class has been moved to {@link org.apache.gobblin.util.limiter.RateBasedLimiter}.
  */
 @Deprecated
 public class RateBasedLimiter extends gobblin.util.limiter.RateBasedLimiter {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/SourceDecorator.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/SourceDecorator.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/SourceDecorator.java
index fc60b46..9471444 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/SourceDecorator.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/SourceDecorator.java
@@ -38,8 +38,8 @@ import org.apache.gobblin.source.workunit.WorkUnitStream;
 
 
 /**
- * A decorator class for {@link gobblin.source.Source} that catches any
- * possible exceptions/errors thrown by the {@link gobblin.source.Source}.
+ * A decorator class for {@link org.apache.gobblin.source.Source} that catches any
+ * possible exceptions/errors thrown by the {@link org.apache.gobblin.source.Source}.
  *
  * @author Yinan Li
  */

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/Task.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/Task.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/Task.java
index 0ef96c0..20b183f 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/Task.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/Task.java
@@ -85,7 +85,7 @@ import org.apache.gobblin.writer.WatermarkStorage;
 
 
 /**
- * A physical unit of execution for a Gobblin {@link gobblin.source.workunit.WorkUnit}.
+ * A physical unit of execution for a Gobblin {@link org.apache.gobblin.source.workunit.WorkUnit}.
  *
  * <p>
  *     Each task is executed by a single thread in a thread pool managed by the {@link TaskExecutor}
@@ -771,9 +771,9 @@ public class Task implements TaskIFace {
   }
 
   /**
-   * Get the final state of each construct used by this task and add it to the {@link gobblin.runtime.TaskState}.
-   * @param extractor the {@link gobblin.instrumented.extractor.InstrumentedExtractorBase} used by this task.
-   * @param converter the {@link gobblin.converter.Converter} used by this task.
+   * Get the final state of each construct used by this task and add it to the {@link org.apache.gobblin.runtime.TaskState}.
+   * @param extractor the {@link org.apache.gobblin.instrumented.extractor.InstrumentedExtractorBase} used by this task.
+   * @param converter the {@link org.apache.gobblin.converter.Converter} used by this task.
    * @param rowChecker the {@link RowLevelPolicyChecker} used by this task.
    */
   private void addConstructsFinalStateToTaskState(InstrumentedExtractorBase<?, ?> extractor,

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/TaskContext.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/TaskContext.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/TaskContext.java
index 11f887d..590cdf9 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/TaskContext.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/TaskContext.java
@@ -254,7 +254,7 @@ public class TaskContext {
 
   /**
    * Get a pre-fork {@link RowLevelPolicyChecker} for executing row-level
-   * {@link gobblin.qualitychecker.row.RowLevelPolicy}.
+   * {@link org.apache.gobblin.qualitychecker.row.RowLevelPolicy}.
    *
    * @return a {@link RowLevelPolicyChecker}
    */
@@ -264,7 +264,7 @@ public class TaskContext {
 
   /**
    * Get a post-fork {@link RowLevelPolicyChecker} for executing row-level
-   * {@link gobblin.qualitychecker.row.RowLevelPolicy} in the given branch.
+   * {@link org.apache.gobblin.qualitychecker.row.RowLevelPolicy} in the given branch.
    *
    * @param index branch index
    * @return a {@link RowLevelPolicyChecker}
@@ -275,7 +275,7 @@ public class TaskContext {
 
   /**
    * Get a post-fork {@link TaskLevelPolicyChecker} for executing task-level
-   * {@link gobblin.qualitychecker.task.TaskLevelPolicy} in the given branch.
+   * {@link org.apache.gobblin.qualitychecker.task.TaskLevelPolicy} in the given branch.
    *
    * @param taskState {@link TaskState} of a {@link Task}
    * @param index branch index
@@ -298,7 +298,7 @@ public class TaskContext {
   }
 
   /**
-   * Get a {@link DataWriterBuilder} for building a {@link gobblin.writer.DataWriter}.
+   * Get a {@link DataWriterBuilder} for building a {@link org.apache.gobblin.writer.DataWriter}.
    *
    * @param branches number of forked branches
    * @param index branch index

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/TaskState.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/TaskState.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/TaskState.java
index 981aef1..6eb2f5f 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/TaskState.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/TaskState.java
@@ -64,22 +64,22 @@ public class TaskState extends WorkUnitState {
   // Built-in metric names
 
   /**
-   * @deprecated see {@link gobblin.instrumented.writer.InstrumentedDataWriterBase}.
+   * @deprecated see {@link org.apache.gobblin.instrumented.writer.InstrumentedDataWriterBase}.
    */
   private static final String RECORDS = "records";
 
   /**
-   * @deprecated see {@link gobblin.instrumented.writer.InstrumentedDataWriterBase}.
+   * @deprecated see {@link org.apache.gobblin.instrumented.writer.InstrumentedDataWriterBase}.
    */
   private static final String RECORDS_PER_SECOND = "recordsPerSec";
 
   /**
-   * @deprecated see {@link gobblin.instrumented.writer.InstrumentedDataWriterBase}.
+   * @deprecated see {@link org.apache.gobblin.instrumented.writer.InstrumentedDataWriterBase}.
    */
   private static final String BYTES = "bytes";
 
   /**
-   * @deprecated see {@link gobblin.instrumented.writer.InstrumentedDataWriterBase}.
+   * @deprecated see {@link org.apache.gobblin.instrumented.writer.InstrumentedDataWriterBase}.
    */
   private static final String BYTES_PER_SECOND = "bytesPerSec";
 
@@ -249,7 +249,7 @@ public class TaskState extends WorkUnitState {
    * @param recordsWritten number of records written by the writer
    * @param branchIndex fork branch index
    *
-   * @deprecated see {@link gobblin.instrumented.writer.InstrumentedDataWriterBase}.
+   * @deprecated see {@link org.apache.gobblin.instrumented.writer.InstrumentedDataWriterBase}.
    */
   public synchronized void updateRecordMetrics(long recordsWritten, int branchIndex) {
     TaskMetrics metrics = TaskMetrics.get(this);
@@ -271,7 +271,7 @@ public class TaskState extends WorkUnitState {
    * @param bytesWritten number of bytes written by the writer
    * @param branchIndex fork branch index
    *
-   * @deprecated see {@link gobblin.instrumented.writer.InstrumentedDataWriterBase}.
+   * @deprecated see {@link org.apache.gobblin.instrumented.writer.InstrumentedDataWriterBase}.
    */
   public synchronized void updateByteMetrics(long bytesWritten, int branchIndex) {
     TaskMetrics metrics = TaskMetrics.get(this);

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/TimeBasedLimiter.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/TimeBasedLimiter.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/TimeBasedLimiter.java
index cf8a03c..ec11e5c 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/TimeBasedLimiter.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/TimeBasedLimiter.java
@@ -23,7 +23,7 @@ import java.util.concurrent.TimeUnit;
 /**
  * {@inheritDoc}
  *
- * @deprecated This class has been moved to {@link gobblin.util.limiter.TimeBasedLimiter}.
+ * @deprecated This class has been moved to {@link org.apache.gobblin.util.limiter.TimeBasedLimiter}.
  */
 @Deprecated
 public class TimeBasedLimiter extends gobblin.util.limiter.TimeBasedLimiter {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/FlowSpec.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/FlowSpec.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/FlowSpec.java
index 79a4cb2..e7c08d2 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/FlowSpec.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/FlowSpec.java
@@ -67,7 +67,7 @@ public class FlowSpec implements Configurable, Spec {
   // config. We use it as a cache until typesafe config is more widely adopted in Gobblin.
   final Properties configAsProperties;
 
-  /** URI of {@link gobblin.runtime.api.JobTemplate} to use. */
+  /** URI of {@link org.apache.gobblin.runtime.api.JobTemplate} to use. */
   final Optional<Set<URI>> templateURIs;
 
   /** Child {@link Spec}s to this {@link FlowSpec} **/

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpec.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpec.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpec.java
index 5c1158f..0ae943e 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpec.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpec.java
@@ -61,7 +61,7 @@ public class JobSpec implements Configurable, Spec {
   // Note that this property is not strictly necessary as it can be generated from the typesafe
   // config. We use it as a cache until typesafe config is more widely adopted in Gobblin.
   Properties configAsProperties;
-  /** URI of {@link gobblin.runtime.api.JobTemplate} to use. */
+  /** URI of {@link org.apache.gobblin.runtime.api.JobTemplate} to use. */
   Optional<URI> templateURI;
 
   public static Builder builder(URI jobSpecUri) {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/package-info.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/package-info.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/package-info.java
index 755c5b5..25f8807 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/package-info.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/package-info.java
@@ -23,12 +23,12 @@
  *  <dd>A self-contained context for running alike Gobblin jobs. These jobs share location where
  *  they are stored and managed, how they are scheduled, and how they are run.
  *     <dl>
- *      <dt>Gobblin instance driver ({@link gobblin.runtime.api.GobblinInstanceDriver})</dt>
+ *      <dt>Gobblin instance driver ({@link org.apache.gobblin.runtime.api.GobblinInstanceDriver})</dt>
  *      <dd>Starts all global Gobblin services, instantiates Job Catalog, Job Launcher, and scheduler.
  *          Interprets job specs to schedule via the executor or run immediately. (Similar to original
  *          JobScheduler class).</dd>
  *     </dl>
- *      <dt>Gobblin instance launcher ({@link gobblin.runtime.api.GobblinInstanceLauncher})<dt>
+ *      <dt>Gobblin instance launcher ({@link org.apache.gobblin.runtime.api.GobblinInstanceLauncher})<dt>
  *      <dd>Main class instantiated by the JVM or running framework. Reads application level
  *          configurations, instantiates and runs the Gobblin instance driver.
  *          Examples: JavaMainAppLauncher (original SchedulerDaemon), AzkabanAppLauncher (original
@@ -44,24 +44,24 @@
  *      <dt>JobExecution Driver</dt>
  *      <dd>Executes the job and its tasks. This can be done locally in a thread-pool,
  *          or as a M/R job, as a Yarn job using the Helix task execution framework, etc. This
- *          concept replaces the previous {@link gobblin.runtime.JobLauncher}. </dd>
- *      <dt>JobExecution Launcher ({@link gobblin.runtime.api.JobExecutionLauncher})</dt>
+ *          concept replaces the previous {@link org.apache.gobblin.runtime.JobLauncher}. </dd>
+ *      <dt>JobExecution Launcher ({@link org.apache.gobblin.runtime.api.JobExecutionLauncher})</dt>
  *      <dd>Instantiates the JobExecution Driver. The driver may be instantiated locally, or it
  *      can be launched in a remote container (similarly to Oozie). JobExecutionLauncher should not
- *      be confused with the legacy {@link gobblin.runtime.JobLauncher}. Essentially, we decided to
+ *      be confused with the legacy {@link org.apache.gobblin.runtime.JobLauncher}. Essentially, we decided to
  *      roughly split the JobLauncher into JobExecutionLauncher and a JobExecutionDriver. This
  *      allows us to abstract the aspect of instantiating and running the JobExecutionDriver. Thus,
  *      we have the option of running the driver locally or remotely. </dd>
  *    </dl>
  *  </dd>
- *  <dt>Job catalog ({@link gobblin.runtime.api.JobCatalog})</dt>
+ *  <dt>Job catalog ({@link org.apache.gobblin.runtime.api.JobCatalog})</dt>
  *  <dd>Maintains the collection of JobSpecs known to a specific Gobblin instance.
  *    <dl>
- *      <dt>JobSpec Monitor ({@link gobblin.runtime.api.JobSpecMonitorFactory})</dt>
+ *      <dt>JobSpec Monitor ({@link org.apache.gobblin.runtime.api.JobSpecMonitorFactory})</dt>
  *      <dd>Discovers jobs to execute and generates job specs for each one.</dd>
  *    </dl>
  *  </dd>
- *  <dt>Job Scheduler ({@link gobblin.runtime.api.JobSpecScheduler})</dt>
+ *  <dt>Job Scheduler ({@link org.apache.gobblin.runtime.api.JobSpecScheduler})</dt>
  *  <dd>A pluggable scheduler implementation that triggers job executions on a schedule.
  *  Examples: Quartz, pass-through.
  *  </dd>

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/cli/PasswordManagerCLI.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/cli/PasswordManagerCLI.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/cli/PasswordManagerCLI.java
index d9d0412..cb9f594 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/cli/PasswordManagerCLI.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/cli/PasswordManagerCLI.java
@@ -22,7 +22,7 @@ import org.apache.gobblin.util.CLIPasswordEncryptor;
 
 
 /**
- * An application that uses {@link gobblin.password.PasswordManager} to encrypt and decrypt strings.
+ * An application that uses {@link org.apache.gobblin.password.PasswordManager} to encrypt and decrypt strings.
  */
 @Alias(value = "passwordManager", description = "Encrypt or decrypt strings for the password manager.")
 public class PasswordManagerCLI implements CliApplication {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblin.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblin.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblin.java
index aef1626..a78b149 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblin.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblin.java
@@ -227,7 +227,7 @@ public class EmbeddedGobblin {
   }
 
   /**
-   * Use a {@link gobblin.runtime.api.GobblinInstancePlugin}.
+   * Use a {@link org.apache.gobblin.runtime.api.GobblinInstancePlugin}.
    */
   public EmbeddedGobblin usePlugin(GobblinInstancePluginFactory pluginFactory) {
     this.plugins.add(pluginFactory);
@@ -235,7 +235,7 @@ public class EmbeddedGobblin {
   }
 
   /**
-   * Use a {@link gobblin.runtime.api.GobblinInstancePlugin} identified by name.
+   * Use a {@link org.apache.gobblin.runtime.api.GobblinInstancePlugin} identified by name.
    */
   public EmbeddedGobblin usePlugin(String pluginAlias) throws ClassNotFoundException, IllegalAccessException, InstantiationException {
     return usePlugin(GobblinInstancePluginUtils.instantiatePluginByAlias(pluginAlias));
@@ -372,7 +372,7 @@ public class EmbeddedGobblin {
 
   /**
    * This is the base {@link Config} used for the job, containing all default configurations. Subclasses can override
-   * default configurations (for example setting a particular {@link gobblin.runtime.JobLauncherFactory.JobLauncherType}.
+   * default configurations (for example setting a particular {@link org.apache.gobblin.runtime.JobLauncherFactory.JobLauncherType}.
    */
   protected Config getDefaultSysConfig() {
     return ConfigFactory.parseResources("embedded/embedded.conf");
@@ -566,7 +566,7 @@ public class EmbeddedGobblin {
   }
 
   /**
-   * A {@link gobblin.runtime.api.JobLifecycleListener} that listens for a particular job and detects the start of the job.
+   * A {@link org.apache.gobblin.runtime.api.JobLifecycleListener} that listens for a particular job and detects the start of the job.
    */
   private static class EmbeddedJobLifecycleListener extends DefaultJobLifecycleListenerImpl {
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/fork/Fork.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/fork/Fork.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/fork/Fork.java
index e38689f..d7897b0 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/fork/Fork.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/fork/Fork.java
@@ -243,7 +243,7 @@ public class Fork<S, D> implements Closeable, FinalState, RecordStreamConsumer<S
   /**
    * {@inheritDoc}.
    *
-   * @return a {@link gobblin.configuration.State} object storing merged final states of constructs
+   * @return a {@link org.apache.gobblin.configuration.State} object storing merged final states of constructs
    *         used in this {@link Fork}
    */
   @Override
@@ -499,7 +499,7 @@ public class Fork<S, D> implements Closeable, FinalState, RecordStreamConsumer<S
   }
 
   /**
-   * Build a {@link gobblin.writer.DataWriter} for writing fetched data records.
+   * Build a {@link org.apache.gobblin.writer.DataWriter} for writing fetched data records.
    */
   private DataWriter<Object> buildWriter()
       throws IOException {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/StaticJobCatalog.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/StaticJobCatalog.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/StaticJobCatalog.java
index 1f75f80..80d5955 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/StaticJobCatalog.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/StaticJobCatalog.java
@@ -34,7 +34,7 @@ import org.apache.gobblin.runtime.api.JobSpecNotFoundException;
 
 
 /**
- * A {@link gobblin.runtime.api.JobCatalog} with a static collection of {@link JobSpec}s defined at construction time.
+ * A {@link org.apache.gobblin.runtime.api.JobCatalog} with a static collection of {@link JobSpec}s defined at construction time.
  */
 public class StaticJobCatalog extends JobCatalogBase {
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_exec/package-info.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_exec/package-info.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_exec/package-info.java
index d4dd507..96fcf80 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_exec/package-info.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_exec/package-info.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 /**
- * Standard {@link gobblin.runtime.api.JobExecutionLauncher} implementations
+ * Standard {@link org.apache.gobblin.runtime.api.JobExecutionLauncher} implementations
  *
  */
 package org.apache.gobblin.runtime.job_exec;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/local/LocalJobLauncher.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/local/LocalJobLauncher.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/local/LocalJobLauncher.java
index 4e782d5..ac3671b 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/local/LocalJobLauncher.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/local/LocalJobLauncher.java
@@ -52,7 +52,7 @@ import org.apache.gobblin.runtime.util.MultiWorkUnitUnpackingIterator;
 import org.apache.gobblin.source.workunit.WorkUnitStream;
 
 /**
- * An implementation of {@link gobblin.runtime.JobLauncher} for launching and running jobs
+ * An implementation of {@link org.apache.gobblin.runtime.JobLauncher} for launching and running jobs
  * locally on a single node.
  *
  * @author Yinan Li

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/GobblinOutputCommitter.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/GobblinOutputCommitter.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/GobblinOutputCommitter.java
index 9139f5b..65401c0 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/GobblinOutputCommitter.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/GobblinOutputCommitter.java
@@ -54,7 +54,7 @@ import lombok.Getter;
  * Hadoop {@link OutputCommitter} implementation that overrides the default
  * {@link #abortJob(JobContext, org.apache.hadoop.mapreduce.JobStatus.State)} behavior.
  * This is necessary to add functionality for cleaning up staging data when the
- * {@link gobblin.runtime.JobLauncher#cancelJob(JobListener)} method is
+ * {@link org.apache.gobblin.runtime.JobLauncher#cancelJob(JobListener)} method is
  * called via Azkaban. Azkaban only allows the cancel method run to for 5 ms until it
  * does a hard kill on the process. In order to make sure the staging data still gets
  * cleaned-up, the cleanup will take place in the AM.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncher.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncher.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncher.java
index c94577c..dcb6a14 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncher.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncher.java
@@ -510,7 +510,7 @@ public class MRJobLauncher extends AbstractJobLauncher {
   }
 
   /**
-   * Create a {@link gobblin.metrics.GobblinMetrics} instance for this job run from the Hadoop counters.
+   * Create a {@link org.apache.gobblin.metrics.GobblinMetrics} instance for this job run from the Hadoop counters.
    */
   @VisibleForTesting
   void countersToMetrics(GobblinMetrics metrics)

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRTaskStateTracker.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRTaskStateTracker.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRTaskStateTracker.java
index 37d3dea..95d701c 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRTaskStateTracker.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRTaskStateTracker.java
@@ -41,7 +41,7 @@ import org.apache.gobblin.source.workunit.WorkUnit;
 
 
 /**
- * A concrete extension to {@link gobblin.runtime.AbstractTaskStateTracker} for Hadoop MapReduce based runtime.
+ * A concrete extension to {@link org.apache.gobblin.runtime.AbstractTaskStateTracker} for Hadoop MapReduce based runtime.
  *
  * @author Yinan Li
  */

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/metrics/RuntimeMetrics.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/metrics/RuntimeMetrics.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/metrics/RuntimeMetrics.java
index eca80aa..9ed280e 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/metrics/RuntimeMetrics.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/metrics/RuntimeMetrics.java
@@ -18,7 +18,7 @@
 package org.apache.gobblin.runtime.metrics;
 
 /**
- * Constants used for naming {@link gobblin.metrics.Metric}s and metric metadata in gobblin-runtime.
+ * Constants used for naming {@link org.apache.gobblin.metrics.Metric}s and metric metadata in gobblin-runtime.
  */
 public class RuntimeMetrics {
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/plugins/PluginStaticKeys.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/plugins/PluginStaticKeys.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/plugins/PluginStaticKeys.java
index 937e195..51e3d2b 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/plugins/PluginStaticKeys.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/plugins/PluginStaticKeys.java
@@ -18,7 +18,7 @@
 package org.apache.gobblin.runtime.plugins;
 
 /**
- * Static keys for {@link gobblin.runtime.api.GobblinInstancePlugin}s.
+ * Static keys for {@link org.apache.gobblin.runtime.api.GobblinInstancePlugin}s.
  */
 public class PluginStaticKeys {
   public static final String HADOOP_LOGIN_FROM_KEYTAB_ALIAS = "hadoopLoginFromKeytab";

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskFactory.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskFactory.java
index 2166625..4abe7e2 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskFactory.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskFactory.java
@@ -34,7 +34,7 @@ public interface TaskFactory {
   TaskIFace createTask(TaskContext taskContext);
 
   /**
-   * Build a {@link DataPublisher} for the input {@link gobblin.runtime.JobState.DatasetState}.
+   * Build a {@link DataPublisher} for the input {@link org.apache.gobblin.runtime.JobState.DatasetState}.
    */
   DataPublisher createDataPublisher(JobState.DatasetState datasetState);
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/HOCONInputStreamJobTemplate.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/HOCONInputStreamJobTemplate.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/HOCONInputStreamJobTemplate.java
index c792d7b..a1337fd 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/HOCONInputStreamJobTemplate.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/HOCONInputStreamJobTemplate.java
@@ -35,7 +35,7 @@ import lombok.extern.slf4j.Slf4j;
 
 
 /**
- * A {@link gobblin.runtime.api.JobTemplate} that loads a HOCON file as a {@link StaticJobTemplate}.
+ * A {@link org.apache.gobblin.runtime.api.JobTemplate} that loads a HOCON file as a {@link StaticJobTemplate}.
  */
 @Slf4j
 public class HOCONInputStreamJobTemplate extends StaticJobTemplate {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/ResourceBasedJobTemplate.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/ResourceBasedJobTemplate.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/ResourceBasedJobTemplate.java
index 5fab14a..54b1bfc 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/ResourceBasedJobTemplate.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/ResourceBasedJobTemplate.java
@@ -33,7 +33,7 @@ import lombok.extern.slf4j.Slf4j;
 
 
 /**
- * A {@link gobblin.runtime.api.JobTemplate} that reads the template information from a resources file.
+ * A {@link org.apache.gobblin.runtime.api.JobTemplate} that reads the template information from a resources file.
  *
  * This class is final because otherwise we could not guarantee the {@link InputStream} to be closed if the super
  * constructor throws an exception.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/JobStateToJsonConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/JobStateToJsonConverter.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/JobStateToJsonConverter.java
index 8497350..5860daa 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/JobStateToJsonConverter.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/JobStateToJsonConverter.java
@@ -50,7 +50,7 @@ import org.apache.gobblin.util.JobConfigurationUtils;
 
 
 /**
- * A utility class for converting a {@link gobblin.runtime.JobState} object to a json-formatted document.
+ * A utility class for converting a {@link org.apache.gobblin.runtime.JobState} object to a json-formatted document.
  *
  * @author Yinan Li
  */

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/main/java/org/apache/gobblin/util/SchedulerUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/util/SchedulerUtils.java b/gobblin-runtime/src/main/java/org/apache/gobblin/util/SchedulerUtils.java
index 5406e0f..1174c62 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/util/SchedulerUtils.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/util/SchedulerUtils.java
@@ -143,7 +143,7 @@ public class SchedulerUtils {
    * {@link PathAlterationObserverScheduler}.
    *
    * @param monitor a {@link PathAlterationObserverScheduler}
-   * @param listener a {@link gobblin.util.filesystem.PathAlterationListener}
+   * @param listener a {@link org.apache.gobblin.util.filesystem.PathAlterationListener}
    * @param rootDirPath root directory
    */
   public static void addPathAlterationObserver(PathAlterationObserverScheduler monitor, PathAlterationListener listener,

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncherTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncherTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncherTest.java
index cd7af9d..1792468 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncherTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncherTest.java
@@ -247,7 +247,7 @@ public class MRJobLauncherTest extends BMNGRunner {
    * Seems setting mapreduce.map.failures.maxpercent=100 does not prevent Hadoop2's LocalJobRunner from
    * failing and aborting a job if any mapper task fails. Aborting the job causes its working directory
    * to be deleted in {@link GobblinOutputCommitter}, which further fails this test since all the output
-   * {@link gobblin.runtime.TaskState}s are deleted. There may be a bug in Hadoop2's LocalJobRunner.
+   * {@link org.apache.gobblin.runtime.TaskState}s are deleted. There may be a bug in Hadoop2's LocalJobRunner.
    *
    * Also applicable to the two tests below.
    */

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/test/java/org/apache/gobblin/scheduler/JobConfigFileMonitorTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/scheduler/JobConfigFileMonitorTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/scheduler/JobConfigFileMonitorTest.java
index 5d5025e..8b8c41b 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/scheduler/JobConfigFileMonitorTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/scheduler/JobConfigFileMonitorTest.java
@@ -47,7 +47,7 @@ import org.apache.gobblin.testing.AssertWithBackoff;
 
 
 /**
- * Unit tests for the job configuration file monitor in {@link gobblin.scheduler.JobScheduler}.
+ * Unit tests for the job configuration file monitor in {@link org.apache.gobblin.scheduler.JobScheduler}.
  *
  * @author Yinan Li
  */

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestConverter2.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestConverter2.java b/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestConverter2.java
index b28117b..f8e5684 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestConverter2.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestConverter2.java
@@ -39,7 +39,7 @@ import org.apache.gobblin.fork.CopyableSchema;
 
 /**
  * An implementation of {@link Converter} for tests related to the
- * {@link gobblin.fork.ForkOperator}.
+ * {@link org.apache.gobblin.fork.ForkOperator}.
  *
  * @author Yinan Li
  */

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/Tunnel.java
----------------------------------------------------------------------
diff --git a/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/Tunnel.java b/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/Tunnel.java
index c1866fd..3cab263 100644
--- a/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/Tunnel.java
+++ b/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/Tunnel.java
@@ -39,8 +39,8 @@ import org.apache.gobblin.util.ExecutorsUtils;
  * support the concept of "proxies", let alone HTTP proxies, and hence a solution is needed to enable this.
  *
  * This class provides a method of tunneling arbitrary protocols like JDBC connections over an HTTP proxy. Note that
- * while it is currently only implemented for JDBC (see {@link gobblin.source.jdbc.JdbcExtractor} and
- * {@link gobblin.source.jdbc.JdbcExtractor}), it can be extended to work with any other
+ * while it is currently only implemented for JDBC (see {@link org.apache.gobblin.source.jdbc.JdbcExtractor} and
+ * {@link org.apache.gobblin.source.jdbc.JdbcExtractor}), it can be extended to work with any other
  * TCP-based protocol.
  *
  * The way the Tunnel works is as follows:

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-utility/src/main/java/org/apache/gobblin/broker/BrokerConfigurationKeyGenerator.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/broker/BrokerConfigurationKeyGenerator.java b/gobblin-utility/src/main/java/org/apache/gobblin/broker/BrokerConfigurationKeyGenerator.java
index 6deb3dd..e335c9f 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/broker/BrokerConfigurationKeyGenerator.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/broker/BrokerConfigurationKeyGenerator.java
@@ -28,7 +28,7 @@ import lombok.Builder;
 
 
 /**
- * Generates key strings that the default {@link gobblin.broker.iface.SharedResourcesBroker} can understand. Useful
+ * Generates key strings that the default {@link org.apache.gobblin.broker.iface.SharedResourcesBroker} can understand. Useful
  * for populating a configuration programmatically.
  */
 public class BrokerConfigurationKeyGenerator {
@@ -36,7 +36,7 @@ public class BrokerConfigurationKeyGenerator {
   private static final Joiner JOINER = Joiner.on(".").skipNulls();
 
   /**
-   * Generate a {@link gobblin.broker.iface.SharedResourcesBroker} configuration key for a particular {@link SharedResourceFactory},
+   * Generate a {@link org.apache.gobblin.broker.iface.SharedResourcesBroker} configuration key for a particular {@link SharedResourceFactory},
    * {@link SharedResourceKey} and {@link ScopeType}.
    *
    * Example:

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-utility/src/main/java/org/apache/gobblin/broker/SharedResourcesBrokerFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/broker/SharedResourcesBrokerFactory.java b/gobblin-utility/src/main/java/org/apache/gobblin/broker/SharedResourcesBrokerFactory.java
index 3b8726d..06d705a 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/broker/SharedResourcesBrokerFactory.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/broker/SharedResourcesBrokerFactory.java
@@ -34,7 +34,7 @@ import org.apache.gobblin.util.ConfigUtils;
 
 
 /**
- * Used to create a default implementation of {@link gobblin.broker.iface.SharedResourcesBroker}.
+ * Used to create a default implementation of {@link org.apache.gobblin.broker.iface.SharedResourcesBroker}.
  *
  * All {@link SharedResourcesBroker}s created by this factory automatically load a set of configurations. In order of
  * preference:

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-utility/src/main/java/org/apache/gobblin/broker/SharedResourcesBrokerImpl.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/broker/SharedResourcesBrokerImpl.java b/gobblin-utility/src/main/java/org/apache/gobblin/broker/SharedResourcesBrokerImpl.java
index 2287922..97f401f 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/broker/SharedResourcesBrokerImpl.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/broker/SharedResourcesBrokerImpl.java
@@ -111,7 +111,7 @@ public class SharedResourcesBrokerImpl<S extends ScopeType<S>> implements Shared
   }
 
   /**
-   * Get a {@link gobblin.broker.iface.ConfigView} for the input scope, key, and factory.
+   * Get a {@link org.apache.gobblin.broker.iface.ConfigView} for the input scope, key, and factory.
    */
   public <K extends SharedResourceKey> KeyedScopedConfigViewImpl<S, K> getConfigView(S scope, K key, String factoryName) {
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-utility/src/main/java/org/apache/gobblin/broker/SharedResourcesBrokerUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/broker/SharedResourcesBrokerUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/broker/SharedResourcesBrokerUtils.java
index d8414da..e66ad7c 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/broker/SharedResourcesBrokerUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/broker/SharedResourcesBrokerUtils.java
@@ -31,7 +31,7 @@ import org.apache.gobblin.broker.iface.ScopeType;
 
 
 /**
- * General utilities for {@link gobblin.broker.iface.SharedResourcesBroker} functionality.
+ * General utilities for {@link org.apache.gobblin.broker.iface.SharedResourcesBroker} functionality.
  */
 public class SharedResourcesBrokerUtils {
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-utility/src/main/java/org/apache/gobblin/broker/package-info.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/broker/package-info.java b/gobblin-utility/src/main/java/org/apache/gobblin/broker/package-info.java
index 64e49de..e2dcfe4 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/broker/package-info.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/broker/package-info.java
@@ -16,29 +16,29 @@
  */
 
 /**
- * A {@link gobblin.broker.iface.SharedResourcesBroker} is an object that provides and manages objects that are accessed
+ * A {@link org.apache.gobblin.broker.iface.SharedResourcesBroker} is an object that provides and manages objects that are accessed
  * from multiple points in the application, allowing disconnected components to use shared objects, as well as easy user
  * configuration for those objects.
  *
  * As a model, consider file handles for emitting logs. Multiple tasks in the application might need to access a global log
- * file, or each task might have its own log file. To use a {@link gobblin.broker.iface.SharedResourcesBroker}, a task
- * creates a factory (see {@link gobblin.broker.iface.SharedResourceFactory}), in this case a log file handle factory.
+ * file, or each task might have its own log file. To use a {@link org.apache.gobblin.broker.iface.SharedResourcesBroker}, a task
+ * creates a factory (see {@link org.apache.gobblin.broker.iface.SharedResourceFactory}), in this case a log file handle factory.
  * To acquire the file handle, the task sends a request to
- * the broker providing the log file handle factory and a {@link gobblin.broker.iface.SharedResourceKey} (a discriminator between
+ * the broker providing the log file handle factory and a {@link org.apache.gobblin.broker.iface.SharedResourceKey} (a discriminator between
  * different objects created by the same factory, in the case of the log file handle, the key could specify whether we
  * need an error log handle or an info file handle). The broker has a cache of already created objects, and will either
  * return the same object if one matches the task's request, or will use the factory to create a new object.
  *
- * Brokers and the objects cached in them are scoped (see {@link gobblin.broker.iface.ScopeType} and
- * {@link gobblin.broker.iface.ScopeInstance}). Scoping allows the application to provide information to the broker
+ * Brokers and the objects cached in them are scoped (see {@link org.apache.gobblin.broker.iface.ScopeType} and
+ * {@link org.apache.gobblin.broker.iface.ScopeInstance}). Scoping allows the application to provide information to the broker
  * about its topology, and allows different scopes to get different objects. In the log file handle example, there might
  * be a different handle per task, so all calls withing the same task will get the same handle, while calls from different
  * tasks will get a different broker. In the most common use case, the task need not worry about scopes, as the
  * factory automatically determines which scope the handle should be created on. However, scoped requests are also
  * available, where a task can request an object at a specified scope.
  *
- * When creating a new object, the broker passes a configuration to the factory (see {@link gobblin.broker.iface.ConfigView}
- * and {@link gobblin.broker.iface.ScopedConfigView}), allowing users to globally change the
+ * When creating a new object, the broker passes a configuration to the factory (see {@link org.apache.gobblin.broker.iface.ConfigView}
+ * and {@link org.apache.gobblin.broker.iface.ScopedConfigView}), allowing users to globally change the
  * behavior of shared resources transparently to the task. Users can specify configurations for specific factories, scopes,
  * and keys (for example, the location of the log file could be settable through configuration, and user can specify
  * a different location for global and task scope logs).

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-utility/src/main/java/org/apache/gobblin/util/DatePartitionType.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/DatePartitionType.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/DatePartitionType.java
index f48bce1..a2be0bd 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/DatePartitionType.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/DatePartitionType.java
@@ -21,8 +21,8 @@ import org.joda.time.chrono.ISOChronology;
 
 
 /**
- * Temporal granularity types for writing ({@link gobblin.writer.partitioner.TimeBasedWriterPartitioner}) and reading
- * ({@link gobblin.source.DatePartitionedAvroFileSource}) date partitioned data.
+ * Temporal granularity types for writing ({@link org.apache.gobblin.writer.partitioner.TimeBasedWriterPartitioner}) and reading
+ * ({@link org.apache.gobblin.source.DatePartitionedAvroFileSource}) date partitioned data.
  *
  * @author Lorand Bendig
  *

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-utility/src/main/java/org/apache/gobblin/util/ForkOperatorUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/ForkOperatorUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/ForkOperatorUtils.java
index ce7df72..aee9fb7 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/ForkOperatorUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/ForkOperatorUtils.java
@@ -28,7 +28,7 @@ import org.apache.gobblin.configuration.WorkUnitState;
 
 
 /**
- * Utility class for use with the {@link gobblin.fork.ForkOperator} class.
+ * Utility class for use with the {@link org.apache.gobblin.fork.ForkOperator} class.
  *
  * @author Yinan Li
  */
@@ -64,8 +64,8 @@ public class ForkOperatorUtils {
    * Get a new property key from an original one based on the branch id. The method assumes the branch id specified by
    * the {@link ConfigurationKeys#FORK_BRANCH_ID_KEY} parameter in the given WorkUnitState. The fork id key specifies
    * which fork this parameter belongs to. Note this method will only provide the aforementioned functionality for
-   * {@link gobblin.converter.Converter}s. To get the same functionality in {@link gobblin.writer.DataWriter}s use
-   * the {@link gobblin.writer.DataWriterBuilder#forBranch(int)} to construct a writer with a specific branch id.
+   * {@link org.apache.gobblin.converter.Converter}s. To get the same functionality in {@link org.apache.gobblin.writer.DataWriter}s use
+   * the {@link org.apache.gobblin.writer.DataWriterBuilder#forBranch(int)} to construct a writer with a specific branch id.
    *
    * @param workUnitState contains the fork id key
    * @param key           property key

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-utility/src/main/java/org/apache/gobblin/util/JobLauncherUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/JobLauncherUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/JobLauncherUtils.java
index 8bcb71f..df4d73a 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/JobLauncherUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/JobLauncherUtils.java
@@ -78,7 +78,7 @@ public class JobLauncherUtils {
   }
 
   /**
-   * Create an ID for a new multi-task (corresponding to a {@link gobblin.source.workunit.MultiWorkUnit})
+   * Create an ID for a new multi-task (corresponding to a {@link org.apache.gobblin.source.workunit.MultiWorkUnit})
    * for the job with the given job ID.
    *
    * @param jobId job ID

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-utility/src/main/java/org/apache/gobblin/util/ProxiedFileSystemUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/ProxiedFileSystemUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/ProxiedFileSystemUtils.java
index e8f9fcc..3626199 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/ProxiedFileSystemUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/ProxiedFileSystemUtils.java
@@ -48,7 +48,7 @@ import org.apache.gobblin.configuration.State;
  * access any operations on behalf of the specified user.
  *
  * <p>
- *   As a user, use methods in {@link gobblin.util.ProxiedFileSystemCache} to generate the proxied file systems.
+ *   As a user, use methods in {@link org.apache.gobblin.util.ProxiedFileSystemCache} to generate the proxied file systems.
  * </p>
  *
  * @see <a href="http://hadoop.apache.org/docs/r1.2.1/Secure_Impersonation.html">Secure Impersonation</a>,

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-utility/src/main/java/org/apache/gobblin/util/ProxiedFileSystemWrapper.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/ProxiedFileSystemWrapper.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/ProxiedFileSystemWrapper.java
index d3bd8e3..573e901 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/ProxiedFileSystemWrapper.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/ProxiedFileSystemWrapper.java
@@ -51,7 +51,7 @@ public class ProxiedFileSystemWrapper {
 
   /**
    * Two authentication types for Hadoop Security, through TOKEN or KEYTAB.
-   * @deprecated Use {@link gobblin.util.ProxiedFileSystemUtils.AuthType}.
+   * @deprecated Use {@link org.apache.gobblin.util.ProxiedFileSystemUtils.AuthType}.
    */
   @Deprecated
   public enum AuthType {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-utility/src/main/java/org/apache/gobblin/util/RateControlledFileSystem.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/RateControlledFileSystem.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/RateControlledFileSystem.java
index 3146591..f9c1b7d 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/RateControlledFileSystem.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/RateControlledFileSystem.java
@@ -33,20 +33,20 @@ import org.apache.gobblin.util.limiter.RateBasedLimiter;
 
 
 /**
- * Subclass of {@link org.apache.hadoop.fs.FileSystem} that wraps with a {@link gobblin.util.limiter.Limiter}
+ * Subclass of {@link org.apache.hadoop.fs.FileSystem} that wraps with a {@link org.apache.gobblin.util.limiter.Limiter}
  * to control HDFS call rate.
  *
  *  <p>
  *  This classes uses Guava's {@link Cache} for storing {@link org.apache.hadoop.fs.FileSystem} URI to
- *  {@link gobblin.util.limiter.Limiter} mapping.
+ *  {@link org.apache.gobblin.util.limiter.Limiter} mapping.
  *  </p>
  *
  *  <p>
- *  For methods that require HDFS calls, this class will first acquire a permit using {@link gobblin.util.limiter.Limiter},
+ *  For methods that require HDFS calls, this class will first acquire a permit using {@link org.apache.gobblin.util.limiter.Limiter},
  *  to make sure HDFS call rate is allowed by the uppper limit.
  *  </p>
  *
- *  @deprecated use {@link gobblin.util.filesystem.ThrottledFileSystem}
+ *  @deprecated use {@link org.apache.gobblin.util.filesystem.ThrottledFileSystem}
  */
 @Deprecated
 public class RateControlledFileSystem extends ThrottledFileSystem {


Mime
View raw message