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:06 UTC
[48/77] [abbrv] incubator-gobblin git commit: Changed JavaDocs
references from gobblin to org.apache.gobblin package
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();