gobblin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a...@apache.org
Subject [49/77] [abbrv] incubator-gobblin git commit: Changed JavaDocs references from gobblin to org.apache.gobblin package
Date Mon, 31 Jul 2017 07:53:07 GMT
Changed JavaDocs references from gobblin to org.apache.gobblin package


Project: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/commit/177a42de
Tree: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/tree/177a42de
Diff: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/diff/177a42de

Branch: refs/heads/master
Commit: 177a42de4f49ed3e8b7b06693d8f9715a31be26f
Parents: 68fadf9
Author: Abhishek Tiwari <abhishektiwari.btech@gmail.com>
Authored: Sun Jul 30 18:47:31 2017 -0700
Committer: Abhishek Tiwari <abhishektiwari.btech@gmail.com>
Committed: Sun Jul 30 18:47:31 2017 -0700

----------------------------------------------------------------------
 .../java/org/apache/gobblin/Constructs.java     | 16 +++----
 .../apache/gobblin/broker/BrokerConstants.java  |  2 +-
 .../apache/gobblin/broker/ResourceEntry.java    |  4 +-
 .../gobblin_scopes/GobblinScopeInstance.java    |  2 +-
 .../broker/gobblin_scopes/JobScopeInstance.java |  2 +-
 .../gobblin_scopes/TaskScopeInstance.java       |  2 +-
 .../broker/iface/SharedResourceFactory.java     |  4 +-
 .../gobblin/configuration/SourceState.java      |  6 +--
 .../gobblin/configuration/WorkUnitState.java    | 26 +++++------
 .../org/apache/gobblin/converter/Converter.java |  4 +-
 .../qualitychecker/row/RowLevelPolicy.java      |  4 +-
 .../java/org/apache/gobblin/source/Source.java  | 12 ++---
 .../gobblin/source/extractor/Extractor.java     |  2 +-
 .../gobblin/source/extractor/Watermark.java     |  4 +-
 .../source/extractor/WatermarkInterval.java     |  4 +-
 .../gobblin/source/workunit/MultiWorkUnit.java  |  2 +-
 .../gobblin/source/workunit/WorkUnit.java       |  2 +-
 .../source/workunit/WorkUnitWeighter.java       |  2 +-
 .../org/apache/gobblin/util/DecoratorUtils.java |  6 +--
 .../org/apache/gobblin/util/FinalState.java     |  2 +-
 .../org/apache/gobblin/writer/DataWriter.java   |  2 +-
 .../gobblin/aws/GobblinAWSTaskRunner.java       |  2 +-
 .../cluster/GobblinClusterMetricTagNames.java   |  2 +-
 .../gobblin/cluster/GobblinHelixTask.java       |  8 ++--
 .../gobblin/cluster/GobblinTaskRunner.java      |  2 +-
 .../conditions/RecompactionCondition.java       |  4 +-
 .../compaction/dataset/DatasetHelper.java       |  2 +-
 .../hivebasedconstructs/MRCompactionEntity.java |  4 +-
 .../CompactionAvroJobConfigurator.java          |  2 +-
 .../compaction/mapreduce/MRCompactor.java       |  2 +-
 .../avro/MRCompactorAvroKeyDedupJobRunner.java  |  2 +-
 .../compaction/suite/CompactionAvroSuite.java   | 10 ++--
 .../compaction/suite/CompactionSuite.java       | 10 ++--
 .../conditions/RecompactionConditionTest.java   |  2 +-
 .../common/impl/ConfigStoreValueInspector.java  |  2 +-
 .../config/common/impl/InMemoryTopology.java    |  8 ++--
 ...impleHadoopFilesystemConfigStoreFactory.java |  2 +-
 .../gobblin/crypto/EncryptionFactory.java       |  4 +-
 .../gobblin/instrumented/Instrumentable.java    | 30 ++++++------
 .../gobblin/instrumented/Instrumented.java      | 36 +++++++--------
 .../converter/InstrumentedConverter.java        |  2 +-
 .../converter/InstrumentedConverterBase.java    |  6 +--
 .../InstrumentedConverterDecorator.java         |  6 +--
 .../extractor/InstrumentedExtractor.java        |  2 +-
 .../extractor/InstrumentedExtractorBase.java    | 14 +++---
 .../InstrumentedExtractorDecorator.java         |  4 +-
 .../fork/InstrumentedForkOperator.java          |  2 +-
 .../fork/InstrumentedForkOperatorBase.java      |  4 +-
 .../fork/InstrumentedForkOperatorDecorator.java |  4 +-
 .../InstrumentedRowLevelPolicy.java             |  2 +-
 .../InstrumentedRowLevelPolicyBase.java         |  6 +--
 .../InstrumentedRowLevelPolicyDecorator.java    |  4 +-
 .../writer/InstrumentedDataWriter.java          |  2 +-
 .../writer/InstrumentedDataWriterBase.java      |  8 ++--
 .../writer/InstrumentedDataWriterDecorator.java |  4 +-
 .../source/extractor/JobCommitPolicy.java       |  2 +-
 .../extractor/extract/AbstractSource.java       |  2 +-
 .../extractor/extract/EventBasedExtractor.java  |  2 +-
 .../extractor/extract/EventBasedSource.java     |  2 +-
 .../writer/AcknowledgableRecordEnvelope.java    |  2 +-
 .../gobblin/writer/AsyncWriterManager.java      |  4 +-
 .../writer/PartitionAwareDataWriterBuilder.java |  2 +-
 .../writer/partitioner/WriterPartitioner.java   |  2 +-
 .../SpeculativeAttemptAwareConstruct.java       |  4 +-
 .../apache/gobblin/converter/EmptyIterable.java |  2 +-
 .../GobblinMetricsPinotFlattenerConverter.java  |  2 +-
 .../avro/AvroRecordToAvroWritableConverter.java |  2 +-
 .../avro/AvroToAvroCopyableConverter.java       |  6 +--
 .../converter/filter/AvroFilterConverter.java   |  2 +-
 .../gobblin/publisher/BaseDataPublisher.java    |  2 +-
 .../row/RowLevelPolicyChecker.java              |  6 +--
 .../source/DatePartitionedAvroFileSource.java   |  2 +-
 .../source/DatePartitionedDailyAvroSource.java  |  2 +-
 .../DatePartitionedAvroFileExtractor.java       |  2 +-
 .../extractor/extract/QueryBasedSource.java     |  2 +-
 .../extractor/hadoop/HadoopFileInputSource.java |  2 +-
 .../hadoop/OldApiHadoopFileInputSource.java     |  2 +-
 .../java/org/apache/gobblin/util/TestUtils.java |  2 +-
 .../gobblin/writer/FsDataWriterBuilder.java     |  2 +-
 .../gobblin/writer/SimpleDataWriterBuilder.java |  4 +-
 .../gobblin/writer/PartitionedWriterTest.java   |  2 +-
 .../hive/extractor/HiveBaseExtractor.java       |  2 +-
 .../copy/ConcurrentBoundedWorkUnitList.java     |  8 ++--
 .../data/management/copy/CopyResourcePool.java  |  4 +-
 .../data/management/copy/CopySource.java        |  6 +--
 .../data/management/copy/CopyableDataset.java   |  4 +-
 .../copy/CopyableGlobDatasetFinder.java         |  4 +-
 .../copy/IterableCopyableDataset.java           |  2 +-
 .../management/copy/OwnerAndPermission.java     |  2 +-
 .../FileAwareInputStreamExtractor.java          |  2 +-
 .../hive/avro/HiveAvroCopyEntityHelper.java     |  2 +-
 .../PrioritizedCopyableDataset.java             |  8 ++--
 .../copy/publisher/CopyDataPublisher.java       |  2 +-
 .../publisher/CopyEventSubmitterHelper.java     |  2 +-
 .../copy/recovery/RecoveryHelper.java           |  8 ++--
 .../writer/FileAwareInputStreamDataWriter.java  |  4 +-
 .../SimpleDatasetHierarchicalPrioritizer.java   |  2 +-
 .../dataset/SimpleDatasetRequestor.java         |  2 +-
 .../management/hive/HiveRegistrableDataset.java |  2 +-
 .../gobblin/data/management/partition/File.java |  2 +-
 .../policy/CombineSelectionPolicy.java          |  2 +-
 .../retention/dataset/CleanableDataset.java     |  4 +-
 .../retention/dataset/CleanableDatasetBase.java | 14 +++---
 .../MultiVersionCleanableDatasetBase.java       |  2 +-
 .../retention/dataset/SnapshotDataset.java      |  4 +-
 .../retention/dataset/TrackingDataset.java      |  4 +-
 .../policy/CombineRetentionPolicy.java          |  2 +-
 .../policy/RawDatasetRetentionPolicy.java       |  2 +-
 .../retention/policy/RetentionPolicy.java       |  4 +-
 .../policy/predicates/WhitelistPredicate.java   |  2 +-
 .../profile/ConfigurableGlobDatasetFinder.java  | 12 ++---
 .../profile/ModificationTimeDatasetProfile.java |  2 +-
 .../profile/ProxyableDatasetProfile.java        |  6 +--
 .../profile/SnapshotDatasetProfile.java         |  2 +-
 .../profile/TrackingDatasetProfile.java         |  2 +-
 .../retention/version/DatasetVersion.java       |  2 +-
 .../version/FileStatusDatasetVersion.java       |  4 +-
 .../retention/version/StringDatasetVersion.java |  4 +-
 .../version/TimestampedDatasetVersion.java      |  4 +-
 .../finder/DateTimeDatasetVersionFinder.java    |  2 +-
 .../finder/FileLevelTimestampVersionFinder.java |  2 +-
 .../finder/GlobModTimeDatasetVersionFinder.java |  2 +-
 .../finder/ModDateTimeDatasetVersionFinder.java |  2 +-
 .../version/finder/SingleVersionFinder.java     |  2 +-
 .../finder/UnixTimestampVersionFinder.java      |  2 +-
 .../finder/WatermarkDatasetVersionFinder.java   |  2 +-
 .../trash/ImmediateDeletionTrash.java           |  2 +-
 .../data/management/trash/MockTrash.java        |  4 +-
 .../trash/NoopSnapshotCleanupPolicy.java        |  2 +-
 .../data/management/trash/ProxiedTrash.java     | 10 ++--
 .../management/trash/SnapshotCleanupPolicy.java |  4 +-
 .../data/management/trash/TestTrash.java        |  4 +-
 .../gobblin/data/management/trash/Trash.java    |  8 ++--
 .../data/management/trash/TrashFactory.java     | 18 ++++----
 .../version/FileStatusDatasetVersion.java       |  2 +-
 .../version/TimestampedDatasetVersion.java      |  2 +-
 .../finder/AbstractDatasetVersionFinder.java    | 10 ++--
 .../version/finder/DatasetVersionFinder.java    |  6 +--
 .../finder/DateTimeDatasetVersionFinder.java    |  2 +-
 .../finder/FileLevelTimestampVersionFinder.java |  6 +--
 .../converter/HiveAvroToOrcConverterTest.java   |  2 +-
 .../metrics/Implementing-New-Reporters.md       |  2 +-
 .../example/simplejson/SimpleJsonSource.java    |  2 +-
 .../example/wikipedia/WikipediaConverter.java   |  2 +-
 .../example/wikipedia/WikipediaSource.java      |  2 +-
 .../org/apache/gobblin/hive/HivePartition.java  |  4 +-
 .../gobblin/hive/HiveRegistrationUnit.java      | 12 ++---
 .../java/org/apache/gobblin/hive/HiveTable.java |  4 +-
 .../hive/policy/HiveRegistrationPolicy.java     |  2 +-
 .../policy/HiveSnapshotRegistrationPolicy.java  |  2 +-
 .../metastore/JobHistoryDataSourceProvider.java |  2 +-
 .../metastore/util/StateStoreCleaner.java       |  2 +-
 .../gobblin/metrics/ContextAwareHistogram.java  |  2 +-
 .../gobblin/metrics/ContextAwareMeter.java      |  2 +-
 .../gobblin/metrics/ContextAwareTimer.java      |  2 +-
 .../gobblin/metrics/InnerMetricContext.java     |  6 +--
 .../apache/gobblin/metrics/MetricContext.java   | 16 +++----
 .../org/apache/gobblin/metrics/MetricNames.java | 18 ++++----
 .../java/org/apache/gobblin/metrics/Tag.java    |  2 +-
 .../broker/SubTaggedMetricContextKey.java       |  8 ++--
 .../metrics/context/NameConflictException.java  |  4 +-
 .../metrics/context/ReportableContext.java      |  8 ++--
 .../metrics/context/filter/ContextFilter.java   |  6 +--
 .../gobblin/metrics/event/EventSubmitter.java   | 14 +++---
 .../gobblin/metrics/event/TimingEvent.java      |  2 +-
 .../metrics/notification/EventNotification.java |  2 +-
 .../MetricContextCleanupNotification.java       |  6 +--
 .../NewMetricContextNotification.java           |  2 +-
 .../metrics/notification/Notification.java      |  2 +-
 .../reporter/ConfiguredScheduledReporter.java   |  4 +-
 .../metrics/reporter/ContextAwareReporter.java  |  2 +-
 .../reporter/ContextAwareScheduledReporter.java |  8 ++--
 .../gobblin/metrics/reporter/EventReporter.java | 18 ++++----
 .../metrics/reporter/MetricReportReporter.java  | 18 ++++----
 .../reporter/OutputStreamEventReporter.java     |  6 +--
 .../RecursiveScheduledMetricReporter.java       |  2 +-
 .../reporter/RecursiveScheduledReporter.java    |  2 +-
 .../reporter/util/AvroBinarySerializer.java     |  2 +-
 .../reporter/util/AvroJsonSerializer.java       |  2 +-
 .../metrics/reporter/util/AvroSerializer.java   |  6 +--
 .../metrics/reporter/util/EventUtils.java       |  6 +--
 .../reporter/util/MetricReportUtils.java        |  6 +--
 .../reporter/util/NoopSchemaVersionWriter.java  |  2 +-
 .../gobblin/metrics/MetricContextTest.java      |  2 +-
 .../gobblin/metrics/RootMetricContextTest.java  |  2 +-
 .../metrics/performance/PerformanceUtils.java   | 10 ++--
 .../apache/gobblin/metrics/GobblinMetrics.java  | 26 +++++------
 .../gobblin/metrics/GobblinMetricsRegistry.java |  4 +-
 .../metrics/reporter/ScheduledReporterTest.java |  2 +-
 .../gobblin/azkaban/AzkabanJobLauncher.java     |  2 +-
 .../management/retention/DatasetCleanerJob.java |  2 +-
 .../restore/ComplianceRestoreJob.java           |  2 +-
 .../restore/RestorableHivePartitionDataset.java |  2 +-
 ...oEncryptedSerializedRecordConverterBase.java |  2 +-
 .../gobblin/eventhub/EventhubMetricNames.java   |  8 ++--
 .../gobblin/metrics/KafkaReportingFormats.java  | 10 ++--
 .../metrics/kafka/KafkaAvroEventReporter.java   |  6 +--
 .../metrics/kafka/KafkaAvroReporter.java        |  2 +-
 .../metrics/kafka/KafkaEventReporter.java       |  8 ++--
 .../gobblin/metrics/kafka/KafkaReporter.java    |  4 +-
 .../metrics/reporter/KafkaPusherTest.java       |  2 +-
 .../metrics/reporter/MockKafkaPusher.java       |  2 +-
 .../gobblin/kafka/serialize/MD5Digest.java      |  2 +-
 .../kafka/writer/KafkaWriterMetricNames.java    |  6 +--
 .../util/SchemaRegistryVersionWriter.java       |  4 +-
 .../extractor/extract/kafka/KafkaSource.java    |  2 +-
 .../extract/kafka/MultiLongWatermark.java       |  2 +-
 .../metrics/graphite/GraphiteEventReporter.java | 12 ++---
 .../metrics/graphite/GraphiteReporter.java      |  8 ++--
 .../metrics/graphite/TestGraphiteSender.java    |  2 +-
 .../metrics/hadoop/HadoopCounterReporter.java   | 10 ++--
 .../hadoop/NewAPIHadoopCounterReporter.java     | 10 ++--
 .../metrics/influxdb/InfluxDBEventReporter.java | 12 ++---
 .../metrics/influxdb/InfluxDBReporter.java      |  8 ++--
 .../gobblin/metrics/influxdb/TestInfluxDB.java  |  2 +-
 .../gobblin/rest/JobExecutionInfoClient.java    |  6 +--
 .../rest/JobExecutionInfoServerTest.java        |  8 ++--
 .../gobblin/service/FlowStatusResource.java     |  4 +-
 .../util/limiter/RestliLimiterFactory.java      |  2 +-
 .../ConfigClientBasedPolicyFactory.java         |  2 +-
 .../gobblin/restli/throttling/URIMetadata.java  |  2 +-
 .../throttling/ZookeeperLeaderElection.java     |  2 +-
 .../runtime/AbstractTaskStateTracker.java       |  2 +-
 .../apache/gobblin/runtime/BaseLimiterType.java |  2 +-
 .../runtime/CheckpointableWatermarkState.java   |  2 +-
 .../gobblin/runtime/CountBasedLimiter.java      |  2 +-
 .../gobblin/runtime/DefaultLimiterFactory.java  |  2 +-
 .../runtime/ForkBranchMismatchException.java    |  2 +-
 .../org/apache/gobblin/runtime/JobState.java    |  2 +-
 .../org/apache/gobblin/runtime/Limiter.java     |  2 +-
 .../runtime/LimitingExtractorDecorator.java     |  2 +-
 .../gobblin/runtime/NonRefillableLimiter.java   |  2 +-
 .../gobblin/runtime/PoolBasedLimiter.java       |  2 +-
 .../gobblin/runtime/RateBasedLimiter.java       |  2 +-
 .../apache/gobblin/runtime/SourceDecorator.java |  4 +-
 .../java/org/apache/gobblin/runtime/Task.java   |  8 ++--
 .../org/apache/gobblin/runtime/TaskContext.java |  8 ++--
 .../org/apache/gobblin/runtime/TaskState.java   | 12 ++---
 .../gobblin/runtime/TimeBasedLimiter.java       |  2 +-
 .../apache/gobblin/runtime/api/FlowSpec.java    |  2 +-
 .../org/apache/gobblin/runtime/api/JobSpec.java |  2 +-
 .../gobblin/runtime/api/package-info.java       | 16 +++----
 .../gobblin/runtime/cli/PasswordManagerCLI.java |  2 +-
 .../runtime/embedded/EmbeddedGobblin.java       |  8 ++--
 .../org/apache/gobblin/runtime/fork/Fork.java   |  4 +-
 .../runtime/job_catalog/StaticJobCatalog.java   |  2 +-
 .../gobblin/runtime/job_exec/package-info.java  |  2 +-
 .../gobblin/runtime/local/LocalJobLauncher.java |  2 +-
 .../mapreduce/GobblinOutputCommitter.java       |  2 +-
 .../runtime/mapreduce/MRJobLauncher.java        |  2 +-
 .../runtime/mapreduce/MRTaskStateTracker.java   |  2 +-
 .../gobblin/runtime/metrics/RuntimeMetrics.java |  2 +-
 .../runtime/plugins/PluginStaticKeys.java       |  2 +-
 .../gobblin/runtime/task/TaskFactory.java       |  2 +-
 .../template/HOCONInputStreamJobTemplate.java   |  2 +-
 .../template/ResourceBasedJobTemplate.java      |  2 +-
 .../runtime/util/JobStateToJsonConverter.java   |  2 +-
 .../org/apache/gobblin/util/SchedulerUtils.java |  2 +-
 .../runtime/mapreduce/MRJobLauncherTest.java    |  2 +-
 .../scheduler/JobConfigFileMonitorTest.java     |  2 +-
 .../org/apache/gobblin/test/TestConverter2.java |  2 +-
 .../java/org/apache/gobblin/tunnel/Tunnel.java  |  4 +-
 .../broker/BrokerConfigurationKeyGenerator.java |  4 +-
 .../broker/SharedResourcesBrokerFactory.java    |  2 +-
 .../broker/SharedResourcesBrokerImpl.java       |  2 +-
 .../broker/SharedResourcesBrokerUtils.java      |  2 +-
 .../org/apache/gobblin/broker/package-info.java | 16 +++----
 .../apache/gobblin/util/DatePartitionType.java  |  4 +-
 .../apache/gobblin/util/ForkOperatorUtils.java  |  6 +--
 .../apache/gobblin/util/JobLauncherUtils.java   |  2 +-
 .../gobblin/util/ProxiedFileSystemUtils.java    |  2 +-
 .../gobblin/util/ProxiedFileSystemWrapper.java  |  2 +-
 .../gobblin/util/RateControlledFileSystem.java  |  8 ++--
 .../org/apache/gobblin/util/WriterUtils.java    | 48 ++++++++++----------
 .../gobblin/util/callbacks/package-info.java    | 10 ++--
 .../PathAlterationObserverScheduler.java        |  2 +-
 .../apache/gobblin/util/limiter/Limiter.java    |  2 +-
 .../org/apache/gobblin/util/AvroUtilsTest.java  |  4 +-
 .../apache/gobblin/util/FileListUtilsTest.java  |  2 +-
 .../org/apache/gobblin/util/test/BaseClass.java |  2 +-
 .../apache/gobblin/util/test/ExtendedClass.java |  2 +-
 .../org/apache/gobblin/util/test/TestClass.java |  2 +-
 .../gobblin/yarn/GobblinYarnEventConstants.java |  2 +-
 .../gobblin/yarn/GobblinYarnMetricTagNames.java |  2 +-
 .../gobblin/yarn/GobblinYarnTaskRunner.java     |  2 +-
 .../event/GetApplicationReportFailureEvent.java |  2 +-
 286 files changed, 654 insertions(+), 654 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-api/src/main/java/org/apache/gobblin/Constructs.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/Constructs.java b/gobblin-api/src/main/java/org/apache/gobblin/Constructs.java
index cde29bc..3136459 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/Constructs.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/Constructs.java
@@ -32,21 +32,21 @@ import org.apache.gobblin.writer.DataWriter;
  */
 public enum Constructs {
 
-  /** {@link gobblin.source.Source} */
+  /** {@link org.apache.gobblin.source.Source} */
   SOURCE("Source", Source.class),
-  /** {@link gobblin.source.extractor.Extractor} */
+  /** {@link org.apache.gobblin.source.extractor.Extractor} */
   EXTRACTOR("Extractor", Extractor.class),
-  /** {@link gobblin.converter.Converter} */
+  /** {@link org.apache.gobblin.converter.Converter} */
   CONVERTER("Converter", Converter.class),
-  /** {@link gobblin.qualitychecker.row.RowLevelPolicy} */
+  /** {@link org.apache.gobblin.qualitychecker.row.RowLevelPolicy} */
   ROW_QUALITY_CHECKER("RowLevelPolicy", RowLevelPolicy.class),
-  /** {@link gobblin.qualitychecker.task.TaskLevelPolicy} */
+  /** {@link org.apache.gobblin.qualitychecker.task.TaskLevelPolicy} */
   TASK_QUALITY_CHECKER("TaskLevelPolicy", TaskLevelPolicy.class),
-  /** {@link gobblin.fork.ForkOperator} */
+  /** {@link org.apache.gobblin.fork.ForkOperator} */
   FORK_OPERATOR("ForkOperator", ForkOperator.class),
-  /** {@link gobblin.writer.DataWriter} */
+  /** {@link org.apache.gobblin.writer.DataWriter} */
   WRITER("DataWriter", DataWriter.class),
-  /** {@link gobblin.publisher.DataPublisher} */
+  /** {@link org.apache.gobblin.publisher.DataPublisher} */
   DATA_PUBLISHER("DataPublisher",DataPublisher.class);
 
   private final String name;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-api/src/main/java/org/apache/gobblin/broker/BrokerConstants.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/BrokerConstants.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/BrokerConstants.java
index cc1737d..c29a162 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/broker/BrokerConstants.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/BrokerConstants.java
@@ -18,7 +18,7 @@
 package org.apache.gobblin.broker;
 
 /**
- * Constants used for {@link gobblin.broker.iface.SharedResourcesBroker}.
+ * Constants used for {@link org.apache.gobblin.broker.iface.SharedResourcesBroker}.
  */
 public class BrokerConstants {
   public static final String GOBBLIN_BROKER_CONFIG_PREFIX = "gobblin.broker";

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-api/src/main/java/org/apache/gobblin/broker/ResourceEntry.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/ResourceEntry.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/ResourceEntry.java
index 496ee25..6402391 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/broker/ResourceEntry.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/ResourceEntry.java
@@ -31,13 +31,13 @@ public interface ResourceEntry<T> extends SharedResourceFactoryResponse<T> {
 
   /**
    * @return Whether this entry is valid. If the entry is invalid, it will be invalidated from the cache, causing a new
-   * call to the {@link gobblin.broker.iface.SharedResourceFactory}.
+   * call to the {@link org.apache.gobblin.broker.iface.SharedResourceFactory}.
    */
   boolean isValid();
 
   /**
    * This method will be called when the entry is invalidated. It may or may not close the contained resource depending
-   * on the semantics the {@link gobblin.broker.iface.SharedResourceFactory} wishes to provide (e.g. whether already
+   * on the semantics the {@link org.apache.gobblin.broker.iface.SharedResourceFactory} wishes to provide (e.g. whether already
    * acquired objects should be closed).
    *
    * Note that for consistency, the broker runs this method synchronously before a new instance is created for the same

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeInstance.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeInstance.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeInstance.java
index 3229560..f4f37f4 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeInstance.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeInstance.java
@@ -21,7 +21,7 @@ import org.apache.gobblin.broker.SimpleScope;
 
 
 /**
- * {@link gobblin.broker.iface.ScopeInstance} superclass for scopes used in Gobblin ingestion jobs.
+ * {@link org.apache.gobblin.broker.iface.ScopeInstance} superclass for scopes used in Gobblin ingestion jobs.
  */
 public class GobblinScopeInstance extends SimpleScope<GobblinScopeTypes> {
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/JobScopeInstance.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/JobScopeInstance.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/JobScopeInstance.java
index 53f30cb..5449d7d 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/JobScopeInstance.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/JobScopeInstance.java
@@ -21,7 +21,7 @@ import lombok.Getter;
 
 
 /**
- * A {@link gobblin.broker.iface.ScopeInstance} for a Gobblin job.
+ * A {@link org.apache.gobblin.broker.iface.ScopeInstance} for a Gobblin job.
  */
 @Getter
 public class JobScopeInstance extends GobblinScopeInstance {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/TaskScopeInstance.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/TaskScopeInstance.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/TaskScopeInstance.java
index 35592f7..34c521b 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/TaskScopeInstance.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/TaskScopeInstance.java
@@ -21,7 +21,7 @@ import lombok.Getter;
 
 
 /**
- * A {@link gobblin.broker.iface.ScopeInstance} for a Gobblin task.
+ * A {@link org.apache.gobblin.broker.iface.ScopeInstance} for a Gobblin task.
  */
 public class TaskScopeInstance extends GobblinScopeInstance {
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourceFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourceFactory.java b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourceFactory.java
index fcb4661..ad0cb82 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourceFactory.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SharedResourceFactory.java
@@ -31,8 +31,8 @@ public interface SharedResourceFactory<T, K extends SharedResourceKey, S extends
   /**
    * Requests an object for the provided {@link SharedResourceKey}, with the provided configuration.
    * The factory can return a variety of responses:
-   * * {@link gobblin.broker.ResourceEntry}: a newly built resource of type T for the input key and scope.
-   * * {@link gobblin.broker.ResourceCoordinate}: the coordinates (factory, key, scope) of another resource of type T that
+   * * {@link org.apache.gobblin.broker.ResourceEntry}: a newly built resource of type T for the input key and scope.
+   * * {@link org.apache.gobblin.broker.ResourceCoordinate}: the coordinates (factory, key, scope) of another resource of type T that
    *    should be used instead (this allows, for example, to use a different factory, or always return a global scoped object.)
    */
   SharedResourceFactoryResponse<T>

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-api/src/main/java/org/apache/gobblin/configuration/SourceState.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/configuration/SourceState.java b/gobblin-api/src/main/java/org/apache/gobblin/configuration/SourceState.java
index 141386a..78f7fcf 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/configuration/SourceState.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/configuration/SourceState.java
@@ -50,7 +50,7 @@ import lombok.Getter;
  * <p>
  *   Properties can be overwritten at runtime and persisted upon job completion. Persisted
  *   properties will be loaded in the next run and made available to use by the
- *   {@link gobblin.source.Source}.
+ *   {@link org.apache.gobblin.source.Source}.
  * </p>
  *
  * @author kgoodhop
@@ -167,12 +167,12 @@ public class SourceState extends State {
    *   This method should always return a new unique {@link Extract} instance.
    * </p>
    *
-   * @param type {@link gobblin.source.workunit.Extract.TableType}
+   * @param type {@link org.apache.gobblin.source.workunit.Extract.TableType}
    * @param namespace namespace of the table this extract belongs to
    * @param table name of the table this extract belongs to
    * @return a new unique {@link Extract} instance
    *
-   * @Deprecated Use {@link gobblin.source.extractor.extract.AbstractSource#createExtract(
+   * @Deprecated Use {@link org.apache.gobblin.source.extractor.extract.AbstractSource#createExtract(
    * gobblin.source.workunit.Extract.TableType, String, String)}
    */
   @Deprecated

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-api/src/main/java/org/apache/gobblin/configuration/WorkUnitState.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/configuration/WorkUnitState.java b/gobblin-api/src/main/java/org/apache/gobblin/configuration/WorkUnitState.java
index 1a8ea89..af02d01 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/configuration/WorkUnitState.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/configuration/WorkUnitState.java
@@ -242,20 +242,20 @@ public class WorkUnitState extends State {
    * {@link Watermark} indicates that all data for the source has been pulled up to a specific point.
    *
    * <p>
-   *  This method should be called inside the {@link gobblin.source.extractor.Extractor} class, during the initialization
-   *  of the class, before any calls to {@link gobblin.source.extractor.Extractor#readRecord(Object)} are executed. This
+   *  This method should be called inside the {@link org.apache.gobblin.source.extractor.Extractor} class, during the initialization
+   *  of the class, before any calls to {@link org.apache.gobblin.source.extractor.Extractor#readRecord(Object)} are executed. This
    *  method keeps a local point to the given {@link Watermark} and expects the following invariant to always be upheld.
    *  The invariant for this {@link Watermark} is that it should cover all records up to and including the most recent
-   *  record returned by {@link gobblin.source.extractor.Extractor#readRecord(Object)}.
+   *  record returned by {@link org.apache.gobblin.source.extractor.Extractor#readRecord(Object)}.
    * </p>
    * <p>
    *  The {@link Watermark} set in this method may be polled by the framework multiple times, in order to track the
    *  progress of how the {@link Watermark} changes. This is important for reporting percent completion of a
-   *  {@link gobblin.source.workunit.WorkUnit}.
+   *  {@link org.apache.gobblin.source.workunit.WorkUnit}.
    * </p>
    *
-   * TODO - Once we are ready to make a backwards incompatible change to the {@link gobblin.source.extractor.Extractor}
-   * interface, this method should become part of the {@link gobblin.source.extractor.Extractor} interface. For example,
+   * TODO - Once we are ready to make a backwards incompatible change to the {@link org.apache.gobblin.source.extractor.Extractor}
+   * interface, this method should become part of the {@link org.apache.gobblin.source.extractor.Extractor} interface. For example,
    * a method such as getCurrentHighWatermark() should be added.
    */
   public void setActualHighWatermark(Watermark watermark) {
@@ -281,7 +281,7 @@ public class WorkUnitState extends State {
   }
 
   /**
-   * Get the high watermark as set in {@link gobblin.source.extractor.Extractor}.
+   * Get the high watermark as set in {@link org.apache.gobblin.source.extractor.Extractor}.
    *
    * @return high watermark
    * @deprecated use {@link #getActualHighWatermark}.
@@ -368,9 +368,9 @@ public class WorkUnitState extends State {
   }
 
   /**
-   * Get the {@link gobblin.source.workunit.Extract} associated with the {@link WorkUnit}.
+   * Get the {@link org.apache.gobblin.source.workunit.Extract} associated with the {@link WorkUnit}.
    *
-   * @return {@link gobblin.source.workunit.Extract} associated with the {@link WorkUnit}
+   * @return {@link org.apache.gobblin.source.workunit.Extract} associated with the {@link WorkUnit}
    */
   public Extract getExtract() {
     return new Extract(this.workUnit.getExtract());
@@ -430,15 +430,15 @@ public class WorkUnitState extends State {
   }
 
   /**
-   * Adds all properties from {@link gobblin.configuration.State} to this {@link gobblin.configuration.WorkUnitState}.
+   * Adds all properties from {@link org.apache.gobblin.configuration.State} to this {@link org.apache.gobblin.configuration.WorkUnitState}.
    *
    * <p>
    *   A property with name "property" will be added to this object with the key
    *   "{@link #FINAL_CONSTRUCT_STATE_PREFIX}[.<infix>].property"
    * </p>
    *
-   * @param infix Optional infix used for the name of the property in the {@link gobblin.configuration.WorkUnitState}.
-   * @param finalConstructState {@link gobblin.configuration.State} for which all properties should be added to this
+   * @param infix Optional infix used for the name of the property in the {@link org.apache.gobblin.configuration.WorkUnitState}.
+   * @param finalConstructState {@link org.apache.gobblin.configuration.State} for which all properties should be added to this
    *                                                               object.
    */
   public void addFinalConstructState(String infix, State finalConstructState) {
@@ -453,7 +453,7 @@ public class WorkUnitState extends State {
 
   /**
    * Builds a State containing all properties added with {@link #addFinalConstructState}
-   * to this {@link gobblin.configuration.WorkUnitState}. All such properties will be stripped of
+   * to this {@link org.apache.gobblin.configuration.WorkUnitState}. All such properties will be stripped of
    * {@link #FINAL_CONSTRUCT_STATE_PREFIX} but not of any infixes.
    *
    * <p>

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-api/src/main/java/org/apache/gobblin/converter/Converter.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/converter/Converter.java b/gobblin-api/src/main/java/org/apache/gobblin/converter/Converter.java
index 49544fe..82cf10e 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/converter/Converter.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/converter/Converter.java
@@ -104,9 +104,9 @@ public abstract class Converter<SI, SO, DI, DO> implements Closeable, FinalState
       throws DataConversionException;
 
   /**
-   * Get final state for this object. By default this returns an empty {@link gobblin.configuration.State}, but
+   * Get final state for this object. By default this returns an empty {@link org.apache.gobblin.configuration.State}, but
    * concrete subclasses can add information that will be added to the task state.
-   * @return Empty {@link gobblin.configuration.State}.
+   * @return Empty {@link org.apache.gobblin.configuration.State}.
    */
   @Override
   public State getFinalState() {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-api/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicy.java b/gobblin-api/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicy.java
index de718eb..d0e8359 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicy.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicy.java
@@ -73,9 +73,9 @@ public abstract class RowLevelPolicy implements Closeable, FinalState {
   }
 
   /**
-   * Get final state for this object. By default this returns an empty {@link gobblin.configuration.State}, but
+   * Get final state for this object. By default this returns an empty {@link org.apache.gobblin.configuration.State}, but
    * concrete subclasses can add information that will be added to the task state.
-   * @return Empty {@link gobblin.configuration.State}.
+   * @return Empty {@link org.apache.gobblin.configuration.State}.
    */
   @Override
   public State getFinalState() {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-api/src/main/java/org/apache/gobblin/source/Source.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/Source.java b/gobblin-api/src/main/java/org/apache/gobblin/source/Source.java
index 7b9b82a..86d767a 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/source/Source.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/source/Source.java
@@ -47,7 +47,7 @@ public interface Source<S, D> {
    * Get a list of {@link WorkUnit}s, each of which is for extracting a portion of the data.
    *
    * <p>
-   *   Each {@link WorkUnit} will be used instantiate a {@link gobblin.configuration.WorkUnitState} that gets passed to the
+   *   Each {@link WorkUnit} will be used instantiate a {@link org.apache.gobblin.configuration.WorkUnitState} that gets passed to the
    *   {@link #getExtractor(gobblin.configuration.WorkUnitState)} method to get an {@link Extractor} for extracting schema
    *   and data records from the source. The {@link WorkUnit} instance should have all the properties
    *   needed for the {@link Extractor} to work.
@@ -56,24 +56,24 @@ public interface Source<S, D> {
    * <p>
    *   Typically the list of {@link WorkUnit}s for the current run is determined by taking into account
    *   the list of {@link WorkUnit}s from the previous run so data gets extracted incrementally. The
-   *   method {@link gobblin.configuration.SourceState#getPreviousWorkUnitStates} can be used to get the list of {@link WorkUnit}s
+   *   method {@link org.apache.gobblin.configuration.SourceState#getPreviousWorkUnitStates} can be used to get the list of {@link WorkUnit}s
    *   from the previous run.
    * </p>
    *
-   * @param state see {@link gobblin.configuration.SourceState}
+   * @param state see {@link org.apache.gobblin.configuration.SourceState}
    * @return a list of {@link WorkUnit}s
    */
   public abstract List<WorkUnit> getWorkunits(SourceState state);
 
   /**
-   * Get an {@link Extractor} based on a given {@link gobblin.configuration.WorkUnitState}.
+   * Get an {@link Extractor} based on a given {@link org.apache.gobblin.configuration.WorkUnitState}.
    *
    * <p>
-   *   The {@link Extractor} returned can use {@link gobblin.configuration.WorkUnitState} to store arbitrary key-value pairs
+   *   The {@link Extractor} returned can use {@link org.apache.gobblin.configuration.WorkUnitState} to store arbitrary key-value pairs
    *   that will be persisted to the state store and loaded in the next scheduled job run.
    * </p>
    *
-   * @param state a {@link gobblin.configuration.WorkUnitState} carrying properties needed by the returned {@link Extractor}
+   * @param state a {@link org.apache.gobblin.configuration.WorkUnitState} carrying properties needed by the returned {@link Extractor}
    * @return an {@link Extractor} used to extract schema and data records from the data source
    * @throws IOException if it fails to create an {@link Extractor}
    */

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/Extractor.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/Extractor.java b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/Extractor.java
index 6a1af0f..22b1670 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/Extractor.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/Extractor.java
@@ -37,7 +37,7 @@ import javax.annotation.Nullable;
  *
  * <p>
  *     All source specific logic for a data source should be encapsulated in an
- *     implementation of this interface and {@link gobblin.source.Source}.
+ *     implementation of this interface and {@link org.apache.gobblin.source.Source}.
  * </p>
  *
  * @author kgoodhop

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/Watermark.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/Watermark.java b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/Watermark.java
index 391e876..1eb7c07 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/Watermark.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/Watermark.java
@@ -25,8 +25,8 @@ import com.google.gson.JsonElement;
  * to track this state.
  *
  * <p>
- *  A {@link Watermark} will be serialized in {@link gobblin.source.workunit.WorkUnit}s and
- *  {@link gobblin.configuration.WorkUnitState}s. The {@link #toJson()} method will be used to serialize the
+ *  A {@link Watermark} will be serialized in {@link org.apache.gobblin.source.workunit.WorkUnit}s and
+ *  {@link org.apache.gobblin.configuration.WorkUnitState}s. The {@link #toJson()} method will be used to serialize the
  *  {@link Watermark} into a {@link JsonElement}.
  * </p>
  */

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/WatermarkInterval.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/WatermarkInterval.java b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/WatermarkInterval.java
index 37f70bd..394d09d 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/WatermarkInterval.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/WatermarkInterval.java
@@ -22,9 +22,9 @@ import com.google.gson.JsonObject;
 
 
 /**
- * Each {@link gobblin.source.workunit.WorkUnit} has a corresponding {@link WatermarkInterval}. The
+ * Each {@link org.apache.gobblin.source.workunit.WorkUnit} has a corresponding {@link WatermarkInterval}. The
  * {@link WatermarkInterval} represents the range of the data that needs to be pulled for the {@link WorkUnit}. So, the
- * {@link gobblin.source.workunit.WorkUnit} should pull data from the {@link #lowWatermark} to the
+ * {@link org.apache.gobblin.source.workunit.WorkUnit} should pull data from the {@link #lowWatermark} to the
  * {@link #expectedHighWatermark}.
  */
 public class WatermarkInterval {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/MultiWorkUnit.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/MultiWorkUnit.java b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/MultiWorkUnit.java
index 834f4f3..f80085a 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/MultiWorkUnit.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/MultiWorkUnit.java
@@ -31,7 +31,7 @@ import com.google.common.collect.Lists;
  * A class that wraps multiple {@link WorkUnit}s so they can executed within a single task.
  *
  * <p>
- *  This class also extends the {@link gobblin.configuration.State} object and thus it is possible to set and get
+ *  This class also extends the {@link org.apache.gobblin.configuration.State} object and thus it is possible to set and get
  *  properties from this class. The {@link #setProp(String, Object)} method will add the specified key, value pair to
  *  this class as well as to every {@link WorkUnit} in {@link #workUnits}. The {@link #getProp(String)} methods will
  *  only return properties that have been explicitily set in this class (e.g. it will not retrieve properties from

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnit.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnit.java b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnit.java
index 21915a5..5df29a6 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnit.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnit.java
@@ -90,7 +90,7 @@ public class WorkUnit extends State {
   /**
    * Constructor for a {@link WorkUnit} given a {@link SourceState}, {@link Extract}, and a {@link WatermarkInterval}.
    *
-   * @param state a {@link gobblin.configuration.SourceState} the properties of which will be copied into this {@link WorkUnit} instance.
+   * @param state a {@link org.apache.gobblin.configuration.SourceState} the properties of which will be copied into this {@link WorkUnit} instance.
    * @param extract an {@link Extract}.
    * @param watermarkInterval a {@link WatermarkInterval} which defines the range of data this {@link WorkUnit} will process.
    *

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnitWeighter.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnitWeighter.java b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnitWeighter.java
index a9db38c..eed8e45 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnitWeighter.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnitWeighter.java
@@ -21,7 +21,7 @@ package org.apache.gobblin.source.workunit;
  * Provides weights for {@link WorkUnit}s to use by a {@link WorkUnitBinPacker}.
  *
  * <p>
- *   The weight is used by a bin packing algorithm to organize {@link WorkUnit}s into {@link gobblin.source.workunit.MultiWorkUnit}s
+ *   The weight is used by a bin packing algorithm to organize {@link WorkUnit}s into {@link org.apache.gobblin.source.workunit.MultiWorkUnit}s
  *   with a bounded total weight. The weighter must have the following properties:
  *   <ul>
  *     <li>If wu1.equals(wu2), then weight(wu1) == weight(wu2).</li>

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-api/src/main/java/org/apache/gobblin/util/DecoratorUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/util/DecoratorUtils.java b/gobblin-api/src/main/java/org/apache/gobblin/util/DecoratorUtils.java
index 9b67347..f8b90ae 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/util/DecoratorUtils.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/util/DecoratorUtils.java
@@ -28,7 +28,7 @@ import com.google.common.collect.Lists;
 public class DecoratorUtils {
 
   /**
-   * Resolves the truly underlying object in a possible chain of {@link gobblin.util.Decorator}.
+   * Resolves the truly underlying object in a possible chain of {@link org.apache.gobblin.util.Decorator}.
    *
    * @param obj object to resolve.
    * @return the true non-decorator underlying object.
@@ -44,8 +44,8 @@ public class DecoratorUtils {
    * Finds the decorator lineage of the given object.
    *
    * <p>
-   * If object is not a {@link gobblin.util.Decorator}, this method will return a singleton list with just the object.
-   * If object is a {@link gobblin.util.Decorator}, it will return a list of the underlying object followed by the
+   * If object is not a {@link org.apache.gobblin.util.Decorator}, this method will return a singleton list with just the object.
+   * If object is a {@link org.apache.gobblin.util.Decorator}, it will return a list of the underlying object followed by the
    * decorator lineage up to the input decorator object.
    * </p>
    *

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-api/src/main/java/org/apache/gobblin/util/FinalState.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/util/FinalState.java b/gobblin-api/src/main/java/org/apache/gobblin/util/FinalState.java
index 2abff3f..2ebc0ac 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/util/FinalState.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/util/FinalState.java
@@ -28,7 +28,7 @@ public interface FinalState {
   /**
    * Called by tasks after all work for the construct has been executed. The construct can return a state
    * describing a summary of its execution / final state.
-   * @return a {@link gobblin.configuration.State} with summary of execution / final state of the construct.
+   * @return a {@link org.apache.gobblin.configuration.State} with summary of execution / final state of the construct.
    */
   public State getFinalState();
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-api/src/main/java/org/apache/gobblin/writer/DataWriter.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/writer/DataWriter.java b/gobblin-api/src/main/java/org/apache/gobblin/writer/DataWriter.java
index 0dcc888..18d11d6 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/writer/DataWriter.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/writer/DataWriter.java
@@ -85,7 +85,7 @@ public interface DataWriter<D> extends Closeable, Flushable {
   }
 
   /**
-   * Default handler calls flush on this object when a {@link gobblin.stream.FlushControlMessage} is received
+   * Default handler calls flush on this object when a {@link org.apache.gobblin.stream.FlushControlMessage} is received
    * @return A {@link ControlMessageHandler}.
    */
   default ControlMessageHandler getMessageHandler() {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSTaskRunner.java
----------------------------------------------------------------------
diff --git a/gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSTaskRunner.java b/gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSTaskRunner.java
index dc9693b..93f36cf 100644
--- a/gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSTaskRunner.java
+++ b/gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSTaskRunner.java
@@ -52,7 +52,7 @@ import org.apache.gobblin.util.JvmUtils;
 
 /**
  * Class running on worker nodes managing services for executing Gobblin
- * {@link gobblin.source.workunit.WorkUnit}s.
+ * {@link org.apache.gobblin.source.workunit.WorkUnit}s.
  *
  * <p>
  *   This class makes use of super class {@link GobblinTaskRunner} to run:

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterMetricTagNames.java
----------------------------------------------------------------------
diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterMetricTagNames.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterMetricTagNames.java
index 0ecf6b3..34c865c 100644
--- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterMetricTagNames.java
+++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterMetricTagNames.java
@@ -21,7 +21,7 @@ import org.apache.gobblin.annotation.Alpha;
 
 
 /**
- * A central place for constants of {@link gobblin.metrics.MetricContext} tag names for a Gobblin cluster.
+ * A central place for constants of {@link org.apache.gobblin.metrics.MetricContext} tag names for a Gobblin cluster.
  *
  * @author Yinan Li
  */

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTask.java
----------------------------------------------------------------------
diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTask.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTask.java
index 7af4ee1..7c7a0f9 100644
--- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTask.java
+++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTask.java
@@ -60,16 +60,16 @@ import org.apache.gobblin.broker.gobblin_scopes.JobScopeInstance;
 
 /**
  * An implementation of Helix's {@link org.apache.helix.task.Task} that wraps and runs one or more Gobblin
- * {@link gobblin.runtime.Task}s.
+ * {@link org.apache.gobblin.runtime.Task}s.
  *
  * <p>
  *   Upon startup, a {@link GobblinHelixTask} reads the property
  *   {@link GobblinClusterConfigurationKeys#WORK_UNIT_FILE_PATH} for the path of the file storing a serialized
  *   {@link WorkUnit} on the {@link FileSystem} of choice and de-serializes the {@link WorkUnit}. Depending on
  *   if the serialized {@link WorkUnit} is a {@link MultiWorkUnit}, it then creates one or more Gobblin
- *   {@link gobblin.runtime.Task}s to run the {@link WorkUnit}(s) (possibly wrapped in the {@link MultiWorkUnit})
- *   and waits for the Gobblin {@link gobblin.runtime.Task}(s) to finish. Upon completion of the Gobblin
- *   {@link gobblin.runtime.Task}(s), it persists the {@link TaskState} of each {@link gobblin.runtime.Task} to
+ *   {@link org.apache.gobblin.runtime.Task}s to run the {@link WorkUnit}(s) (possibly wrapped in the {@link MultiWorkUnit})
+ *   and waits for the Gobblin {@link org.apache.gobblin.runtime.Task}(s) to finish. Upon completion of the Gobblin
+ *   {@link org.apache.gobblin.runtime.Task}(s), it persists the {@link TaskState} of each {@link org.apache.gobblin.runtime.Task} to
  *   a file that will be collected by the {@link GobblinHelixJobLauncher} later upon completion of the job.
  * </p>
  *

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinTaskRunner.java
----------------------------------------------------------------------
diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinTaskRunner.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinTaskRunner.java
index 7dd2676..838abe6 100644
--- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinTaskRunner.java
+++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinTaskRunner.java
@@ -84,7 +84,7 @@ import org.apache.gobblin.util.logs.Log4jConfigurationHelper;
 
 /**
  * The main class running in the containers managing services for running Gobblin
- * {@link gobblin.source.workunit.WorkUnit}s.
+ * {@link org.apache.gobblin.source.workunit.WorkUnit}s.
  *
  * <p>
  *   This class serves as a Helix participant and it uses a {@link HelixManager} to work with Helix.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/conditions/RecompactionCondition.java
----------------------------------------------------------------------
diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/conditions/RecompactionCondition.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/conditions/RecompactionCondition.java
index 46c40d8..6ae1f65 100644
--- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/conditions/RecompactionCondition.java
+++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/conditions/RecompactionCondition.java
@@ -24,8 +24,8 @@ import org.apache.gobblin.compaction.dataset.DatasetHelper;
  * different criteria or different combination strategies to decide if a recompaction is mandatory.
  *
  * The interface {@link RecompactionCondition} provides a generic API. This is used when
- * {@link gobblin.compaction.mapreduce.MRCompactorJobRunner} attempts to check if a recompaction is necessary. Real
- * examination is delegated to {@link gobblin.compaction.dataset.Dataset#checkIfNeedToRecompact(DatasetHelper)},
+ * {@link org.apache.gobblin.compaction.mapreduce.MRCompactorJobRunner} attempts to check if a recompaction is necessary. Real
+ * examination is delegated to {@link org.apache.gobblin.compaction.dataset.Dataset#checkIfNeedToRecompact(DatasetHelper)},
  * which finally invokes this API.
  */
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/dataset/DatasetHelper.java
----------------------------------------------------------------------
diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/dataset/DatasetHelper.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/dataset/DatasetHelper.java
index bd82d29..2eede65 100644
--- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/dataset/DatasetHelper.java
+++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/dataset/DatasetHelper.java
@@ -49,7 +49,7 @@ import org.apache.gobblin.util.reflection.GobblinConstructorUtils;
  * A class {@link DatasetHelper} which provides runtime metrics and other helper functions for a given dataset.
  *
  * The class also contains different recompaction conditions {@link RecompactionCondition}, which indicates if a
- * recompaction is needed. These conditions will be examined by {@link gobblin.compaction.mapreduce.MRCompactorJobRunner}
+ * recompaction is needed. These conditions will be examined by {@link org.apache.gobblin.compaction.mapreduce.MRCompactorJobRunner}
  * after late data was found and copied from inputDir to outputLateDir.
  */
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/hivebasedconstructs/MRCompactionEntity.java
----------------------------------------------------------------------
diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/hivebasedconstructs/MRCompactionEntity.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/hivebasedconstructs/MRCompactionEntity.java
index 4f4b105..2d721d0 100644
--- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/hivebasedconstructs/MRCompactionEntity.java
+++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/hivebasedconstructs/MRCompactionEntity.java
@@ -24,12 +24,12 @@ import lombok.Getter;
 
 
 /**
- * Entity that stores information required for launching an {@link gobblin.compaction.mapreduce.MRCompactor} job
+ * Entity that stores information required for launching an {@link org.apache.gobblin.compaction.mapreduce.MRCompactor} job
  *
  * {@link #primaryKeyList}: Comma delimited list of fields to use as primary key
  * {@link #deltaList}: Comma delimited list of fields to use as deltaList
  * {@link #dataFilesPath}: Location of files associated with table
- * {@link #props}: Other properties to be passed to {@link gobblin.compaction.mapreduce.MRCompactor}
+ * {@link #props}: Other properties to be passed to {@link org.apache.gobblin.compaction.mapreduce.MRCompactor}
  */
 @Getter
 public class MRCompactionEntity {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/CompactionAvroJobConfigurator.java
----------------------------------------------------------------------
diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/CompactionAvroJobConfigurator.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/CompactionAvroJobConfigurator.java
index d78c16d..9c1e362 100644
--- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/CompactionAvroJobConfigurator.java
+++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/CompactionAvroJobConfigurator.java
@@ -234,7 +234,7 @@ public class CompactionAvroJobConfigurator {
 
   /**
    * Customized MR job creation. This method will be used in
-   * {@link gobblin.compaction.suite.CompactionAvroSuite#createJob(Dataset)}
+   * {@link org.apache.gobblin.compaction.suite.CompactionAvroSuite#createJob(Dataset)}
    *
    * @param  dataset  A path or directory which needs compaction
    * @return A configured map-reduce job for avro compaction

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/MRCompactor.java
----------------------------------------------------------------------
diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/MRCompactor.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/MRCompactor.java
index 2b57782..ad695c5 100644
--- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/MRCompactor.java
+++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/MRCompactor.java
@@ -89,7 +89,7 @@ import org.apache.gobblin.util.recordcount.IngestionRecordCountProvider;
 import org.apache.gobblin.util.reflection.GobblinConstructorUtils;
 
 /**
- * MapReduce-based {@link gobblin.compaction.Compactor}. Compaction will run on each qualified {@link Dataset}
+ * MapReduce-based {@link org.apache.gobblin.compaction.Compactor}. Compaction will run on each qualified {@link Dataset}
  * under {@link #COMPACTION_INPUT_DIR}.
  *
  * @author Ziyang Liu

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/MRCompactorAvroKeyDedupJobRunner.java
----------------------------------------------------------------------
diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/MRCompactorAvroKeyDedupJobRunner.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/MRCompactorAvroKeyDedupJobRunner.java
index 931e287..00b6742 100644
--- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/MRCompactorAvroKeyDedupJobRunner.java
+++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/MRCompactorAvroKeyDedupJobRunner.java
@@ -55,7 +55,7 @@ import org.apache.gobblin.util.AvroUtils;
 
 
 /**
- * A subclass of {@link gobblin.compaction.mapreduce.MRCompactorJobRunner} that configures
+ * A subclass of {@link org.apache.gobblin.compaction.mapreduce.MRCompactorJobRunner} that configures
  * and runs MR compaction job for Avro data.
  *
  * To dedup using entire records set compaction.use.all.attributes=true. Otherwise, a schema needs

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/suite/CompactionAvroSuite.java
----------------------------------------------------------------------
diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/suite/CompactionAvroSuite.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/suite/CompactionAvroSuite.java
index 48cbbcd..0142f6b 100644
--- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/suite/CompactionAvroSuite.java
+++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/suite/CompactionAvroSuite.java
@@ -56,7 +56,7 @@ public class CompactionAvroSuite implements CompactionSuite<FileSystemDataset> {
   /**
    * Implementation of {@link CompactionSuite#getDatasetsFinderVerifiers()}
    * @return A list of {@link CompactionVerifier} instances which will be verified after
-   *         {@link FileSystemDataset} is found but before a {@link gobblin.source.workunit.WorkUnit}
+   *         {@link FileSystemDataset} is found but before a {@link org.apache.gobblin.source.workunit.WorkUnit}
    *         is created.
    */
   public List<CompactionVerifier<FileSystemDataset>> getDatasetsFinderVerifiers() {
@@ -70,7 +70,7 @@ public class CompactionAvroSuite implements CompactionSuite<FileSystemDataset> {
   /**
    * Implementation of {@link CompactionSuite#getMapReduceVerifiers()}
    * @return A list of {@link CompactionVerifier} instances which will be verified before
-   *         {@link gobblin.compaction.mapreduce.MRCompactionTask} starts the map-reduce job
+   *         {@link org.apache.gobblin.compaction.mapreduce.MRCompactionTask} starts the map-reduce job
    */
   public List<CompactionVerifier<FileSystemDataset>> getMapReduceVerifiers() {
     List<CompactionVerifier<FileSystemDataset>> list = new ArrayList<>();
@@ -80,7 +80,7 @@ public class CompactionAvroSuite implements CompactionSuite<FileSystemDataset> {
   /**
    * Serialize a dataset {@link FileSystemDataset} to a {@link State}
    * @param dataset A dataset needs serialization
-   * @param state   A state that is used to save {@link gobblin.dataset.Dataset}
+   * @param state   A state that is used to save {@link org.apache.gobblin.dataset.Dataset}
    */
   public void save (FileSystemDataset dataset, State state) {
     state.setProp(SERIALIZE_COMPACTION_FILE_PATH_NAME, dataset.datasetURN());
@@ -89,7 +89,7 @@ public class CompactionAvroSuite implements CompactionSuite<FileSystemDataset> {
   /**
    * Deserialize a new {@link FileSystemDataset} from a given {@link State}
    *
-   * @param state a type of {@link gobblin.runtime.TaskState}
+   * @param state a type of {@link org.apache.gobblin.runtime.TaskState}
    * @return A new instance of {@link FileSystemDataset}
    */
   public FileSystemDataset load (final State state) {
@@ -125,7 +125,7 @@ public class CompactionAvroSuite implements CompactionSuite<FileSystemDataset> {
    * work is delegated to {@link CompactionAvroJobConfigurator#createJob(FileSystemDataset)}
    *
    * @param  dataset a top level input path which contains all avro files those need to be compacted
-   * @return a map-reduce job which will compact avro files against {@link gobblin.dataset.Dataset}
+   * @return a map-reduce job which will compact avro files against {@link org.apache.gobblin.dataset.Dataset}
    */
   public Job createJob (FileSystemDataset dataset) throws IOException {
     configurator = new CompactionAvroJobConfigurator(this.state);

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/suite/CompactionSuite.java
----------------------------------------------------------------------
diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/suite/CompactionSuite.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/suite/CompactionSuite.java
index fba0076..3c36ba5 100644
--- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/suite/CompactionSuite.java
+++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/suite/CompactionSuite.java
@@ -31,16 +31,16 @@ import java.io.IOException;
 import java.util.List;
 
 /**
- * This interface provides major components required by {@link gobblin.compaction.source.CompactionSource}
- * and {@link gobblin.compaction.mapreduce.MRCompactionTask} flow.
+ * This interface provides major components required by {@link org.apache.gobblin.compaction.source.CompactionSource}
+ * and {@link org.apache.gobblin.compaction.mapreduce.MRCompactionTask} flow.
  *
  * User needs to implement {@link #createJob(Dataset)} method to create a customized map-reduce job.
  * Two types of {@link CompactionVerifier}s should be provided. One is to verify datasets returned by
  * {@link ConfigBasedDatasetsFinder#findDatasets()}. The other is to verify datasets before we run MR
- * job inside {@link gobblin.compaction.mapreduce.MRCompactionTask}
+ * job inside {@link org.apache.gobblin.compaction.mapreduce.MRCompactionTask}
  *
  * The class also handles how to create a map-reduce job and how to serialized and deserialize a {@link Dataset}
- * to and from a {@link gobblin.source.workunit.WorkUnit} properly.
+ * to and from a {@link org.apache.gobblin.source.workunit.WorkUnit} properly.
  */
 
 public interface CompactionSuite<D extends Dataset> {
@@ -57,7 +57,7 @@ public interface CompactionSuite<D extends Dataset> {
 
   /**
    * Get a list of verifiers for each dataset validation.
-   * Verifiers are executed by {@link gobblin.compaction.source.CompactionSource#getWorkunits(SourceState)}
+   * Verifiers are executed by {@link org.apache.gobblin.compaction.source.CompactionSource#getWorkunits(SourceState)}
    */
   List<CompactionVerifier<D>> getDatasetsFinderVerifiers();
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/conditions/RecompactionConditionTest.java
----------------------------------------------------------------------
diff --git a/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/conditions/RecompactionConditionTest.java b/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/conditions/RecompactionConditionTest.java
index f57193b..8211710 100644
--- a/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/conditions/RecompactionConditionTest.java
+++ b/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/conditions/RecompactionConditionTest.java
@@ -53,7 +53,7 @@ import static org.mockito.Mockito.when;
 
 
 /**
- * Test class for {@link gobblin.compaction.conditions.RecompactionCondition}.
+ * Test class for {@link org.apache.gobblin.compaction.conditions.RecompactionCondition}.
  */
 @Test(groups = {"gobblin.compaction.mapreduce.conditions"})
 public class RecompactionConditionTest {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/ConfigStoreValueInspector.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/ConfigStoreValueInspector.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/ConfigStoreValueInspector.java
index 43239cd..2de0c51 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/ConfigStoreValueInspector.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/ConfigStoreValueInspector.java
@@ -28,7 +28,7 @@ import org.apache.gobblin.config.store.api.ConfigKeyPath;
 
 /**
  * The ConfigStoreValueInspector interface used to inspect the {@link com.typesafe.config.Config} for a given
- * {@link gobblin.config.store.api.ConfigKeyPath} in {@link ConfigStore}
+ * {@link org.apache.gobblin.config.store.api.ConfigKeyPath} in {@link ConfigStore}
  *
  * @author mitu
  *

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/InMemoryTopology.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/InMemoryTopology.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/InMemoryTopology.java
index b0a2f19..1d9d5e6 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/InMemoryTopology.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/InMemoryTopology.java
@@ -38,7 +38,7 @@ import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;
 
 
 /**
- * InMemoryTopology will return stale data if the internal config store is Not {@link gobblin.config.store.api.ConfigStoreWithStableVersioning}
+ * InMemoryTopology will return stale data if the internal config store is Not {@link org.apache.gobblin.config.store.api.ConfigStoreWithStableVersioning}
  *
  * @author ibuenros
  *
@@ -142,7 +142,7 @@ public class InMemoryTopology implements ConfigStoreTopologyInspector {
    *   If the result is already in cache, return the result.
    *   Otherwise, delegate the functionality to the fallback object.
    *
-   *   If the fallback did not support this operation, will build the entire topology of the {@link gobblin.config.store.api.ConfigStore}
+   *   If the fallback did not support this operation, will build the entire topology of the {@link org.apache.gobblin.config.store.api.ConfigStore}
    *   using default breath first search.
    * </p>
    */
@@ -177,7 +177,7 @@ public class InMemoryTopology implements ConfigStoreTopologyInspector {
    *   If the result is already in cache, return the result.
    *   Otherwise, delegate the functionality to the fallback object.
    *
-   *   If the fallback did not support this operation, will build the entire topology of the {@link gobblin.config.store.api.ConfigStore}
+   *   If the fallback did not support this operation, will build the entire topology of the {@link org.apache.gobblin.config.store.api.ConfigStore}
    *   using default breath first search.
    * </p>
    */
@@ -208,7 +208,7 @@ public class InMemoryTopology implements ConfigStoreTopologyInspector {
    *   If the result is already in cache, return the result.
    *   Otherwise, delegate the functionality to the fallback object.
    *
-   *   If the fallback did not support this operation, will build the entire topology of the {@link gobblin.config.store.api.ConfigStore}
+   *   If the fallback did not support this operation, will build the entire topology of the {@link org.apache.gobblin.config.store.api.ConfigStore}
    *   using default breath first search.
    * </p>
    */

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/SimpleHadoopFilesystemConfigStoreFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/SimpleHadoopFilesystemConfigStoreFactory.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/SimpleHadoopFilesystemConfigStoreFactory.java
index 7e3d57a..04c412f 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/SimpleHadoopFilesystemConfigStoreFactory.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/SimpleHadoopFilesystemConfigStoreFactory.java
@@ -99,7 +99,7 @@ public abstract class SimpleHadoopFilesystemConfigStoreFactory implements Config
   protected abstract String getPhysicalScheme();
 
   /**
-   * Returns the default {@link FileSystem} used for {@link gobblin.config.store.api.ConfigStore}s generated by this
+   * Returns the default {@link FileSystem} used for {@link org.apache.gobblin.config.store.api.ConfigStore}s generated by this
    * factory.
    * @param factoryConfig the user supplied factory configuration.
    * @param configDefinedDefaultURI if the user specified a default uri, that uri.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core-base/src/main/java/org/apache/gobblin/crypto/EncryptionFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/crypto/EncryptionFactory.java b/gobblin-core-base/src/main/java/org/apache/gobblin/crypto/EncryptionFactory.java
index ff31673..9bc964e 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/crypto/EncryptionFactory.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/crypto/EncryptionFactory.java
@@ -27,7 +27,7 @@ import org.apache.gobblin.codec.StreamCodec;
 
 /**
  * This class knows how to build encryption algorithms based on configuration parameters. To add your own
- * encryption implementation, please add another implementation of {@link gobblin.crypto.EncryptionProvider}
+ * encryption implementation, please add another implementation of {@link org.apache.gobblin.crypto.EncryptionProvider}
  * in Gobblin's classpath as well as referencing the new implementation in META-INF/services/gobblin.crypto.EncryptionProvider
  * of the containing JAR. (See {@link java.util.ServiceLoader} documentation for more details).
  */
@@ -37,7 +37,7 @@ public class EncryptionFactory {
 
   /**
    * Build a StreamCodec with the given config parameters. The type will be extracted from the parameters.
-   * See {@link gobblin.crypto.EncryptionConfigParser} for a set of standard configuration parameters, although
+   * See {@link org.apache.gobblin.crypto.EncryptionConfigParser} for a set of standard configuration parameters, although
    * each encryption provider may have its own arbitrary set.
    * @return A StreamCodec for the given parameters
    * @throws IllegalArgumentException If no provider exists that can build the requested encryption codec

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/Instrumentable.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/Instrumentable.java b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/Instrumentable.java
index e9292b1..b307690 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/Instrumentable.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/Instrumentable.java
@@ -27,13 +27,13 @@ import org.apache.gobblin.metrics.Tag;
 
 
 /**
- * Interface for classes instrumenting their execution into a {@link gobblin.metrics.MetricContext}.
+ * Interface for classes instrumenting their execution into a {@link org.apache.gobblin.metrics.MetricContext}.
  */
 public interface Instrumentable {
 
   /**
-   * Get {@link gobblin.metrics.MetricContext} containing metrics related to this Instrumentable.
-   * @return an instance of {@link gobblin.metrics.MetricContext}.
+   * Get {@link org.apache.gobblin.metrics.MetricContext} containing metrics related to this Instrumentable.
+   * @return an instance of {@link org.apache.gobblin.metrics.MetricContext}.
    */
   @Nonnull
   public MetricContext getMetricContext();
@@ -45,39 +45,39 @@ public interface Instrumentable {
   public boolean isInstrumentationEnabled();
 
   /**
-   * Generate tags that should be added to the {@link gobblin.metrics.MetricContext}.
-   * @return List of tags to add to {@link gobblin.metrics.MetricContext}.
+   * Generate tags that should be added to the {@link org.apache.gobblin.metrics.MetricContext}.
+   * @return List of tags to add to {@link org.apache.gobblin.metrics.MetricContext}.
    */
   public List<Tag<?>> generateTags(State state);
 
   /**
-   * Generate a new {@link gobblin.metrics.MetricContext} replacing old {@link gobblin.metrics.Tag} with input
-   * {@link gobblin.metrics.Tag} (only tags with the same keys will be replaced),
+   * Generate a new {@link org.apache.gobblin.metrics.MetricContext} replacing old {@link org.apache.gobblin.metrics.Tag} with input
+   * {@link org.apache.gobblin.metrics.Tag} (only tags with the same keys will be replaced),
    * and recreate all metrics in this new context.
    *
    * <p>
-   *   This method is useful when the state of the {@link gobblin.instrumented.Instrumentable} changes and the user
+   *   This method is useful when the state of the {@link org.apache.gobblin.instrumented.Instrumentable} changes and the user
    *   wants that state change to be reflected in the tags of the instrumentation.
    * </p>
    *
    * <p>
-   *   Notice that this method creates a brand new {@link gobblin.metrics.MetricContext} and {@link gobblin.metrics.Metric}
+   *   Notice that this method creates a brand new {@link org.apache.gobblin.metrics.MetricContext} and {@link org.apache.gobblin.metrics.Metric}
    *   every time it is called,
    *   with the associated processing and memory overhead. Use sparingly only for state changes that must be visible in
    *   emitted metrics.
    * </p>
    *
-   * @param tags additional {@link gobblin.metrics.Tag}.
+   * @param tags additional {@link org.apache.gobblin.metrics.Tag}.
    */
   public void switchMetricContext(List<Tag<?>> tags);
 
   /**
-   * Switches the existing {@link gobblin.metrics.MetricContext} with the supplied metric context and regenerates
-   * {@link gobblin.metrics.Metric}.
+   * Switches the existing {@link org.apache.gobblin.metrics.MetricContext} with the supplied metric context and regenerates
+   * {@link org.apache.gobblin.metrics.Metric}.
    *
    * <p>
-   *   This method is useful when the state of the {@link gobblin.instrumented.Instrumentable} changes and the user
-   *   wants that state change to be reflected in the set of {@link gobblin.metrics.Tag} of the instrumentation.
+   *   This method is useful when the state of the {@link org.apache.gobblin.instrumented.Instrumentable} changes and the user
+   *   wants that state change to be reflected in the set of {@link org.apache.gobblin.metrics.Tag} of the instrumentation.
    * </p>
    *
    * <p>
@@ -87,7 +87,7 @@ public interface Instrumentable {
    *   avoiding the overhead of generating a brand new context every time a metric context switch is required.
    * </p>
    *
-   * @param context new {@link gobblin.metrics.MetricContext}.
+   * @param context new {@link org.apache.gobblin.metrics.MetricContext}.
    */
   public void switchMetricContext(MetricContext context);
 }

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/Instrumented.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/Instrumented.java b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/Instrumented.java
index 9b149e8..f2aa103 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/Instrumented.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/Instrumented.java
@@ -60,9 +60,9 @@ import org.apache.gobblin.writer.DataWriter;
  * Provides simple instrumentation for gobblin-core components.
  *
  * <p>
- * Creates {@link gobblin.metrics.MetricContext}. Tries to read the name of the parent context
+ * Creates {@link org.apache.gobblin.metrics.MetricContext}. Tries to read the name of the parent context
  * from key "metrics.context.name" at state, and tries to get the parent context by name from
- * the {@link gobblin.metrics.MetricContext} registry (the parent context must be registered).
+ * the {@link org.apache.gobblin.metrics.MetricContext} registry (the parent context must be registered).
  * </p>
  *
  * <p>
@@ -92,26 +92,26 @@ public class Instrumented implements Instrumentable, Closeable {
   }
 
   /**
-   * Get a {@link gobblin.metrics.MetricContext} to be used by an object needing instrumentation.
+   * Get a {@link org.apache.gobblin.metrics.MetricContext} to be used by an object needing instrumentation.
    *
    * <p>
    * This method will read the property "metrics.context.name" from the input State, and will attempt
-   * to find a MetricContext with that name in the global instance of {@link gobblin.metrics.GobblinMetricsRegistry}.
+   * to find a MetricContext with that name in the global instance of {@link org.apache.gobblin.metrics.GobblinMetricsRegistry}.
    * If it succeeds, the generated MetricContext will be a child of the retrieved Context, otherwise it will
    * be a parent-less context.
    * </p>
    * <p>
    * The method will automatically add two tags to the context:
    * <ul>
-   *  <li> construct will contain the name of the {@link gobblin.Constructs} that klazz represents. </li>
+   *  <li> construct will contain the name of the {@link org.apache.gobblin.Constructs} that klazz represents. </li>
    *  <li> class will contain the canonical name of the input class. </li>
    * </ul>
    * </p>
    *
-   * @param state {@link gobblin.configuration.State} used to find the parent MetricContext.
+   * @param state {@link org.apache.gobblin.configuration.State} used to find the parent MetricContext.
    * @param klazz Class of the object needing instrumentation.
    * @param tags Additional tags to add to the returned context.
-   * @return A {@link gobblin.metrics.MetricContext} with the appropriate tags and parent.
+   * @return A {@link org.apache.gobblin.metrics.MetricContext} with the appropriate tags and parent.
    */
   public static MetricContext getMetricContext(State state, Class<?> klazz, List<Tag<?>> tags) {
     int randomId = RAND.nextInt(Integer.MAX_VALUE);
@@ -148,15 +148,15 @@ public class Instrumented implements Instrumentable, Closeable {
   }
 
   /**
-   * Generates a new {@link gobblin.metrics.MetricContext} with the parent and tags taken from the reference context.
-   * Allows replacing {@link gobblin.metrics.Tag} with new input tags.
-   * This method will not copy any {@link gobblin.metrics.Metric} contained in the reference {@link gobblin.metrics.MetricContext}.
+   * Generates a new {@link org.apache.gobblin.metrics.MetricContext} with the parent and tags taken from the reference context.
+   * Allows replacing {@link org.apache.gobblin.metrics.Tag} with new input tags.
+   * This method will not copy any {@link org.apache.gobblin.metrics.Metric} contained in the reference {@link org.apache.gobblin.metrics.MetricContext}.
    *
-   * @param context Reference {@link gobblin.metrics.MetricContext}.
-   * @param newTags New {@link gobblin.metrics.Tag} to apply to context. Repeated keys will override old tags.
-   * @param name Name of the new {@link gobblin.metrics.MetricContext}.
+   * @param context Reference {@link org.apache.gobblin.metrics.MetricContext}.
+   * @param newTags New {@link org.apache.gobblin.metrics.Tag} to apply to context. Repeated keys will override old tags.
+   * @param name Name of the new {@link org.apache.gobblin.metrics.MetricContext}.
    *             If absent or empty, will modify old name by adding a random integer at the end.
-   * @return Generated {@link gobblin.metrics.MetricContext}.
+   * @return Generated {@link org.apache.gobblin.metrics.MetricContext}.
    */
   public static MetricContext newContextFromReferenceContext(MetricContext context, List<Tag<?>> newTags,
       Optional<String> name) {
@@ -184,8 +184,8 @@ public class Instrumented implements Instrumentable, Closeable {
   }
 
   /**
-   * Determines whether an object or, if it is a {@link gobblin.util.Decorator}, any object on its lineage,
-   * is of class {@link gobblin.instrumented.Instrumentable}.
+   * Determines whether an object or, if it is a {@link org.apache.gobblin.util.Decorator}, any object on its lineage,
+   * is of class {@link org.apache.gobblin.instrumented.Instrumentable}.
    * @param obj Object to analyze.
    * @return Whether the lineage is instrumented.
    */
@@ -203,8 +203,8 @@ public class Instrumented implements Instrumentable, Closeable {
   }
 
   /**
-   * Returns a {@link com.codahale.metrics.Timer.Context} only if {@link gobblin.metrics.MetricContext} is defined.
-   * @param context an Optional&lt;{@link gobblin.metrics.MetricContext}$gt;
+   * Returns a {@link com.codahale.metrics.Timer.Context} only if {@link org.apache.gobblin.metrics.MetricContext} is defined.
+   * @param context an Optional&lt;{@link org.apache.gobblin.metrics.MetricContext}$gt;
    * @param name name of the timer.
    * @return an Optional&lt;{@link com.codahale.metrics.Timer.Context}$gt;
    */

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/converter/InstrumentedConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/converter/InstrumentedConverter.java b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/converter/InstrumentedConverter.java
index aaf32ed..16d1c44 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/converter/InstrumentedConverter.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/converter/InstrumentedConverter.java
@@ -25,7 +25,7 @@ import org.apache.gobblin.converter.DataConversionException;
  * Instrumented converter that automatically captures certain metrics.
  * Subclasses should implement convertRecordImpl instead of convertRecord.
  *
- * See {@link gobblin.converter.Converter}.
+ * See {@link org.apache.gobblin.converter.Converter}.
  *
  * @author ibuenros
  */


Mime
View raw message