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:03 UTC
[45/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-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 {