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 <[email protected]> Authored: Sun Jul 30 18:47:31 2017 -0700 Committer: Abhishek Tiwari <[email protected]> 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<{@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<{@link org.apache.gobblin.metrics.MetricContext}$gt; * @param name name of the timer. * @return an Optional<{@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 */
