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 {
