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();
