gobblin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a...@apache.org
Subject [48/77] [abbrv] incubator-gobblin git commit: Changed JavaDocs references from gobblin to org.apache.gobblin package
Date Mon, 31 Jul 2017 07:53:06 GMT
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/converter/InstrumentedConverterBase.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/converter/InstrumentedConverterBase.java b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/converter/InstrumentedConverterBase.java
index e42d401..81cbd91 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/converter/InstrumentedConverterBase.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/converter/InstrumentedConverterBase.java
@@ -44,8 +44,8 @@ import org.apache.gobblin.metrics.Tag;
 
 
 /**
- * package-private implementation of instrumentation for {@link gobblin.converter.Converter}.
- * See {@link gobblin.instrumented.converter.InstrumentedConverter} for extensible class.
+ * package-private implementation of instrumentation for {@link org.apache.gobblin.converter.Converter}.
+ * See {@link org.apache.gobblin.instrumented.converter.InstrumentedConverter} for extensible class.
  */
 abstract class InstrumentedConverterBase<SI, SO, DI, DO> extends Converter<SI, SO, DI, DO>
     implements Instrumentable, Closeable {
@@ -178,7 +178,7 @@ abstract class InstrumentedConverterBase<SI, SO, DI, DO> extends Converter<SI, S
   /**
    * Subclasses should implement this method instead of convertRecord.
    *
-   * See {@link gobblin.converter.Converter#convertRecord}.
+   * See {@link org.apache.gobblin.converter.Converter#convertRecord}.
    */
   public abstract Iterable<DO> convertRecordImpl(SO outputSchema, DI inputRecord, WorkUnitState workUnit)
       throws DataConversionException;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/converter/InstrumentedConverterDecorator.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/converter/InstrumentedConverterDecorator.java b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/converter/InstrumentedConverterDecorator.java
index 06c857b..ad397c8 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/converter/InstrumentedConverterDecorator.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/converter/InstrumentedConverterDecorator.java
@@ -33,8 +33,8 @@ import org.apache.gobblin.util.DecoratorUtils;
 
 
 /**
- * Decorator that automatically instruments {@link gobblin.converter.Converter}.
- * Handles already instrumented {@link gobblin.instrumented.converter.InstrumentedConverter}
+ * Decorator that automatically instruments {@link org.apache.gobblin.converter.Converter}.
+ * Handles already instrumented {@link org.apache.gobblin.instrumented.converter.InstrumentedConverter}
  * appropriately to avoid double metric reporting.
  */
 public class InstrumentedConverterDecorator<SI, SO, DI, DO> extends InstrumentedConverterBase<SI, SO, DI, DO>
@@ -96,7 +96,7 @@ public class InstrumentedConverterDecorator<SI, SO, DI, DO> extends Instrumented
 
   /**
    * This workarounds the issue that {@link Converter#processStream(RecordStreamWithMetadata, WorkUnitState)} will invoke
-   * {@link gobblin.converter.AsyncConverter1to1#convertRecord(Object, Object, WorkUnitState)} directly, which is an unsupported method.
+   * {@link org.apache.gobblin.converter.AsyncConverter1to1#convertRecord(Object, Object, WorkUnitState)} directly, which is an unsupported method.
    */
   @Override
   public RecordStreamWithMetadata<DO, SO> processStream(RecordStreamWithMetadata<DI, SI> inputStream,

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractor.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractor.java b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractor.java
index aeabd4b..1372575 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractor.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractor.java
@@ -25,7 +25,7 @@ import org.apache.gobblin.stream.RecordEnvelope;
 
 
 /**
- * Instrumented version of {@link gobblin.source.extractor.Extractor} automatically captures certain metrics.
+ * Instrumented version of {@link org.apache.gobblin.source.extractor.Extractor} automatically captures certain metrics.
  * Subclasses should implement readRecordImpl instead of readRecord.
  */
 public abstract class InstrumentedExtractor<S, D> extends InstrumentedExtractorBase<S, D> {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractorBase.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractorBase.java b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractorBase.java
index cb6ca2e..35de712 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractorBase.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractorBase.java
@@ -54,8 +54,8 @@ import javax.annotation.Nullable;
 
 
 /**
- * package-private implementation of instrumentation for {@link gobblin.source.extractor.Extractor}.
- * See {@link gobblin.instrumented.extractor.InstrumentedExtractor} for extensible class.
+ * package-private implementation of instrumentation for {@link org.apache.gobblin.source.extractor.Extractor}.
+ * See {@link org.apache.gobblin.instrumented.extractor.InstrumentedExtractor} for extensible class.
  */
 public abstract class InstrumentedExtractorBase<S, D>
     implements Extractor<S, D>, Instrumentable, Closeable, FinalState {
@@ -222,7 +222,7 @@ public abstract class InstrumentedExtractorBase<S, D>
 
   /**
    * Subclasses should implement this or {@link #readRecordEnvelopeImpl()}
-   * instead of {@link gobblin.source.extractor.Extractor#readRecord}
+   * instead of {@link org.apache.gobblin.source.extractor.Extractor#readRecord}
    */
   protected StreamEntity<D> readStreamEntityImpl() throws DataRecordException, IOException {
     return readRecordEnvelopeImpl();
@@ -230,7 +230,7 @@ public abstract class InstrumentedExtractorBase<S, D>
 
   /**
    * Subclasses should implement this or {@link #readRecordImpl(Object)}
-   * instead of {@link gobblin.source.extractor.Extractor#readRecord}
+   * instead of {@link org.apache.gobblin.source.extractor.Extractor#readRecord}
    */
   @SuppressWarnings(value = "RCN_REDUNDANT_NULLCHECK_OF_NONNULL_VALUE",
       justification = "Findbugs believes readRecord(null) is non-null. This is not true.")
@@ -241,7 +241,7 @@ public abstract class InstrumentedExtractorBase<S, D>
 
   /**
    * Subclasses should implement this or {@link #readRecordEnvelopeImpl()}
-   * instead of {@link gobblin.source.extractor.Extractor#readRecord}
+   * instead of {@link org.apache.gobblin.source.extractor.Extractor#readRecord}
    */
   @Nullable
   protected D readRecordImpl(D reuse) throws DataRecordException, IOException {
@@ -249,9 +249,9 @@ public abstract class InstrumentedExtractorBase<S, D>
   }
 
   /**
-   * 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-core-base/src/main/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractorDecorator.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractorDecorator.java b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractorDecorator.java
index 4af7805..baab42e 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractorDecorator.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractorDecorator.java
@@ -36,8 +36,8 @@ import org.apache.gobblin.util.FinalState;
 
 
 /**
- * Decorator that automatically instruments {@link gobblin.source.extractor.Extractor}.
- * Handles already instrumented {@link gobblin.instrumented.extractor.InstrumentedExtractor}
+ * Decorator that automatically instruments {@link org.apache.gobblin.source.extractor.Extractor}.
+ * Handles already instrumented {@link org.apache.gobblin.instrumented.extractor.InstrumentedExtractor}
  * appropriately to avoid double metric reporting.
  */
 public class InstrumentedExtractorDecorator<S, D> extends InstrumentedExtractorBase<S, D> implements Decorator {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperator.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperator.java b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperator.java
index 9ce4c7f..a4481c2 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperator.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperator.java
@@ -23,7 +23,7 @@ import org.apache.gobblin.configuration.WorkUnitState;
 
 
 /**
- * Instrumented {@link gobblin.fork.ForkOperator} automatically capturing certain metrics.
+ * Instrumented {@link org.apache.gobblin.fork.ForkOperator} automatically capturing certain metrics.
  * Subclasses should implement forkDataRecordImpl instead of forkDataRecord.
  *
  * @author ibuenros

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperatorBase.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperatorBase.java b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperatorBase.java
index ca00aea..2855ec7 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperatorBase.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperatorBase.java
@@ -40,7 +40,7 @@ import org.apache.gobblin.metrics.Tag;
 
 
 /**
- * Package-private implementation of instrumentation for {@link gobblin.fork.ForkOperator}.
+ * Package-private implementation of instrumentation for {@link org.apache.gobblin.fork.ForkOperator}.
  *
  * @see gobblin.instrumented.fork.InstrumentedForkOperator for extensible class.
  */
@@ -159,7 +159,7 @@ abstract class InstrumentedForkOperatorBase<S, D> implements Instrumentable, For
   }
 
   /**
-   * Subclasses should implement this instead of {@link gobblin.fork.ForkOperator#forkDataRecord}.
+   * Subclasses should implement this instead of {@link org.apache.gobblin.fork.ForkOperator#forkDataRecord}.
    */
   public abstract List<Boolean> forkDataRecordImpl(WorkUnitState workUnitState, D input);
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperatorDecorator.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperatorDecorator.java b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperatorDecorator.java
index 8436b20..f1d044f 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperatorDecorator.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperatorDecorator.java
@@ -30,8 +30,8 @@ import org.apache.gobblin.util.DecoratorUtils;
 
 
 /**
- * Decorator that automatically instruments {@link gobblin.fork.ForkOperator}.
- * Handles already instrumented {@link gobblin.instrumented.fork.InstrumentedForkOperator}
+ * Decorator that automatically instruments {@link org.apache.gobblin.fork.ForkOperator}.
+ * Handles already instrumented {@link org.apache.gobblin.instrumented.fork.InstrumentedForkOperator}
  * appropriately to avoid double metric reporting.
  */
 public class InstrumentedForkOperatorDecorator<S, D> extends InstrumentedForkOperatorBase<S, D> implements Decorator {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicy.java b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicy.java
index 27b34cf..9b907c6 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicy.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicy.java
@@ -21,7 +21,7 @@ import org.apache.gobblin.configuration.State;
 
 
 /**
- * Instrumented {@link gobblin.qualitychecker.row.RowLevelPolicy} automatically capturing certain metrics.
+ * Instrumented {@link org.apache.gobblin.qualitychecker.row.RowLevelPolicy} automatically capturing certain metrics.
  * Subclasses should implement executePolicyImpl instead of executePolicy.
  *
  * @author ibuenros

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyBase.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyBase.java b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyBase.java
index b48332f..d404a77 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyBase.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyBase.java
@@ -40,8 +40,8 @@ import org.apache.gobblin.qualitychecker.row.RowLevelPolicy;
 
 
 /**
- * package-private implementation of instrumentation for {@link gobblin.qualitychecker.row.RowLevelPolicy}.
- * See {@link gobblin.instrumented.qualitychecker.InstrumentedRowLevelPolicy} for extensible class.
+ * package-private implementation of instrumentation for {@link org.apache.gobblin.qualitychecker.row.RowLevelPolicy}.
+ * See {@link org.apache.gobblin.instrumented.qualitychecker.InstrumentedRowLevelPolicy} for extensible class.
  */
 abstract class InstrumentedRowLevelPolicyBase extends RowLevelPolicy implements Instrumentable, Closeable {
 
@@ -156,7 +156,7 @@ abstract class InstrumentedRowLevelPolicyBase extends RowLevelPolicy implements
   }
 
   /**
-   * Subclasses should implement this instead of {@link gobblin.qualitychecker.row.RowLevelPolicy#executePolicy}.
+   * Subclasses should implement this instead of {@link org.apache.gobblin.qualitychecker.row.RowLevelPolicy#executePolicy}.
    */
   public abstract Result executePolicyImpl(Object record);
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyDecorator.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyDecorator.java b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyDecorator.java
index ddf02fb..ba289f0 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyDecorator.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyDecorator.java
@@ -30,8 +30,8 @@ import org.apache.gobblin.util.DecoratorUtils;
 
 
 /**
- * Decorator that automatically instruments {@link gobblin.qualitychecker.row.RowLevelPolicy}.
- * Handles already instrumented {@link gobblin.instrumented.qualitychecker.InstrumentedRowLevelPolicy}
+ * Decorator that automatically instruments {@link org.apache.gobblin.qualitychecker.row.RowLevelPolicy}.
+ * Handles already instrumented {@link org.apache.gobblin.instrumented.qualitychecker.InstrumentedRowLevelPolicy}
  * appropriately to avoid double metric reporting.
  */
 public class InstrumentedRowLevelPolicyDecorator extends InstrumentedRowLevelPolicyBase implements Decorator {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriter.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriter.java b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriter.java
index f4ae8e7..ff382d5 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriter.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriter.java
@@ -23,7 +23,7 @@ import org.apache.gobblin.configuration.State;
 
 
 /**
- * Instrumented version of {@link gobblin.writer.DataWriter} automatically capturing certain metrics.
+ * Instrumented version of {@link org.apache.gobblin.writer.DataWriter} automatically capturing certain metrics.
  * Subclasses should implement writeImpl instead of write.
  */
 public abstract class InstrumentedDataWriter<D> extends InstrumentedDataWriterBase<D> {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriterBase.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriterBase.java b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriterBase.java
index 99e0a5f..8affa21 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriterBase.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriterBase.java
@@ -48,7 +48,7 @@ import org.apache.gobblin.writer.DataWriter;
 @Slf4j
 
 /**
- * Package-private implementation of instrumentation for {@link gobblin.writer.DataWriter}.
+ * Package-private implementation of instrumentation for {@link org.apache.gobblin.writer.DataWriter}.
  *
  * @see gobblin.instrumented.writer.InstrumentedDataWriter for extensible class.
  */
@@ -195,14 +195,14 @@ abstract class InstrumentedDataWriterBase<D> implements DataWriter<D>, Instrumen
   }
 
   /**
-   * Subclasses should implement this instead of {@link gobblin.writer.DataWriter#write}
+   * Subclasses should implement this instead of {@link org.apache.gobblin.writer.DataWriter#write}
    */
   public abstract void writeImpl(D record) throws IOException;
 
   /**
-   * 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-core-base/src/main/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriterDecorator.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriterDecorator.java b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriterDecorator.java
index 2f6ff8b..e90f895 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriterDecorator.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriterDecorator.java
@@ -37,8 +37,8 @@ import org.apache.gobblin.writer.WatermarkAwareWriter;
 
 
 /**
- * Decorator that automatically instruments {@link gobblin.writer.DataWriter}. Handles already instrumented
- * {@link gobblin.instrumented.writer.InstrumentedDataWriter} appropriately to avoid double metric reporting.
+ * Decorator that automatically instruments {@link org.apache.gobblin.writer.DataWriter}. Handles already instrumented
+ * {@link org.apache.gobblin.instrumented.writer.InstrumentedDataWriter} appropriately to avoid double metric reporting.
  */
 public class InstrumentedDataWriterDecorator<D> extends InstrumentedDataWriterBase<D> implements Decorator, WatermarkAwareWriter<D> {
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/JobCommitPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/JobCommitPolicy.java b/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/JobCommitPolicy.java
index 2546f00..f60acb6 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/JobCommitPolicy.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/JobCommitPolicy.java
@@ -36,7 +36,7 @@ public enum JobCommitPolicy {
   COMMIT_ON_FULL_SUCCESS("full"),
 
   /**
-   * Commit a job even if some of its tasks fail. It's up to the {@link gobblin.publisher.DataPublisher} to
+   * Commit a job even if some of its tasks fail. It's up to the {@link org.apache.gobblin.publisher.DataPublisher} to
    * decide whether data of failed tasks of the job should be committed or not.
    *
    * @deprecated Use {@link #COMMIT_SUCCESSFUL_TASKS} instead, which provides a less confusing commit semantics,

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/AbstractSource.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/AbstractSource.java b/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/AbstractSource.java
index 8eaadc1..db51597 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/AbstractSource.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/AbstractSource.java
@@ -36,7 +36,7 @@ import org.apache.gobblin.source.workunit.Extract.TableType;
 
 
 /**
- * A base implementation of {@link gobblin.source.Source} that provides default behavior.
+ * A base implementation of {@link org.apache.gobblin.source.Source} that provides default behavior.
  *
  * @author Yinan Li
  */

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/EventBasedExtractor.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/EventBasedExtractor.java b/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/EventBasedExtractor.java
index 4b31938..994d45f 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/EventBasedExtractor.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/EventBasedExtractor.java
@@ -22,7 +22,7 @@ import org.apache.gobblin.instrumented.extractor.InstrumentedExtractor;
 
 
 /**
- * A base {@link gobblin.source.extractor.Extractor} class for
+ * A base {@link org.apache.gobblin.source.extractor.Extractor} class for
  * event-based sources.
  */
 public abstract class EventBasedExtractor<S, D> extends InstrumentedExtractor<S, D> {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/EventBasedSource.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/EventBasedSource.java b/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/EventBasedSource.java
index 840cb66..939a3fe 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/EventBasedSource.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/EventBasedSource.java
@@ -21,7 +21,7 @@ import org.apache.gobblin.configuration.SourceState;
 
 
 /**
- * A base implementation of {@link gobblin.source.Source} for
+ * A base implementation of {@link org.apache.gobblin.source.Source} for
  * event-based sources.
  */
 public abstract class EventBasedSource<S, D> extends AbstractSource<S, D> {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AcknowledgableRecordEnvelope.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AcknowledgableRecordEnvelope.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AcknowledgableRecordEnvelope.java
index 8e28ea8..97e9d91 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AcknowledgableRecordEnvelope.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AcknowledgableRecordEnvelope.java
@@ -59,7 +59,7 @@ public class AcknowledgableRecordEnvelope<D> implements Ackable {
 
   /**
    * Get the original watermark that was attached to this record,
-   * typically by a {@link gobblin.source.extractor.StreamingExtractor}
+   * typically by a {@link org.apache.gobblin.source.extractor.StreamingExtractor}
    */
   public CheckpointableWatermark getWatermark() {
     return _watermark.getCheckpointableWatermark();

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AsyncWriterManager.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AsyncWriterManager.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AsyncWriterManager.java
index 17a5530..ac30c7b 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AsyncWriterManager.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/AsyncWriterManager.java
@@ -190,9 +190,9 @@ public class AsyncWriterManager<D> implements WatermarkAwareWriter<D>, DataWrite
 
   /**
    * TODO: Figure out what this means for checkpointing.
-   * 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-core-base/src/main/java/org/apache/gobblin/writer/PartitionAwareDataWriterBuilder.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/PartitionAwareDataWriterBuilder.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/PartitionAwareDataWriterBuilder.java
index 0ed9110..e8a8d54 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/PartitionAwareDataWriterBuilder.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/PartitionAwareDataWriterBuilder.java
@@ -29,7 +29,7 @@ import org.apache.gobblin.writer.partitioner.WriterPartitioner;
 
 /**
  * A {@link DataWriterBuilder} used with a {@link WriterPartitioner}. When provided with a partitioner, Gobblin will create a
- * {@link gobblin.writer.DataWriter} per partition. All partitions will be build with identical builders, except
+ * {@link org.apache.gobblin.writer.DataWriter} per partition. All partitions will be build with identical builders, except
  * that {@link #forPartition} will specify the partition.
  *
  * <p>

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core-base/src/main/java/org/apache/gobblin/writer/partitioner/WriterPartitioner.java
----------------------------------------------------------------------
diff --git a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/partitioner/WriterPartitioner.java b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/partitioner/WriterPartitioner.java
index 7246f47..22032e6 100644
--- a/gobblin-core-base/src/main/java/org/apache/gobblin/writer/partitioner/WriterPartitioner.java
+++ b/gobblin-core-base/src/main/java/org/apache/gobblin/writer/partitioner/WriterPartitioner.java
@@ -24,7 +24,7 @@ import org.apache.avro.generic.GenericRecord;
 /**
  * Partitions records in the writer phase.
  *
- * Implementations must have a constructor with signature <init>({@link gobblin.configuration.State}).
+ * Implementations must have a constructor with signature <init>({@link org.apache.gobblin.configuration.State}).
  */
 public interface WriterPartitioner<D> {
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core/src/main/java/org/apache/gobblin/commit/SpeculativeAttemptAwareConstruct.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/commit/SpeculativeAttemptAwareConstruct.java b/gobblin-core/src/main/java/org/apache/gobblin/commit/SpeculativeAttemptAwareConstruct.java
index 6bb5903..406fbe6 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/commit/SpeculativeAttemptAwareConstruct.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/commit/SpeculativeAttemptAwareConstruct.java
@@ -22,8 +22,8 @@ import org.apache.gobblin.annotation.Alpha;
 
 /**
  * A declaration by any Gobblin construct to claim whether it is safe to have multiple speculative attempts.
- * For example, if any {@link gobblin.writer.DataWriter} implements {@link SpeculativeAttemptAwareConstruct}
- * and returns true in {@link #isSpeculativeAttemptSafe()}, then multiple attempts of one {@link gobblin.writer.DataWriter}
+ * For example, if any {@link org.apache.gobblin.writer.DataWriter} implements {@link SpeculativeAttemptAwareConstruct}
+ * and returns true in {@link #isSpeculativeAttemptSafe()}, then multiple attempts of one {@link org.apache.gobblin.writer.DataWriter}
  * should not cause conflict among them.
  */
 @Alpha

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core/src/main/java/org/apache/gobblin/converter/EmptyIterable.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/EmptyIterable.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/EmptyIterable.java
index c6aee6b..a080d53 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/converter/EmptyIterable.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/EmptyIterable.java
@@ -18,7 +18,7 @@
 package org.apache.gobblin.converter;
 
 /**
- * @deprecated. Please use {@link gobblin.util.EmptyIterable} instead.
+ * @deprecated. Please use {@link org.apache.gobblin.util.EmptyIterable} instead.
  */
 @Deprecated
 public class EmptyIterable<T> extends gobblin.util.EmptyIterable<T> {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core/src/main/java/org/apache/gobblin/converter/GobblinMetricsPinotFlattenerConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/GobblinMetricsPinotFlattenerConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/GobblinMetricsPinotFlattenerConverter.java
index 3a9526b..ed230ed 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/converter/GobblinMetricsPinotFlattenerConverter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/GobblinMetricsPinotFlattenerConverter.java
@@ -37,7 +37,7 @@ import lombok.extern.slf4j.Slf4j;
 
 
 /**
- * Flatten {@link gobblin.metrics.MetricReport} for use by Pinot.
+ * Flatten {@link org.apache.gobblin.metrics.MetricReport} for use by Pinot.
  * The output schema can be found at "gobblin-metrics/src/main/avro/FlatGobblinMetric.avsc".
  */
 @Slf4j

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroRecordToAvroWritableConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroRecordToAvroWritableConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroRecordToAvroWritableConverter.java
index b1d8079..3eda169 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroRecordToAvroWritableConverter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroRecordToAvroWritableConverter.java
@@ -34,7 +34,7 @@ import org.apache.gobblin.converter.SchemaConversionException;
 
 /**
  * A {@link Converter} that takes an Avro {@link GenericRecord} and converts it to {@link AvroGenericRecordWritable}.
- * This class is useful for integration with the {@link gobblin.converter.serde.HiveSerDeConverter}, which expects input
+ * This class is useful for integration with the {@link org.apache.gobblin.converter.serde.HiveSerDeConverter}, which expects input
  * records to be of type {@link org.apache.hadoop.io.Writable}.
  */
 public class AvroRecordToAvroWritableConverter

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroToAvroCopyableConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroToAvroCopyableConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroToAvroCopyableConverter.java
index 13d1d0a..28e9057 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroToAvroCopyableConverter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/avro/AvroToAvroCopyableConverter.java
@@ -31,13 +31,13 @@ import org.apache.gobblin.fork.CopyableSchema;
 
 /**
  * Implementation of {@link Converter} that takes in an Avro {@link Schema} and {@link GenericRecord} and returns a
- * {@link gobblin.fork.CopyableSchema} and a {@link gobblin.fork.CopyableGenericRecord}.
+ * {@link org.apache.gobblin.fork.CopyableSchema} and a {@link org.apache.gobblin.fork.CopyableGenericRecord}.
  */
 public class AvroToAvroCopyableConverter extends
     Converter<Schema, CopyableSchema, GenericRecord, CopyableGenericRecord> {
 
   /**
-   * Returns a {@link gobblin.fork.CopyableSchema} wrapper around the given {@link Schema}.
+   * Returns a {@link org.apache.gobblin.fork.CopyableSchema} wrapper around the given {@link Schema}.
    * {@inheritDoc}
    * @see gobblin.converter.Converter#convertSchema(java.lang.Object, gobblin.configuration.WorkUnitState)
    */
@@ -47,7 +47,7 @@ public class AvroToAvroCopyableConverter extends
   }
 
   /**
-   * Returns a {@link gobblin.fork.CopyableGenericRecord} wrapper around the given {@link GenericRecord}.
+   * Returns a {@link org.apache.gobblin.fork.CopyableGenericRecord} wrapper around the given {@link GenericRecord}.
    * {@inheritDoc}
    * @see gobblin.converter.Converter#convertRecord(java.lang.Object, java.lang.Object, gobblin.configuration.WorkUnitState)
    */

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core/src/main/java/org/apache/gobblin/converter/filter/AvroFilterConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/converter/filter/AvroFilterConverter.java b/gobblin-core/src/main/java/org/apache/gobblin/converter/filter/AvroFilterConverter.java
index a67cee0..42e81a4 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/converter/filter/AvroFilterConverter.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/converter/filter/AvroFilterConverter.java
@@ -75,7 +75,7 @@ public class AvroFilterConverter extends AvroToAvroConverterBase {
 
   /**
    * Retrieves the specified field from the inputRecord, and checks if it is equal to the expected value
-   * {@link #fieldValue}. If it is then it returns a {@link gobblin.converter.SingleRecordIterable} for the input record.
+   * {@link #fieldValue}. If it is then it returns a {@link org.apache.gobblin.converter.SingleRecordIterable} for the input record.
    * Otherwise it returns a {@link EmptyIterable}.
    * {@inheritDoc}
    * @see gobblin.converter.AvroToAvroConverterBase#convertRecord(org.apache.avro.Schema, org.apache.avro.generic.GenericRecord, gobblin.configuration.WorkUnitState)

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core/src/main/java/org/apache/gobblin/publisher/BaseDataPublisher.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/publisher/BaseDataPublisher.java b/gobblin-core/src/main/java/org/apache/gobblin/publisher/BaseDataPublisher.java
index 0a3408e..5e1a731 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/publisher/BaseDataPublisher.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/publisher/BaseDataPublisher.java
@@ -72,7 +72,7 @@ import org.apache.gobblin.writer.PartitionIdentifier;
  * {@link ConfigurationKeys#WRITER_FILE_PATH}. Then the final output data for a writer will be
  * {@link ConfigurationKeys#DATA_PUBLISHER_FINAL_DIR}/{@link ConfigurationKeys#WRITER_FILE_PATH}. If the
  * {@link ConfigurationKeys#WRITER_FILE_PATH} is not specified, a default one is assigned. The default path is
- * constructed in the {@link gobblin.source.workunit.Extract#getOutputFilePath()} method.
+ * constructed in the {@link org.apache.gobblin.source.workunit.Extract#getOutputFilePath()} method.
  * </p>
  *
  * <p>

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicyChecker.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicyChecker.java b/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicyChecker.java
index 5c92347..5312828 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicyChecker.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/row/RowLevelPolicyChecker.java
@@ -116,9 +116,9 @@ public class RowLevelPolicyChecker<S, D> implements Closeable, FinalState, Recor
 
   /**
    * Get final state for this object, obtained by merging the final states of the
-   * {@link gobblin.qualitychecker.row.RowLevelPolicy}s used by this object.
-   * @return Merged {@link gobblin.configuration.State} of final states for
-   *                {@link gobblin.qualitychecker.row.RowLevelPolicy} used by this checker.
+   * {@link org.apache.gobblin.qualitychecker.row.RowLevelPolicy}s used by this object.
+   * @return Merged {@link org.apache.gobblin.configuration.State} of final states for
+   *                {@link org.apache.gobblin.qualitychecker.row.RowLevelPolicy} used by this checker.
    */
   @Override
   public State getFinalState() {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core/src/main/java/org/apache/gobblin/source/DatePartitionedAvroFileSource.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/DatePartitionedAvroFileSource.java b/gobblin-core/src/main/java/org/apache/gobblin/source/DatePartitionedAvroFileSource.java
index c3e9d08..7e61d91 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/DatePartitionedAvroFileSource.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/DatePartitionedAvroFileSource.java
@@ -30,7 +30,7 @@ import org.apache.gobblin.writer.partitioner.TimeBasedAvroWriterPartitioner;
 
 
 /**
- * Implementation of {@link gobblin.source.Source} that reads over date-partitioned Avro data.
+ * Implementation of {@link org.apache.gobblin.source.Source} that reads over date-partitioned Avro data.
  * This source can be regarded as the reader equivalent of {@link TimeBasedAvroWriterPartitioner}.
  *
  * <p>

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core/src/main/java/org/apache/gobblin/source/DatePartitionedDailyAvroSource.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/DatePartitionedDailyAvroSource.java b/gobblin-core/src/main/java/org/apache/gobblin/source/DatePartitionedDailyAvroSource.java
index 85ceb88..f2b53b3 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/DatePartitionedDailyAvroSource.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/DatePartitionedDailyAvroSource.java
@@ -18,7 +18,7 @@ import org.apache.gobblin.util.DatePartitionType;
 
 
 /**
- * Implementation of {@link gobblin.source.Source} that reads over date-partitioned Avro data.
+ * Implementation of {@link org.apache.gobblin.source.Source} that reads over date-partitioned Avro data.
  *
  * <p>
  *

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/DatePartitionedAvroFileExtractor.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/DatePartitionedAvroFileExtractor.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/DatePartitionedAvroFileExtractor.java
index 51af03a..7da1fb9 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/DatePartitionedAvroFileExtractor.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/DatePartitionedAvroFileExtractor.java
@@ -23,7 +23,7 @@ import org.apache.gobblin.source.extractor.hadoop.AvroFileExtractor;
 
 /**
  * Extension of {@link AvroFileExtractor} where the {@link #getHighWatermark()} method returns the result of the
- * specified WorkUnit's {@link gobblin.source.workunit.WorkUnit#getHighWaterMark()} method.
+ * specified WorkUnit's {@link org.apache.gobblin.source.workunit.WorkUnit#getHighWaterMark()} method.
  */
 public class DatePartitionedAvroFileExtractor extends AvroFileExtractor {
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/QueryBasedSource.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/QueryBasedSource.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/QueryBasedSource.java
index 5e016da..fa5a360 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/QueryBasedSource.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/QueryBasedSource.java
@@ -65,7 +65,7 @@ import lombok.extern.slf4j.Slf4j;
 
 
 /**
- * A base implementation of {@link gobblin.source.Source} for
+ * A base implementation of {@link org.apache.gobblin.source.Source} for
  * query-based sources.
  */
 @Slf4j

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/HadoopFileInputSource.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/HadoopFileInputSource.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/HadoopFileInputSource.java
index ef8ada0..98a5c52 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/HadoopFileInputSource.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/HadoopFileInputSource.java
@@ -47,7 +47,7 @@ import org.apache.gobblin.util.HadoopUtils;
 
 
 /**
- * An implementation of {@link gobblin.source.Source} that uses a Hadoop {@link FileInputFormat} to get a
+ * An implementation of {@link org.apache.gobblin.source.Source} that uses a Hadoop {@link FileInputFormat} to get a
  * {@link FileSplit} per {@link Extractor} return by {@link #getExtractor(WorkUnitState)} and a
  * {@link RecordReader} to read the {@link FileSplit}.
  *

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/OldApiHadoopFileInputSource.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/OldApiHadoopFileInputSource.java b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/OldApiHadoopFileInputSource.java
index 85e7cf6..001afb3 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/OldApiHadoopFileInputSource.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/OldApiHadoopFileInputSource.java
@@ -46,7 +46,7 @@ import org.apache.gobblin.util.HadoopUtils;
 
 
 /**
- * An implementation of {@link gobblin.source.Source} that uses a Hadoop {@link FileInputFormat} to get a
+ * An implementation of {@link org.apache.gobblin.source.Source} that uses a Hadoop {@link FileInputFormat} to get a
  * {@link FileSplit} per {@link Extractor} return by {@link #getExtractor(WorkUnitState)} and a
  * {@link RecordReader} to read the {@link FileSplit}.
  *

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core/src/main/java/org/apache/gobblin/util/TestUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/util/TestUtils.java b/gobblin-core/src/main/java/org/apache/gobblin/util/TestUtils.java
index 26e980a..7ae7572 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/util/TestUtils.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/util/TestUtils.java
@@ -33,7 +33,7 @@ import org.apache.gobblin.source.workunit.WorkUnit;
 public class TestUtils {
 
   /**
-   * Create a {@link WorkUnitState} with a {@link gobblin.broker.iface.SharedResourcesBroker} for running unit tests of
+   * Create a {@link WorkUnitState} with a {@link org.apache.gobblin.broker.iface.SharedResourcesBroker} for running unit tests of
    * constructs.
    */
   public static WorkUnitState createTestWorkUnitState() {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core/src/main/java/org/apache/gobblin/writer/FsDataWriterBuilder.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/FsDataWriterBuilder.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/FsDataWriterBuilder.java
index 76757c3..b034174 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/FsDataWriterBuilder.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/FsDataWriterBuilder.java
@@ -50,7 +50,7 @@ public abstract class FsDataWriterBuilder<S, D> extends PartitionAwareDataWriter
   private List<StreamCodec> encoders;
 
   /**
-   * Get the file name to be used by the writer. If a {@link gobblin.writer.partitioner.WriterPartioner} is used,
+   * Get the file name to be used by the writer. If a {@link org.apache.gobblin.writer.partitioner.WriterPartioner} is used,
    * the partition will be added as part of the file name.
    */
   public String getFileName(State properties) {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core/src/main/java/org/apache/gobblin/writer/SimpleDataWriterBuilder.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/main/java/org/apache/gobblin/writer/SimpleDataWriterBuilder.java b/gobblin-core/src/main/java/org/apache/gobblin/writer/SimpleDataWriterBuilder.java
index c81daa7..903a40d 100644
--- a/gobblin-core/src/main/java/org/apache/gobblin/writer/SimpleDataWriterBuilder.java
+++ b/gobblin-core/src/main/java/org/apache/gobblin/writer/SimpleDataWriterBuilder.java
@@ -38,9 +38,9 @@ import org.apache.gobblin.crypto.EncryptionFactory;
  */
 public class SimpleDataWriterBuilder extends FsDataWriterBuilder<String, Object> {
   /**
-   * Build a {@link gobblin.writer.DataWriter}.
+   * Build a {@link org.apache.gobblin.writer.DataWriter}.
    *
-   * @return the built {@link gobblin.writer.DataWriter}
+   * @return the built {@link org.apache.gobblin.writer.DataWriter}
    * @throws java.io.IOException if there is anything wrong building the writer
    */
   @Override

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-core/src/test/java/org/apache/gobblin/writer/PartitionedWriterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/writer/PartitionedWriterTest.java b/gobblin-core/src/test/java/org/apache/gobblin/writer/PartitionedWriterTest.java
index 6db9cf9..3d5923d 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/writer/PartitionedWriterTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/writer/PartitionedWriterTest.java
@@ -41,7 +41,7 @@ import static org.mockito.Mockito.when;
 
 
 /**
- * Test {@link gobblin.writer.PartitionedDataWriter}
+ * Test {@link org.apache.gobblin.writer.PartitionedDataWriter}
  */
 public class PartitionedWriterTest {
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveBaseExtractor.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveBaseExtractor.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveBaseExtractor.java
index 107fa89..3bdcbb8 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveBaseExtractor.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/extractor/HiveBaseExtractor.java
@@ -29,7 +29,7 @@ import org.apache.gobblin.source.extractor.Extractor;
 
 
 /**
- * Base {@link Extractor} for extracting from {@link gobblin.data.management.conversion.hive.source.HiveSource}
+ * Base {@link Extractor} for extracting from {@link org.apache.gobblin.data.management.conversion.hive.source.HiveSource}
  */
 public abstract class HiveBaseExtractor<S, D> implements Extractor<S, D> {
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/ConcurrentBoundedWorkUnitList.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/ConcurrentBoundedWorkUnitList.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/ConcurrentBoundedWorkUnitList.java
index ce1d136..47462b7 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/ConcurrentBoundedWorkUnitList.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/ConcurrentBoundedWorkUnitList.java
@@ -38,10 +38,10 @@ import lombok.extern.slf4j.Slf4j;
 /**
  * A {@link WorkUnit} container that is bounded, supports concurrent all-or-nothing addAll, and supports priority of
  * file sets, ie. attempting to add a file set with higher priority will automatically evict
- * lower priority {@link gobblin.data.management.partition.FileSet}s if necessary.
+ * lower priority {@link org.apache.gobblin.data.management.partition.FileSet}s if necessary.
  *
  * <p>
- *   File sets in {@link CopySource} are handled as {@link gobblin.data.management.partition.FileSet}, so this class uses a {@link gobblin.data.management.partition.FileSet} comparator
+ *   File sets in {@link CopySource} are handled as {@link org.apache.gobblin.data.management.partition.FileSet}, so this class uses a {@link org.apache.gobblin.data.management.partition.FileSet} comparator
  *   for priority. If fileSetA < fileSetB, then fileSetA has higher priority than fileSetB
  *   (similar to {@link java.util.PriorityQueue}).
  * </p>
@@ -82,7 +82,7 @@ class ConcurrentBoundedWorkUnitList {
   /**
    * Creates a new {@link ConcurrentBoundedWorkUnitList}.
    * @param maxSize Maximum number of {@link WorkUnit}s to contain.
-   * @param comparator {@link Comparator} for {@link gobblin.data.management.partition.FileSet}s to use for {@link gobblin.data.management.partition.FileSet} priority.
+   * @param comparator {@link Comparator} for {@link org.apache.gobblin.data.management.partition.FileSet}s to use for {@link org.apache.gobblin.data.management.partition.FileSet} priority.
    * @param strictLimitMultiplier the list will only start rejecting {@link WorkUnit}s if its capacity exceeds
    *                              maxSize * strictLimitMultiplier. If this parameter is < 1, it will be auto-set to 1.
    */
@@ -101,7 +101,7 @@ class ConcurrentBoundedWorkUnitList {
 
   /**
    * Add a file set to the container.
-   * @param fileSet File set, expressed as a {@link gobblin.data.management.partition.FileSet} of {@link CopyEntity}s.
+   * @param fileSet File set, expressed as a {@link org.apache.gobblin.data.management.partition.FileSet} of {@link CopyEntity}s.
    * @param workUnits List of {@link WorkUnit}s corresponding to this file set.
    * @return true if the file set was added to the container, false otherwise (i.e. has reached max size).
    */

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/CopyResourcePool.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/CopyResourcePool.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/CopyResourcePool.java
index 1a5a65e..553bd00 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/CopyResourcePool.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/CopyResourcePool.java
@@ -92,7 +92,7 @@ public class CopyResourcePool extends ResourcePool {
     }
 
     /**
-     * Set number of {@link CopyEntity}s in {@link gobblin.data.management.partition.FileSet}.
+     * Set number of {@link CopyEntity}s in {@link org.apache.gobblin.data.management.partition.FileSet}.
      */
     public CopyResourceRequirementBuilder setEntities(int numberOfEntities) {
       setRequirement(ENTITIES_DIMENSION, (double) numberOfEntities);
@@ -100,7 +100,7 @@ public class CopyResourcePool extends ResourcePool {
     }
 
     /**
-     * Set total bytes to copy in {@link gobblin.data.management.partition.FileSet}.
+     * Set total bytes to copy in {@link org.apache.gobblin.data.management.partition.FileSet}.
      */
     public CopyResourceRequirementBuilder setBytes(long totalBytes) {
       setRequirement(BYTES_DIMENSION, (double) totalBytes);

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/CopySource.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/CopySource.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/CopySource.java
index 6e78215..5dd7f85 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/CopySource.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/CopySource.java
@@ -93,7 +93,7 @@ import lombok.extern.slf4j.Slf4j;
 
 
 /**
- * {@link gobblin.source.Source} that generates work units from {@link gobblin.data.management.copy.CopyableDataset}s.
+ * {@link org.apache.gobblin.source.Source} that generates work units from {@link org.apache.gobblin.data.management.copy.CopyableDataset}s.
  *
  */
 @Slf4j
@@ -132,7 +132,7 @@ public class CopySource extends AbstractSource<String, FileAwareInputStream> {
    * and writers are built to support multiple {@link CopyEntity}s per workunit
    * </p>
    *
-   * @param state see {@link gobblin.configuration.SourceState}
+   * @param state see {@link org.apache.gobblin.configuration.SourceState}
    * @return Work units for copying files.
    */
   @Override
@@ -312,7 +312,7 @@ public class CopySource extends AbstractSource<String, FileAwareInputStream> {
   }
 
   /**
-   * @param state a {@link gobblin.configuration.WorkUnitState} carrying properties needed by the returned
+   * @param state a {@link org.apache.gobblin.configuration.WorkUnitState} carrying properties needed by the returned
    *          {@link Extractor}
    * @return a {@link FileAwareInputStreamExtractor}.
    * @throws IOException

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/CopyableDataset.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/CopyableDataset.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/CopyableDataset.java
index f8bd006..9cdafb7 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/CopyableDataset.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/CopyableDataset.java
@@ -35,14 +35,14 @@ public interface CopyableDataset extends CopyableDatasetBase {
    *
    * <p>
    *   This method should return a collection of {@link CopyEntity}, each describing one work unit for distcp.
-   *   The most common {@link CopyEntity} is the {@link gobblin.data.management.copy.CopyableDataset}, describing a file
+   *   The most common {@link CopyEntity} is the {@link org.apache.gobblin.data.management.copy.CopyableDataset}, describing a file
    *   that should be copied
    *   to the target.
    *   See {@link CopyableFile} for explanation of the information contained in the {@link CopyableFile}s.
    * </p>
    *
    * @param targetFs target {@link org.apache.hadoop.fs.FileSystem} where copied files will be placed.
-   * @param configuration {@link gobblin.data.management.copy.CopyConfiguration} for this job. See {@link gobblin.data.management.copy.CopyConfiguration}.
+   * @param configuration {@link org.apache.gobblin.data.management.copy.CopyConfiguration} for this job. See {@link org.apache.gobblin.data.management.copy.CopyConfiguration}.
    * @return List of {@link CopyEntity}s in this dataset.
    * @throws IOException
    */

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/CopyableGlobDatasetFinder.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/CopyableGlobDatasetFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/CopyableGlobDatasetFinder.java
index 7c036f5..a08204d 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/CopyableGlobDatasetFinder.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/CopyableGlobDatasetFinder.java
@@ -27,8 +27,8 @@ import org.apache.hadoop.fs.Path;
 
 
 /**
- * {@link gobblin.data.management.retention.profile.ConfigurableGlobDatasetFinder} that returns datasets of type
- * {@link gobblin.data.management.copy.RecursiveCopyableDataset}.N
+ * {@link org.apache.gobblin.data.management.retention.profile.ConfigurableGlobDatasetFinder} that returns datasets of type
+ * {@link org.apache.gobblin.data.management.copy.RecursiveCopyableDataset}.N
  */
 public class CopyableGlobDatasetFinder extends ConfigurableGlobDatasetFinder<CopyableDataset> {
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/IterableCopyableDataset.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/IterableCopyableDataset.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/IterableCopyableDataset.java
index 870037a..9d8b412 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/IterableCopyableDataset.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/IterableCopyableDataset.java
@@ -35,7 +35,7 @@ public interface IterableCopyableDataset extends CopyableDatasetBase {
    * Get an iterator of {@link FileSet}s of {@link CopyEntity}, each one representing a group of files to copy and
    * associated actions.
    * @param targetFs target {@link org.apache.hadoop.fs.FileSystem} where copied files will be placed.
-   * @param configuration {@link gobblin.data.management.copy.CopyConfiguration} for this job. See {@link gobblin.data.management.copy.CopyConfiguration}.
+   * @param configuration {@link org.apache.gobblin.data.management.copy.CopyConfiguration} for this job. See {@link org.apache.gobblin.data.management.copy.CopyConfiguration}.
    * @throws IOException
    */
   public Iterator<FileSet<CopyEntity>> getFileSetIterator(FileSystem targetFs, CopyConfiguration configuration)

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/OwnerAndPermission.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/OwnerAndPermission.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/OwnerAndPermission.java
index 7ed2a95..c7c5185 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/OwnerAndPermission.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/OwnerAndPermission.java
@@ -58,7 +58,7 @@ public class OwnerAndPermission implements Writable {
   }
 
   /**
-   * Read a {@link gobblin.data.management.copy.OwnerAndPermission} from a {@link java.io.DataInput}.
+   * Read a {@link org.apache.gobblin.data.management.copy.OwnerAndPermission} from a {@link java.io.DataInput}.
    * @throws IOException
    */
   public static OwnerAndPermission read(DataInput input) throws IOException {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/extractor/FileAwareInputStreamExtractor.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/extractor/FileAwareInputStreamExtractor.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/extractor/FileAwareInputStreamExtractor.java
index 9ba28b5..5e53344 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/extractor/FileAwareInputStreamExtractor.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/extractor/FileAwareInputStreamExtractor.java
@@ -35,7 +35,7 @@ import org.apache.hadoop.fs.FileSystem;
 /**
  * An implementation of {@link Extractor} that extracts {@link InputStream}s. This extractor is suitable for copy jobs
  * where files from any source to a sink. The extractor extracts a {@link FileAwareInputStream} which encompasses an
- * {@link InputStream} and a {@link gobblin.data.management.copy.CopyEntity} for every file that needs to be copied.
+ * {@link InputStream} and a {@link org.apache.gobblin.data.management.copy.CopyEntity} for every file that needs to be copied.
  *
  * <p>
  * In Gobblin {@link Extractor} terms, each {@link FileAwareInputStream} is a record. i.e one record per copyable file.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/hive/avro/HiveAvroCopyEntityHelper.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/hive/avro/HiveAvroCopyEntityHelper.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/hive/avro/HiveAvroCopyEntityHelper.java
index a845581..5166b60 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/hive/avro/HiveAvroCopyEntityHelper.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/hive/avro/HiveAvroCopyEntityHelper.java
@@ -36,7 +36,7 @@ import org.apache.gobblin.util.PathUtils;
 
 
 /**
- * Update avro related entries in creating {@link gobblin.data.management.copy.CopyEntity}s for copying a Hive table.
+ * Update avro related entries in creating {@link org.apache.gobblin.data.management.copy.CopyEntity}s for copying a Hive table.
  */
 
 @Slf4j

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/prioritization/PrioritizedCopyableDataset.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/prioritization/PrioritizedCopyableDataset.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/prioritization/PrioritizedCopyableDataset.java
index 90580c6..4bac99a 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/prioritization/PrioritizedCopyableDataset.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/prioritization/PrioritizedCopyableDataset.java
@@ -31,7 +31,7 @@ import org.apache.gobblin.util.request_allocation.PushDownRequestor;
 
 
 /**
- * An {@link IterableCopyableDataset} where {@link gobblin.data.management.partition.FileSet}s generated by
+ * An {@link IterableCopyableDataset} where {@link org.apache.gobblin.data.management.partition.FileSet}s generated by
  * {@link #getFileSetIterator(FileSystem, CopyConfiguration)} are guaranteed to be ordered by the prioritizer at
  * {@link CopyConfiguration#getPrioritizer()}.
  */
@@ -40,12 +40,12 @@ public interface PrioritizedCopyableDataset extends IterableCopyableDataset {
   /**
    * Get an iterator of {@link FileSet}s of {@link CopyEntity}, each one representing a group of files to copy and
    * associated actions, sorted by the input {@link Comparator},
-   * and with the provided {@link gobblin.util.request_allocation.Requestor} injected (this is important for pushdown).
+   * and with the provided {@link org.apache.gobblin.util.request_allocation.Requestor} injected (this is important for pushdown).
    *
    * @param targetFs target {@link org.apache.hadoop.fs.FileSystem} where copied files will be placed.
-   * @param configuration {@link gobblin.data.management.copy.CopyConfiguration} for this job. See {@link gobblin.data.management.copy.CopyConfiguration}.
+   * @param configuration {@link org.apache.gobblin.data.management.copy.CopyConfiguration} for this job. See {@link org.apache.gobblin.data.management.copy.CopyConfiguration}.
    * @param prioritizer output {@link FileSet}s must be sorted by this {@link Comparator}.
-   * @param requestor the {@link gobblin.util.request_allocation.Requestor} object that all {@link FileSet}s should have.
+   * @param requestor the {@link org.apache.gobblin.util.request_allocation.Requestor} object that all {@link FileSet}s should have.
    * @throws IOException
    */
   public Iterator<FileSet<CopyEntity>> getFileSetIterator(FileSystem targetFs, CopyConfiguration configuration,

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/publisher/CopyDataPublisher.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/publisher/CopyDataPublisher.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/publisher/CopyDataPublisher.java
index b961faa..dc57039 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/publisher/CopyDataPublisher.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/publisher/CopyDataPublisher.java
@@ -66,7 +66,7 @@ import org.apache.gobblin.util.WriterUtils;
 import lombok.extern.slf4j.Slf4j;
 
 /**
- * A {@link DataPublisher} to {@link gobblin.data.management.copy.CopyEntity}s from task output to final destination.
+ * A {@link DataPublisher} to {@link org.apache.gobblin.data.management.copy.CopyEntity}s from task output to final destination.
  */
 @Slf4j
 public class CopyDataPublisher extends DataPublisher implements UnpublishedHandling {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/publisher/CopyEventSubmitterHelper.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/publisher/CopyEventSubmitterHelper.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/publisher/CopyEventSubmitterHelper.java
index a51257d..3c8d97a 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/publisher/CopyEventSubmitterHelper.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/publisher/CopyEventSubmitterHelper.java
@@ -57,7 +57,7 @@ public class CopyEventSubmitterHelper {
   }
 
   /**
-   * Submit an sla event when a {@link gobblin.data.management.copy.CopyableFile} is published. The <code>workUnitState</code> passed should have the
+   * Submit an sla event when a {@link org.apache.gobblin.data.management.copy.CopyableFile} is published. The <code>workUnitState</code> passed should have the
    * required {@link SlaEventKeys} set.
    *
    * @see SlaEventSubmitter#submit()

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/recovery/RecoveryHelper.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/recovery/RecoveryHelper.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/recovery/RecoveryHelper.java
index e688ba6..c193922 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/recovery/RecoveryHelper.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/recovery/RecoveryHelper.java
@@ -79,7 +79,7 @@ public class RecoveryHelper {
    * persisted file.
    *
    * @param state {@link State} containing job information.
-   * @param file {@link gobblin.data.management.copy.CopyEntity} from which input {@link Path} originated.
+   * @param file {@link org.apache.gobblin.data.management.copy.CopyEntity} from which input {@link Path} originated.
    * @param path {@link Path} to persist.
    * @return true if persist was successful.
    * @throws IOException
@@ -109,11 +109,11 @@ public class RecoveryHelper {
   }
 
   /**
-   * Searches the persist directory to find {@link Path}s matching the input {@link gobblin.data.management.copy.CopyEntity}.
+   * Searches the persist directory to find {@link Path}s matching the input {@link org.apache.gobblin.data.management.copy.CopyEntity}.
    * @param state {@link State} containing job information.
-   * @param file {@link gobblin.data.management.copy.CopyEntity} for which persisted {@link Path}s should be found.
+   * @param file {@link org.apache.gobblin.data.management.copy.CopyEntity} for which persisted {@link Path}s should be found.
    * @param filter {@link com.google.common.base.Predicate} used to filter found paths.
-   * @return Optionally, a {@link Path} in the {@link FileSystem} that is the desired copy of the {@link gobblin.data.management.copy.CopyEntity}.
+   * @return Optionally, a {@link Path} in the {@link FileSystem} that is the desired copy of the {@link org.apache.gobblin.data.management.copy.CopyEntity}.
    * @throws IOException
    */
   public Optional<FileStatus> findPersistedFile(State state, CopyEntity file, Predicate<FileStatus> filter)

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/writer/FileAwareInputStreamDataWriter.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/writer/FileAwareInputStreamDataWriter.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/writer/FileAwareInputStreamDataWriter.java
index ec9eea1..1c7ab78 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/writer/FileAwareInputStreamDataWriter.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/writer/FileAwareInputStreamDataWriter.java
@@ -102,7 +102,7 @@ public class FileAwareInputStreamDataWriter extends InstrumentedDataWriter<FileA
   protected final Optional<String> writerAttemptIdOptional;
   /**
    * The copyable file in the WorkUnit might be modified by converters (e.g. output extensions added / removed).
-   * This field is set when {@link #write} is called, and points to the actual, possibly modified {@link gobblin.data.management.copy.CopyEntity}
+   * This field is set when {@link #write} is called, and points to the actual, possibly modified {@link org.apache.gobblin.data.management.copy.CopyEntity}
    * that was written by this writer.
    */
   protected Optional<CopyableFile> actualProcessedCopyableFile;
@@ -180,7 +180,7 @@ public class FileAwareInputStreamDataWriter extends InstrumentedDataWriter<FileA
    *
    * @param inputStream {@link FSDataInputStream} whose contents should be written to staging path.
    * @param writeAt {@link Path} at which contents should be written.
-   * @param copyableFile {@link gobblin.data.management.copy.CopyEntity} that generated this copy operation.
+   * @param copyableFile {@link org.apache.gobblin.data.management.copy.CopyEntity} that generated this copy operation.
    * @throws IOException
    */
   protected void writeImpl(InputStream inputStream, Path writeAt, CopyableFile copyableFile)

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/SimpleDatasetHierarchicalPrioritizer.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/SimpleDatasetHierarchicalPrioritizer.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/SimpleDatasetHierarchicalPrioritizer.java
index 37bc4fd..327fb74 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/SimpleDatasetHierarchicalPrioritizer.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/SimpleDatasetHierarchicalPrioritizer.java
@@ -42,7 +42,7 @@ import org.apache.gobblin.util.request_allocation.SimpleHierarchicalPrioritizer;
  *
  *  1-1-1 mapping between {@link Dataset} - {@link SimpleDatasetRequest} - {@link SimpleDatasetRequestor}
  *
- * {@link gobblin.util.request_allocation.HierarchicalAllocator} will use {@link TierComparator} from this class
+ * {@link org.apache.gobblin.util.request_allocation.HierarchicalAllocator} will use {@link TierComparator} from this class
  * to shuffle {@link SimpleDatasetRequestor}s so that high priority tiers will appear in front of low priority tiers.
  *
  * Usage:

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/SimpleDatasetRequestor.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/SimpleDatasetRequestor.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/SimpleDatasetRequestor.java
index e58fe08..fc2c3f4 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/SimpleDatasetRequestor.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/SimpleDatasetRequestor.java
@@ -31,7 +31,7 @@ import org.apache.gobblin.dataset.Dataset;
 import org.apache.gobblin.util.request_allocation.PushDownRequestor;
 
 /**
- * A simple {@link gobblin.util.request_allocation.Requestor} used to generate a single {@link SimpleDatasetRequest}
+ * A simple {@link org.apache.gobblin.util.request_allocation.Requestor} used to generate a single {@link SimpleDatasetRequest}
  */
 @AllArgsConstructor
 public class SimpleDatasetRequestor implements PushDownRequestor<SimpleDatasetRequest> {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/hive/HiveRegistrableDataset.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/hive/HiveRegistrableDataset.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/hive/HiveRegistrableDataset.java
index 0145b82..f1a1c1a 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/hive/HiveRegistrableDataset.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/hive/HiveRegistrableDataset.java
@@ -32,7 +32,7 @@ import org.apache.gobblin.hive.spec.HiveSpec;
 public interface HiveRegistrableDataset extends Dataset {
 
   /**
-   * Get a list of {@link HiveSpec}s for this dataset, which can be used by {@link gobblin.hive.HiveRegister}
+   * Get a list of {@link HiveSpec}s for this dataset, which can be used by {@link org.apache.gobblin.hive.HiveRegister}
    * to register this dataset in Hive.
    */
   public List<HiveSpec> getHiveSpecs() throws IOException;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/partition/File.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/partition/File.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/partition/File.java
index b4461b8..de12dc1 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/partition/File.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/partition/File.java
@@ -23,7 +23,7 @@ import org.apache.hadoop.fs.FileStatus;
 /**
  * Interface representing a File.
  *
- * This interface is implemented by file abstractions such as {@link gobblin.data.management.copy.CopyEntity}.
+ * This interface is implemented by file abstractions such as {@link org.apache.gobblin.data.management.copy.CopyEntity}.
  *
  */
 public interface File {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/CombineSelectionPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/CombineSelectionPolicy.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/CombineSelectionPolicy.java
index e5e0860..b6377a0 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/CombineSelectionPolicy.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/CombineSelectionPolicy.java
@@ -45,7 +45,7 @@ import org.apache.gobblin.util.reflection.GobblinConstructorUtils;
 
 
 /**
- * Implementation of {@link gobblin.data.management.policy.VersionSelectionPolicy} that allows combining different
+ * Implementation of {@link org.apache.gobblin.data.management.policy.VersionSelectionPolicy} that allows combining different
  * policies through a union or intersect operation. It will combine the selected sets from each sub-policy using the
  * specified operation.
  *

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/CleanableDataset.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/CleanableDataset.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/CleanableDataset.java
index 61b6d6b..033d0aa 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/CleanableDataset.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/CleanableDataset.java
@@ -24,14 +24,14 @@ import java.io.IOException;
 
 
 /**
- * An abstraction for a set of files where a simple {@link gobblin.data.management.retention.policy.RetentionPolicy}
+ * An abstraction for a set of files where a simple {@link org.apache.gobblin.data.management.retention.policy.RetentionPolicy}
  * can be applied.
  */
 public interface CleanableDataset extends Dataset, FileSystemDataset {
 
   /**
    * Cleans the {@link CleanableDataset}. In general, this means to apply a
-   * {@link gobblin.data.management.retention.policy.RetentionPolicy} and delete files and directories that need deleting.
+   * {@link org.apache.gobblin.data.management.retention.policy.RetentionPolicy} and delete files and directories that need deleting.
    * @throws IOException
    */
   public void clean() throws IOException;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/177a42de/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/CleanableDatasetBase.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/CleanableDatasetBase.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/CleanableDatasetBase.java
index eb08f2b..be3d0c0 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/CleanableDatasetBase.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/CleanableDatasetBase.java
@@ -35,8 +35,8 @@ import org.apache.gobblin.dataset.FileSystemDataset;
 
 /**
  * Implementation of a {@link CleanableDataset} that uses a
- * {@link gobblin.data.management.retention.version.finder.VersionFinder} to find dataset versions, a
- * {@link gobblin.data.management.retention.policy.RetentionPolicy} to figure out deletable versions, and then deletes
+ * {@link org.apache.gobblin.data.management.retention.version.finder.VersionFinder} to find dataset versions, a
+ * {@link org.apache.gobblin.data.management.retention.policy.RetentionPolicy} to figure out deletable versions, and then deletes
  * those files and newly empty parent directories.
  *
  * <p>
@@ -75,26 +75,26 @@ import org.apache.gobblin.dataset.FileSystemDataset;
  * </p>
  *
  * <p>
- *  {@link CleanableDatasetBase} uses a {@link gobblin.data.management.version.finder.DatasetVersionFinder} to find all
+ *  {@link CleanableDatasetBase} uses a {@link org.apache.gobblin.data.management.version.finder.DatasetVersionFinder} to find all
  *  subdirectories that are versions of this dataset. After that, for each dataset, it uses a
- *  {@link gobblin.data.management.retention.policy.RetentionPolicy} to decide which versions of the dataset should be
+ *  {@link org.apache.gobblin.data.management.retention.policy.RetentionPolicy} to decide which versions of the dataset should be
  *  deleted. For each version deleted, if {@link #deleteEmptyDirectories} it will also look at all parent directories
  *  and delete directories that are now empty, up to but not including the dataset root.
  * </p>
  *
- * @param <T> type of {@link gobblin.data.management.retention.version.DatasetVersion} supported by this
+ * @param <T> type of {@link org.apache.gobblin.data.management.retention.version.DatasetVersion} supported by this
  *           {@link CleanableDataset}.
  */
 public abstract class CleanableDatasetBase<T extends FileSystemDatasetVersion>
     extends MultiVersionCleanableDatasetBase<T> implements CleanableDataset, FileSystemDataset {
 
   /**
-   * Get {@link gobblin.data.management.retention.version.finder.VersionFinder} to use.
+   * Get {@link org.apache.gobblin.data.management.retention.version.finder.VersionFinder} to use.
    */
   public abstract VersionFinder<? extends T> getVersionFinder();
 
   /**
-   * Get {@link gobblin.data.management.retention.policy.RetentionPolicy} to use.
+   * Get {@link org.apache.gobblin.data.management.retention.policy.RetentionPolicy} to use.
    */
   public abstract RetentionPolicy<T> getRetentionPolicy();
 


Mime
View raw message