You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gobblin.apache.org by ab...@apache.org on 2017/07/31 07:53:07 UTC
[49/77] [abbrv] incubator-gobblin git commit: Changed JavaDocs
references from gobblin to org.apache.gobblin package
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 <ab...@gmail.com>
Authored: Sun Jul 30 18:47:31 2017 -0700
Committer: Abhishek Tiwari <ab...@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<{@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
*/