http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/SpecExecutorInstance.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/SpecExecutorInstance.java b/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/SpecExecutorInstance.java index 3587f1a..47569f3 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/SpecExecutorInstance.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/SpecExecutorInstance.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.api; +package org.apache.gobblin.runtime.api; import java.net.URI; import java.util.Map; @@ -23,7 +23,7 @@ import java.util.concurrent.Future; import com.typesafe.config.Config; -import gobblin.annotation.Alpha; +import org.apache.gobblin.annotation.Alpha; /**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/SpecExecutorInstanceConsumer.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/SpecExecutorInstanceConsumer.java b/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/SpecExecutorInstanceConsumer.java index b209d3e..475c5af 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/SpecExecutorInstanceConsumer.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/SpecExecutorInstanceConsumer.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.runtime.api; +package org.apache.gobblin.runtime.api; import java.util.List; import java.util.concurrent.Future; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/SpecExecutorInstanceProducer.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/SpecExecutorInstanceProducer.java b/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/SpecExecutorInstanceProducer.java index b3f94f2..12508da 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/SpecExecutorInstanceProducer.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/runtime/api/SpecExecutorInstanceProducer.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package gobblin.runtime.api; +package org.apache.gobblin.runtime.api; import java.net.URI; import java.util.List; import java.util.concurrent.Future; -import gobblin.annotation.Alpha; +import org.apache.gobblin.annotation.Alpha; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/Source.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/Source.java b/gobblin-api/src/main/java/org/apache/gobblin/source/Source.java index ecc3917..7b9b82a 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/source/Source.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/source/Source.java @@ -15,15 +15,15 @@ * limitations under the License. */ -package gobblin.source; +package org.apache.gobblin.source; -import gobblin.configuration.SourceState; -import gobblin.configuration.WorkUnitState; +import org.apache.gobblin.configuration.SourceState; +import org.apache.gobblin.configuration.WorkUnitState; import java.io.IOException; import java.util.List; -import gobblin.source.extractor.Extractor; -import gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.source.extractor.Extractor; +import org.apache.gobblin.source.workunit.WorkUnit; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/WorkUnitStreamSource.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/WorkUnitStreamSource.java b/gobblin-api/src/main/java/org/apache/gobblin/source/WorkUnitStreamSource.java index 13d7049..2137ebc 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/source/WorkUnitStreamSource.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/source/WorkUnitStreamSource.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package gobblin.source; +package org.apache.gobblin.source; -import gobblin.configuration.SourceState; -import gobblin.source.workunit.WorkUnitStream; +import org.apache.gobblin.configuration.SourceState; +import org.apache.gobblin.source.workunit.WorkUnitStream; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/CheckpointableWatermark.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/CheckpointableWatermark.java b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/CheckpointableWatermark.java index 4d366b4..38673b8 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/CheckpointableWatermark.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/CheckpointableWatermark.java @@ -17,9 +17,9 @@ * under the License. */ -package gobblin.source.extractor; +package org.apache.gobblin.source.extractor; -import gobblin.annotation.Alpha; +import org.apache.gobblin.annotation.Alpha; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/ComparableWatermark.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/ComparableWatermark.java b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/ComparableWatermark.java index cc00e70..361f315 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/ComparableWatermark.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/ComparableWatermark.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor; +package org.apache.gobblin.source.extractor; /** * {@link Watermark} that is also {@link Comparable}. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/DataRecordException.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/DataRecordException.java b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/DataRecordException.java index 7f8915b..b1b66c0 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/DataRecordException.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/DataRecordException.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor; +package org.apache.gobblin.source.extractor; public class DataRecordException extends Exception { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/Extractor.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/Extractor.java b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/Extractor.java index fb3134a..6a1af0f 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/Extractor.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/Extractor.java @@ -15,15 +15,15 @@ * limitations under the License. */ -package gobblin.source.extractor; +package org.apache.gobblin.source.extractor; import java.io.Closeable; import java.io.IOException; import java.util.concurrent.atomic.AtomicBoolean; -import gobblin.records.RecordStreamWithMetadata; -import gobblin.stream.RecordEnvelope; -import gobblin.stream.StreamEntity; +import org.apache.gobblin.records.RecordStreamWithMetadata; +import org.apache.gobblin.stream.RecordEnvelope; +import org.apache.gobblin.stream.StreamEntity; import edu.umd.cs.findbugs.annotations.SuppressWarnings; import io.reactivex.Emitter; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/StreamingExtractor.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/StreamingExtractor.java b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/StreamingExtractor.java index 1b8328f..035bcdc 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/StreamingExtractor.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/StreamingExtractor.java @@ -17,12 +17,12 @@ * under the License. */ -package gobblin.source.extractor; +package org.apache.gobblin.source.extractor; import java.io.IOException; -import gobblin.annotation.Alpha; -import gobblin.writer.WatermarkStorage; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.writer.WatermarkStorage; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/Watermark.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/Watermark.java b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/Watermark.java index 5e61d37..391e876 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/Watermark.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/Watermark.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor; +package org.apache.gobblin.source.extractor; import com.google.gson.JsonElement; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/WatermarkInterval.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/WatermarkInterval.java b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/WatermarkInterval.java index 0e42220..37f70bd 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/WatermarkInterval.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/WatermarkInterval.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor; +package org.apache.gobblin.source.extractor; import com.google.gson.JsonElement; import com.google.gson.JsonObject; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/WatermarkSerializerHelper.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/WatermarkSerializerHelper.java b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/WatermarkSerializerHelper.java index 7d15745..e4ae0fc 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/WatermarkSerializerHelper.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/source/extractor/WatermarkSerializerHelper.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor; +package org.apache.gobblin.source.extractor; import com.google.gson.Gson; import com.google.gson.JsonElement; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/BasicWorkUnitStream.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/BasicWorkUnitStream.java b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/BasicWorkUnitStream.java index a143ace..0d07312 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/BasicWorkUnitStream.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/BasicWorkUnitStream.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.workunit; +package org.apache.gobblin.source.workunit; import java.util.Collection; import java.util.Iterator; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/Extract.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/Extract.java b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/Extract.java index 19a0f73..5161427 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/Extract.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/Extract.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.workunit; +package org.apache.gobblin.source.workunit; import java.util.List; import java.util.Locale; @@ -28,10 +28,10 @@ import org.joda.time.format.DateTimeFormatter; import com.google.common.base.Joiner; import com.google.common.base.Strings; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.SourceState; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.SourceState; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/ExtractFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/ExtractFactory.java b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/ExtractFactory.java index d0aae7a..53fff64 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/ExtractFactory.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/ExtractFactory.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.workunit; +package org.apache.gobblin.source.workunit; import java.util.Locale; import java.util.Set; @@ -28,7 +28,7 @@ import org.joda.time.format.DateTimeFormatter; import com.google.common.base.Strings; import com.google.common.collect.Sets; -import gobblin.source.workunit.Extract.TableType; +import org.apache.gobblin.source.workunit.Extract.TableType; public class ExtractFactory { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/ImmutableExtract.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/ImmutableExtract.java b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/ImmutableExtract.java index 480fe23..176019e 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/ImmutableExtract.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/ImmutableExtract.java @@ -15,14 +15,14 @@ * limitations under the License. */ -package gobblin.source.workunit; +package org.apache.gobblin.source.workunit; import java.io.DataInput; import java.io.IOException; import java.util.Properties; -import gobblin.configuration.SourceState; -import gobblin.configuration.State; +import org.apache.gobblin.configuration.SourceState; +import org.apache.gobblin.configuration.State; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/ImmutableWorkUnit.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/ImmutableWorkUnit.java b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/ImmutableWorkUnit.java index 1d80e8e..134d638 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/ImmutableWorkUnit.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/ImmutableWorkUnit.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package gobblin.source.workunit; +package org.apache.gobblin.source.workunit; import java.io.DataInput; import java.io.IOException; import java.util.Properties; -import gobblin.configuration.State; +import org.apache.gobblin.configuration.State; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/MissingExtractAttributeException.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/MissingExtractAttributeException.java b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/MissingExtractAttributeException.java index 1d42f5e..664919e 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/MissingExtractAttributeException.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/MissingExtractAttributeException.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.workunit; +package org.apache.gobblin.source.workunit; public class MissingExtractAttributeException extends Exception { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/MultiWorkUnit.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/MultiWorkUnit.java b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/MultiWorkUnit.java index abbfb71..834f4f3 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/MultiWorkUnit.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/MultiWorkUnit.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.workunit; +package org.apache.gobblin.source.workunit; import java.io.DataInput; import java.io.DataOutput; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnit.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnit.java b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnit.java index 55d00b3..21915a5 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnit.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnit.java @@ -15,11 +15,11 @@ * limitations under the License. */ -package gobblin.source.workunit; +package org.apache.gobblin.source.workunit; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.SourceState; -import gobblin.configuration.State; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.SourceState; +import org.apache.gobblin.configuration.State; import java.io.DataInput; import java.io.DataOutput; @@ -29,9 +29,9 @@ import com.google.gson.Gson; import com.google.gson.JsonElement; import com.google.gson.JsonParser; -import gobblin.source.extractor.Extractor; -import gobblin.source.extractor.Watermark; -import gobblin.source.extractor.WatermarkInterval; +import org.apache.gobblin.source.extractor.Extractor; +import org.apache.gobblin.source.extractor.Watermark; +import org.apache.gobblin.source.extractor.WatermarkInterval; import lombok.ToString; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnitBinPacker.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnitBinPacker.java b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnitBinPacker.java index a8dcf73..daa9273 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnitBinPacker.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnitBinPacker.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.workunit; +package org.apache.gobblin.source.workunit; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnitStream.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnitStream.java b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnitStream.java index ff4b0f2..dba630c 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnitStream.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnitStream.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.workunit; +package org.apache.gobblin.source.workunit; import java.util.Collection; import java.util.Iterator; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnitWeighter.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnitWeighter.java b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnitWeighter.java index ed191f0..a9db38c 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnitWeighter.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnitWeighter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.workunit; +package org.apache.gobblin.source.workunit; /** * Provides weights for {@link WorkUnit}s to use by a {@link WorkUnitBinPacker}. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/stream/ControlMessage.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/stream/ControlMessage.java b/gobblin-api/src/main/java/org/apache/gobblin/stream/ControlMessage.java index b556dff..242cb8d 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/stream/ControlMessage.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/stream/ControlMessage.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.stream; +package org.apache.gobblin.stream; /** * A {@link StreamEntity} used to send control messages through the ingestion pipeline. Most constructs will just http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/stream/FlushControlMessage.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/stream/FlushControlMessage.java b/gobblin-api/src/main/java/org/apache/gobblin/stream/FlushControlMessage.java index a44188a..8760754 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/stream/FlushControlMessage.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/stream/FlushControlMessage.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.stream; +package org.apache.gobblin.stream; import lombok.AllArgsConstructor; import lombok.EqualsAndHashCode; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/stream/RecordEnvelope.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/stream/RecordEnvelope.java b/gobblin-api/src/main/java/org/apache/gobblin/stream/RecordEnvelope.java index 338b4bf..edfa1f0 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/stream/RecordEnvelope.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/stream/RecordEnvelope.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package gobblin.stream; +package org.apache.gobblin.stream; -import gobblin.annotation.Alpha; -import gobblin.fork.CopyHelper; -import gobblin.fork.CopyNotSupportedException; -import gobblin.source.extractor.CheckpointableWatermark; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.fork.CopyHelper; +import org.apache.gobblin.fork.CopyNotSupportedException; +import org.apache.gobblin.source.extractor.CheckpointableWatermark; import javax.annotation.Nullable; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/stream/StreamEntity.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/stream/StreamEntity.java b/gobblin-api/src/main/java/org/apache/gobblin/stream/StreamEntity.java index 45c43d3..6168968 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/stream/StreamEntity.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/stream/StreamEntity.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.stream; +package org.apache.gobblin.stream; import java.io.Closeable; import java.util.List; @@ -23,8 +23,8 @@ import java.util.List; import com.google.common.base.Preconditions; import com.google.common.collect.Lists; -import gobblin.ack.Ackable; -import gobblin.ack.HierarchicalAckable; +import org.apache.gobblin.ack.Ackable; +import org.apache.gobblin.ack.HierarchicalAckable; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/testing/AssertWithBackoff.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/testing/AssertWithBackoff.java b/gobblin-api/src/main/java/org/apache/gobblin/testing/AssertWithBackoff.java index 06a261e..84504df 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/testing/AssertWithBackoff.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/testing/AssertWithBackoff.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.testing; +package org.apache.gobblin.testing; import java.util.concurrent.TimeoutException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/util/ClassAliasResolver.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/util/ClassAliasResolver.java b/gobblin-api/src/main/java/org/apache/gobblin/util/ClassAliasResolver.java index d76d32d..c7663d2 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/util/ClassAliasResolver.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/util/ClassAliasResolver.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.util; +package org.apache.gobblin.util; import java.util.List; import java.util.Map; @@ -29,7 +29,7 @@ import com.google.common.collect.ImmutableMap; import com.google.common.collect.Lists; import com.google.common.collect.Maps; -import gobblin.annotation.Alias; +import org.apache.gobblin.annotation.Alias; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/util/CompletedFuture.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/util/CompletedFuture.java b/gobblin-api/src/main/java/org/apache/gobblin/util/CompletedFuture.java index 9a42c25..3639cc7 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/util/CompletedFuture.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/util/CompletedFuture.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util; +package org.apache.gobblin.util; import java.util.concurrent.ExecutionException; import java.util.concurrent.Future; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/util/Decorator.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/util/Decorator.java b/gobblin-api/src/main/java/org/apache/gobblin/util/Decorator.java index 5a57a2e..2d5170e 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/util/Decorator.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/util/Decorator.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util; +package org.apache.gobblin.util; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/util/DecoratorUtils.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/util/DecoratorUtils.java b/gobblin-api/src/main/java/org/apache/gobblin/util/DecoratorUtils.java index 419527b..9b67347 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/util/DecoratorUtils.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/util/DecoratorUtils.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util; +package org.apache.gobblin.util; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/util/FinalState.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/util/FinalState.java b/gobblin-api/src/main/java/org/apache/gobblin/util/FinalState.java index f27e19a..2abff3f 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/util/FinalState.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/util/FinalState.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.util; +package org.apache.gobblin.util; -import gobblin.configuration.State; +import org.apache.gobblin.configuration.State; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/util/RecordCountProvider.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/util/RecordCountProvider.java b/gobblin-api/src/main/java/org/apache/gobblin/util/RecordCountProvider.java index 0e83c94..cb912b7 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/util/RecordCountProvider.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/util/RecordCountProvider.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.util; +package org.apache.gobblin.util; import java.util.Collection; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/writer/DataWriter.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/writer/DataWriter.java b/gobblin-api/src/main/java/org/apache/gobblin/writer/DataWriter.java index 613cd2b..0dcc888 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/writer/DataWriter.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/writer/DataWriter.java @@ -15,15 +15,15 @@ * limitations under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import java.io.Closeable; import java.io.Flushable; import java.io.IOException; -import gobblin.records.ControlMessageHandler; -import gobblin.records.FlushControlMessageHandler; -import gobblin.stream.RecordEnvelope; +import org.apache.gobblin.records.ControlMessageHandler; +import org.apache.gobblin.records.FlushControlMessageHandler; +import org.apache.gobblin.stream.RecordEnvelope; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/writer/DataWriterBuilder.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/writer/DataWriterBuilder.java b/gobblin-api/src/main/java/org/apache/gobblin/writer/DataWriterBuilder.java index 9376f14..52ea5b1 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/writer/DataWriterBuilder.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/writer/DataWriterBuilder.java @@ -15,17 +15,17 @@ * limitations under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import java.io.IOException; import lombok.Getter; import lombok.extern.slf4j.Slf4j; -import gobblin.configuration.State; -import gobblin.source.workunit.WorkUnitStream; -import gobblin.writer.initializer.NoopWriterInitializer; -import gobblin.writer.initializer.WriterInitializer; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.source.workunit.WorkUnitStream; +import org.apache.gobblin.writer.initializer.NoopWriterInitializer; +import org.apache.gobblin.writer.initializer.WriterInitializer; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/writer/Destination.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/writer/Destination.java b/gobblin-api/src/main/java/org/apache/gobblin/writer/Destination.java index 563908c..506d4ee 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/writer/Destination.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/writer/Destination.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; -import gobblin.configuration.State; +import org.apache.gobblin.configuration.State; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/writer/FluentDataWriterBuilder.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/writer/FluentDataWriterBuilder.java b/gobblin-api/src/main/java/org/apache/gobblin/writer/FluentDataWriterBuilder.java index 8836359..7953017 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/writer/FluentDataWriterBuilder.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/writer/FluentDataWriterBuilder.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; /** * A helper class to help create fluent {@link DataWriterBuilder}s. To make the Java generics magic http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/writer/FsWriterMetrics.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/writer/FsWriterMetrics.java b/gobblin-api/src/main/java/org/apache/gobblin/writer/FsWriterMetrics.java index c1419bb..374c557 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/writer/FsWriterMetrics.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/writer/FsWriterMetrics.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import java.io.IOException; import java.util.Collection; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/writer/PartitionIdentifier.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/writer/PartitionIdentifier.java b/gobblin-api/src/main/java/org/apache/gobblin/writer/PartitionIdentifier.java index 0e1efc5..332ceef 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/writer/PartitionIdentifier.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/writer/PartitionIdentifier.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import lombok.AllArgsConstructor; import lombok.Data; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/writer/WatermarkStorage.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/writer/WatermarkStorage.java b/gobblin-api/src/main/java/org/apache/gobblin/writer/WatermarkStorage.java index cda1b3c..eab115a 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/writer/WatermarkStorage.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/writer/WatermarkStorage.java @@ -17,13 +17,13 @@ * under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import java.io.IOException; import java.util.Map; -import gobblin.annotation.Alpha; -import gobblin.source.extractor.CheckpointableWatermark; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.source.extractor.CheckpointableWatermark; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/writer/WriterOutputFormat.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/writer/WriterOutputFormat.java b/gobblin-api/src/main/java/org/apache/gobblin/writer/WriterOutputFormat.java index c2c297d..64714d4 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/writer/WriterOutputFormat.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/writer/WriterOutputFormat.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import org.apache.commons.lang3.StringUtils; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/writer/WriterWrapper.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/writer/WriterWrapper.java b/gobblin-api/src/main/java/org/apache/gobblin/writer/WriterWrapper.java index 77b195f..edf1473 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/writer/WriterWrapper.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/writer/WriterWrapper.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/writer/initializer/NoopWriterInitializer.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/writer/initializer/NoopWriterInitializer.java b/gobblin-api/src/main/java/org/apache/gobblin/writer/initializer/NoopWriterInitializer.java index 059a062..60dd419 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/writer/initializer/NoopWriterInitializer.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/writer/initializer/NoopWriterInitializer.java @@ -15,11 +15,11 @@ * limitations under the License. */ -package gobblin.writer.initializer; +package org.apache.gobblin.writer.initializer; import lombok.ToString; -import gobblin.initializer.Initializer; -import gobblin.initializer.NoopInitializer; +import org.apache.gobblin.initializer.Initializer; +import org.apache.gobblin.initializer.NoopInitializer; @ToString public class NoopWriterInitializer implements WriterInitializer { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/main/java/org/apache/gobblin/writer/initializer/WriterInitializer.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/writer/initializer/WriterInitializer.java b/gobblin-api/src/main/java/org/apache/gobblin/writer/initializer/WriterInitializer.java index 083c658..d05aae1 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/writer/initializer/WriterInitializer.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/writer/initializer/WriterInitializer.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.writer.initializer; +package org.apache.gobblin.writer.initializer; -import gobblin.initializer.Initializer; +import org.apache.gobblin.initializer.Initializer; public interface WriterInitializer extends Initializer { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/test/java/com/linkedin/gobblin/TestAlias.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/test/java/com/linkedin/gobblin/TestAlias.java b/gobblin-api/src/test/java/com/linkedin/gobblin/TestAlias.java index 4e54d2e..51b92d6 100644 --- a/gobblin-api/src/test/java/com/linkedin/gobblin/TestAlias.java +++ b/gobblin-api/src/test/java/com/linkedin/gobblin/TestAlias.java @@ -11,7 +11,7 @@ */ package com.linkedin.gobblin; -import gobblin.annotation.Alias; +import org.apache.gobblin.annotation.Alias; /** * Dummy test class to test alias resolution for com.linkedin.gobblin package http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/test/java/org/apache/gobblin/ack/HierarchicalAckableTest.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/test/java/org/apache/gobblin/ack/HierarchicalAckableTest.java b/gobblin-api/src/test/java/org/apache/gobblin/ack/HierarchicalAckableTest.java index 54c918a..589e6aa 100644 --- a/gobblin-api/src/test/java/org/apache/gobblin/ack/HierarchicalAckableTest.java +++ b/gobblin-api/src/test/java/org/apache/gobblin/ack/HierarchicalAckableTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.ack; +package org.apache.gobblin.ack; import org.testng.Assert; import org.testng.TestException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/test/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopesTest.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/test/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopesTest.java b/gobblin-api/src/test/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopesTest.java index 559978d..78b11f0 100644 --- a/gobblin-api/src/test/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopesTest.java +++ b/gobblin-api/src/test/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopesTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.broker.gobblin_scopes; +package org.apache.gobblin.broker.gobblin_scopes; import org.testng.Assert; import org.testng.annotations.Test; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/test/java/org/apache/gobblin/compat/TextSerializerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/test/java/org/apache/gobblin/compat/TextSerializerTest.java b/gobblin-api/src/test/java/org/apache/gobblin/compat/TextSerializerTest.java index 32773cb..04ba79f 100644 --- a/gobblin-api/src/test/java/org/apache/gobblin/compat/TextSerializerTest.java +++ b/gobblin-api/src/test/java/org/apache/gobblin/compat/TextSerializerTest.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.compat; +package org.apache.gobblin.compat; import java.io.ByteArrayInputStream; import java.io.ByteArrayOutputStream; @@ -28,7 +28,7 @@ import org.testng.annotations.Test; import com.google.common.base.Strings; -import gobblin.compat.hadoop.TextSerializer; +import org.apache.gobblin.compat.hadoop.TextSerializer; public class TextSerializerTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/test/java/org/apache/gobblin/configuration/StateTest.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/test/java/org/apache/gobblin/configuration/StateTest.java b/gobblin-api/src/test/java/org/apache/gobblin/configuration/StateTest.java index 5dcd8d7..bcfa9a7 100644 --- a/gobblin-api/src/test/java/org/apache/gobblin/configuration/StateTest.java +++ b/gobblin-api/src/test/java/org/apache/gobblin/configuration/StateTest.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.configuration; +package org.apache.gobblin.configuration; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/test/java/org/apache/gobblin/converter/ConverterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/test/java/org/apache/gobblin/converter/ConverterTest.java b/gobblin-api/src/test/java/org/apache/gobblin/converter/ConverterTest.java index 20b47c6..f5f0ed5 100644 --- a/gobblin-api/src/test/java/org/apache/gobblin/converter/ConverterTest.java +++ b/gobblin-api/src/test/java/org/apache/gobblin/converter/ConverterTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.converter; +package org.apache.gobblin.converter; import java.util.List; @@ -24,12 +24,12 @@ import org.testng.annotations.Test; import com.google.common.collect.Lists; -import gobblin.ack.BasicAckableForTesting; -import gobblin.configuration.WorkUnitState; -import gobblin.records.RecordStreamWithMetadata; -import gobblin.stream.ControlMessage; -import gobblin.stream.RecordEnvelope; -import gobblin.stream.StreamEntity; +import org.apache.gobblin.ack.BasicAckableForTesting; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.records.RecordStreamWithMetadata; +import org.apache.gobblin.stream.ControlMessage; +import org.apache.gobblin.stream.RecordEnvelope; +import org.apache.gobblin.stream.StreamEntity; import io.reactivex.Flowable; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/test/java/org/apache/gobblin/fork/CopyHelperTest.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/test/java/org/apache/gobblin/fork/CopyHelperTest.java b/gobblin-api/src/test/java/org/apache/gobblin/fork/CopyHelperTest.java index 6463f2a..58e9fae 100644 --- a/gobblin-api/src/test/java/org/apache/gobblin/fork/CopyHelperTest.java +++ b/gobblin-api/src/test/java/org/apache/gobblin/fork/CopyHelperTest.java @@ -17,7 +17,7 @@ * under the License. */ -package gobblin.fork; +package org.apache.gobblin.fork; import java.io.ByteArrayInputStream; import java.util.Random; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/test/java/org/apache/gobblin/fork/ForkerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/test/java/org/apache/gobblin/fork/ForkerTest.java b/gobblin-api/src/test/java/org/apache/gobblin/fork/ForkerTest.java index 07dbd01..1c8beb1 100644 --- a/gobblin-api/src/test/java/org/apache/gobblin/fork/ForkerTest.java +++ b/gobblin-api/src/test/java/org/apache/gobblin/fork/ForkerTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.fork; +package org.apache.gobblin.fork; import java.io.IOException; import java.util.Collections; @@ -30,12 +30,12 @@ import org.testng.annotations.Test; import com.google.common.collect.Lists; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.records.RecordStreamWithMetadata; -import gobblin.runtime.BasicTestControlMessage; -import gobblin.stream.RecordEnvelope; -import gobblin.stream.StreamEntity; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.records.RecordStreamWithMetadata; +import org.apache.gobblin.runtime.BasicTestControlMessage; +import org.apache.gobblin.stream.RecordEnvelope; +import org.apache.gobblin.stream.StreamEntity; import io.reactivex.Flowable; import lombok.Getter; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/test/java/org/apache/gobblin/password/PasswordManagerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/test/java/org/apache/gobblin/password/PasswordManagerTest.java b/gobblin-api/src/test/java/org/apache/gobblin/password/PasswordManagerTest.java index bd025f2..6ca0a8a 100644 --- a/gobblin-api/src/test/java/org/apache/gobblin/password/PasswordManagerTest.java +++ b/gobblin-api/src/test/java/org/apache/gobblin/password/PasswordManagerTest.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package gobblin.password; +package org.apache.gobblin.password; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; import java.io.File; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/test/java/org/apache/gobblin/source/extractor/TestWatermark.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/test/java/org/apache/gobblin/source/extractor/TestWatermark.java b/gobblin-api/src/test/java/org/apache/gobblin/source/extractor/TestWatermark.java index 56ccf87..0552d45 100644 --- a/gobblin-api/src/test/java/org/apache/gobblin/source/extractor/TestWatermark.java +++ b/gobblin-api/src/test/java/org/apache/gobblin/source/extractor/TestWatermark.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor; +package org.apache.gobblin.source.extractor; import com.google.gson.Gson; import com.google.gson.JsonElement; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/test/java/org/apache/gobblin/source/extractor/WatermarkTest.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/test/java/org/apache/gobblin/source/extractor/WatermarkTest.java b/gobblin-api/src/test/java/org/apache/gobblin/source/extractor/WatermarkTest.java index 499a1a1..9f1dab4 100644 --- a/gobblin-api/src/test/java/org/apache/gobblin/source/extractor/WatermarkTest.java +++ b/gobblin-api/src/test/java/org/apache/gobblin/source/extractor/WatermarkTest.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package gobblin.source.extractor; +package org.apache.gobblin.source.extractor; -import gobblin.configuration.WorkUnitState; -import gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.source.workunit.WorkUnit; import org.testng.Assert; import org.testng.annotations.Test; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/test/java/org/apache/gobblin/source/workunit/ExtractFactoryTest.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/test/java/org/apache/gobblin/source/workunit/ExtractFactoryTest.java b/gobblin-api/src/test/java/org/apache/gobblin/source/workunit/ExtractFactoryTest.java index d286324..3dd16e5 100644 --- a/gobblin-api/src/test/java/org/apache/gobblin/source/workunit/ExtractFactoryTest.java +++ b/gobblin-api/src/test/java/org/apache/gobblin/source/workunit/ExtractFactoryTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.workunit; +package org.apache.gobblin.source.workunit; import java.util.Set; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/test/java/org/apache/gobblin/stream/RecordEnvelopeTest.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/test/java/org/apache/gobblin/stream/RecordEnvelopeTest.java b/gobblin-api/src/test/java/org/apache/gobblin/stream/RecordEnvelopeTest.java index ae07f60..2e276fb 100644 --- a/gobblin-api/src/test/java/org/apache/gobblin/stream/RecordEnvelopeTest.java +++ b/gobblin-api/src/test/java/org/apache/gobblin/stream/RecordEnvelopeTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.stream; +package org.apache.gobblin.stream; import java.util.Random; @@ -24,12 +24,12 @@ import org.testng.annotations.Test; import com.google.gson.JsonElement; -import gobblin.ack.BasicAckableForTesting; -import gobblin.fork.CopyNotSupportedException; -import gobblin.fork.Copyable; -import gobblin.source.extractor.CheckpointableWatermark; -import gobblin.source.extractor.ComparableWatermark; -import gobblin.source.extractor.Watermark; +import org.apache.gobblin.ack.BasicAckableForTesting; +import org.apache.gobblin.fork.CopyNotSupportedException; +import org.apache.gobblin.fork.Copyable; +import org.apache.gobblin.source.extractor.CheckpointableWatermark; +import org.apache.gobblin.source.extractor.ComparableWatermark; +import org.apache.gobblin.source.extractor.Watermark; import lombok.AllArgsConstructor; import lombok.Getter; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/test/java/org/apache/gobblin/stream/StreamEntityTest.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/test/java/org/apache/gobblin/stream/StreamEntityTest.java b/gobblin-api/src/test/java/org/apache/gobblin/stream/StreamEntityTest.java index e3a5704..b2c2d87 100644 --- a/gobblin-api/src/test/java/org/apache/gobblin/stream/StreamEntityTest.java +++ b/gobblin-api/src/test/java/org/apache/gobblin/stream/StreamEntityTest.java @@ -15,14 +15,14 @@ * limitations under the License. */ -package gobblin.stream; +package org.apache.gobblin.stream; import java.util.Random; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.ack.BasicAckableForTesting; +import org.apache.gobblin.ack.BasicAckableForTesting; public class StreamEntityTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/test/java/org/apache/gobblin/testing/AssertWithBackoffTest.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/test/java/org/apache/gobblin/testing/AssertWithBackoffTest.java b/gobblin-api/src/test/java/org/apache/gobblin/testing/AssertWithBackoffTest.java index 4026c33..7f1fae8 100644 --- a/gobblin-api/src/test/java/org/apache/gobblin/testing/AssertWithBackoffTest.java +++ b/gobblin-api/src/test/java/org/apache/gobblin/testing/AssertWithBackoffTest.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.testing; +package org.apache.gobblin.testing; import java.util.concurrent.TimeoutException; import java.util.concurrent.atomic.AtomicInteger; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/test/java/org/apache/gobblin/util/ClassAliasResolverTest.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/test/java/org/apache/gobblin/util/ClassAliasResolverTest.java b/gobblin-api/src/test/java/org/apache/gobblin/util/ClassAliasResolverTest.java index d5e0c59..e4a5cf6 100644 --- a/gobblin-api/src/test/java/org/apache/gobblin/util/ClassAliasResolverTest.java +++ b/gobblin-api/src/test/java/org/apache/gobblin/util/ClassAliasResolverTest.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.util; +package org.apache.gobblin.util; import org.testng.Assert; import org.testng.annotations.Test; @@ -22,7 +22,7 @@ import org.testng.annotations.Test; import com.linkedin.gobblin.TestAlias.DummyAliasCom; import com.linkedin.gobblin.TestAlias.IDummyAliasCom; -import gobblin.annotation.Alias; +import org.apache.gobblin.annotation.Alias; @Test(groups = { "gobblin.api.util"}) public class ClassAliasResolverTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-api/src/test/java/org/apache/gobblin/writer/FsWriterMetricsTest.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/test/java/org/apache/gobblin/writer/FsWriterMetricsTest.java b/gobblin-api/src/test/java/org/apache/gobblin/writer/FsWriterMetricsTest.java index 7f86312..1873862 100644 --- a/gobblin-api/src/test/java/org/apache/gobblin/writer/FsWriterMetricsTest.java +++ b/gobblin-api/src/test/java/org/apache/gobblin/writer/FsWriterMetricsTest.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.writer; +package org.apache.gobblin.writer; import java.io.IOException; import java.util.Set; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/auditor/ValueAuditGenerator.java ---------------------------------------------------------------------- diff --git a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/auditor/ValueAuditGenerator.java b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/auditor/ValueAuditGenerator.java index c408eb0..a658bad 100644 --- a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/auditor/ValueAuditGenerator.java +++ b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/auditor/ValueAuditGenerator.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.audit.values.auditor; +package org.apache.gobblin.audit.values.auditor; import java.io.Closeable; import java.io.IOException; @@ -26,12 +26,12 @@ import org.apache.avro.generic.GenericRecord; import com.typesafe.config.Config; -import gobblin.audit.values.policy.column.ColumnProjectionPolicy; -import gobblin.audit.values.policy.column.DefaultColumnProjectionPolicyFactory; -import gobblin.audit.values.policy.row.DefaultRowSelectionPolicyFactory; -import gobblin.audit.values.policy.row.RowSelectionPolicy; -import gobblin.audit.values.sink.AuditSink; -import gobblin.audit.values.sink.DefaultAuditSinkFactory; +import org.apache.gobblin.audit.values.policy.column.ColumnProjectionPolicy; +import org.apache.gobblin.audit.values.policy.column.DefaultColumnProjectionPolicyFactory; +import org.apache.gobblin.audit.values.policy.row.DefaultRowSelectionPolicyFactory; +import org.apache.gobblin.audit.values.policy.row.RowSelectionPolicy; +import org.apache.gobblin.audit.values.sink.AuditSink; +import org.apache.gobblin.audit.values.sink.DefaultAuditSinkFactory; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/auditor/ValueAuditRuntimeMetadata.java ---------------------------------------------------------------------- diff --git a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/auditor/ValueAuditRuntimeMetadata.java b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/auditor/ValueAuditRuntimeMetadata.java index 533f22b..d1f5bf2 100644 --- a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/auditor/ValueAuditRuntimeMetadata.java +++ b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/auditor/ValueAuditRuntimeMetadata.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.audit.values.auditor; +package org.apache.gobblin.audit.values.auditor; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/AbstractColumnProjectionPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/AbstractColumnProjectionPolicy.java b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/AbstractColumnProjectionPolicy.java index 753d862..59f4e54 100644 --- a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/AbstractColumnProjectionPolicy.java +++ b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/AbstractColumnProjectionPolicy.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.audit.values.policy.column; +package org.apache.gobblin.audit.values.policy.column; import java.util.List; @@ -23,7 +23,7 @@ import org.apache.avro.Schema; import com.google.common.collect.ImmutableList; import com.typesafe.config.Config; -import gobblin.audit.values.auditor.ValueAuditRuntimeMetadata; +import org.apache.gobblin.audit.values.auditor.ValueAuditRuntimeMetadata; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/ColumnProjectionPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/ColumnProjectionPolicy.java b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/ColumnProjectionPolicy.java index 00aff0c..5f08717 100644 --- a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/ColumnProjectionPolicy.java +++ b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/ColumnProjectionPolicy.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.audit.values.policy.column; +package org.apache.gobblin.audit.values.policy.column; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/DefaultColumnProjectionPolicyFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/DefaultColumnProjectionPolicyFactory.java b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/DefaultColumnProjectionPolicyFactory.java index 00eb963..b3713f3 100644 --- a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/DefaultColumnProjectionPolicyFactory.java +++ b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/DefaultColumnProjectionPolicyFactory.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.audit.values.policy.column; +package org.apache.gobblin.audit.values.policy.column; import java.lang.reflect.InvocationTargetException; @@ -25,8 +25,8 @@ import org.apache.commons.lang3.reflect.ConstructorUtils; import com.google.common.base.Preconditions; import com.typesafe.config.Config; -import gobblin.audit.values.auditor.ValueAuditRuntimeMetadata; -import gobblin.util.ClassAliasResolver; +import org.apache.gobblin.audit.values.auditor.ValueAuditRuntimeMetadata; +import org.apache.gobblin.util.ClassAliasResolver; /** * Default factory class to create new {@link ColumnProjectionPolicy}s http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/ProjectAllColumnProjectionPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/ProjectAllColumnProjectionPolicy.java b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/ProjectAllColumnProjectionPolicy.java index 0e0452f..a57e513 100644 --- a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/ProjectAllColumnProjectionPolicy.java +++ b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/column/ProjectAllColumnProjectionPolicy.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.audit.values.policy.column; +package org.apache.gobblin.audit.values.policy.column; import java.util.List; @@ -22,8 +22,8 @@ import org.apache.avro.generic.GenericRecord; import com.typesafe.config.Config; -import gobblin.annotation.Alias; -import gobblin.audit.values.auditor.ValueAuditRuntimeMetadata; +import org.apache.gobblin.annotation.Alias; +import org.apache.gobblin.audit.values.auditor.ValueAuditRuntimeMetadata; /** * An {@link AbstractColumnProjectionPolicy} that projects all columns/fields of the <code>inputRecord</code> http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/AbstractRowSelectionPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/AbstractRowSelectionPolicy.java b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/AbstractRowSelectionPolicy.java index f9e2358..721bd43 100644 --- a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/AbstractRowSelectionPolicy.java +++ b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/AbstractRowSelectionPolicy.java @@ -14,13 +14,13 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.audit.values.policy.row; +package org.apache.gobblin.audit.values.policy.row; import com.typesafe.config.Config; -import gobblin.audit.values.auditor.ValueAuditGenerator; -import gobblin.audit.values.auditor.ValueAuditRuntimeMetadata; -import gobblin.audit.values.policy.column.ColumnProjectionPolicy; +import org.apache.gobblin.audit.values.auditor.ValueAuditGenerator; +import org.apache.gobblin.audit.values.auditor.ValueAuditRuntimeMetadata; +import org.apache.gobblin.audit.values.policy.column.ColumnProjectionPolicy; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/DefaultRowSelectionPolicyFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/DefaultRowSelectionPolicyFactory.java b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/DefaultRowSelectionPolicyFactory.java index dd5b0d7..70a1ec4 100644 --- a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/DefaultRowSelectionPolicyFactory.java +++ b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/DefaultRowSelectionPolicyFactory.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.audit.values.policy.row; +package org.apache.gobblin.audit.values.policy.row; import java.lang.reflect.InvocationTargetException; @@ -25,10 +25,10 @@ import org.apache.commons.lang3.reflect.ConstructorUtils; import com.google.common.base.Preconditions; import com.typesafe.config.Config; -import gobblin.audit.values.auditor.ValueAuditGenerator; -import gobblin.audit.values.auditor.ValueAuditRuntimeMetadata; -import gobblin.audit.values.policy.column.ColumnProjectionPolicy; -import gobblin.util.ClassAliasResolver; +import org.apache.gobblin.audit.values.auditor.ValueAuditGenerator; +import org.apache.gobblin.audit.values.auditor.ValueAuditRuntimeMetadata; +import org.apache.gobblin.audit.values.policy.column.ColumnProjectionPolicy; +import org.apache.gobblin.util.ClassAliasResolver; /** * Default factory class to create new {@link RowSelectionPolicy}s http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/RowSelectionPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/RowSelectionPolicy.java b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/RowSelectionPolicy.java index ae520d3..8a0406e 100644 --- a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/RowSelectionPolicy.java +++ b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/RowSelectionPolicy.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.audit.values.policy.row; +package org.apache.gobblin.audit.values.policy.row; import org.apache.avro.generic.GenericRecord; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/SelectAllRowSelectionPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/SelectAllRowSelectionPolicy.java b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/SelectAllRowSelectionPolicy.java index a794f70..84ba0b9 100644 --- a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/SelectAllRowSelectionPolicy.java +++ b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/policy/row/SelectAllRowSelectionPolicy.java @@ -14,15 +14,15 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.audit.values.policy.row; +package org.apache.gobblin.audit.values.policy.row; import org.apache.avro.generic.GenericRecord; import com.typesafe.config.Config; -import gobblin.annotation.Alias; -import gobblin.audit.values.auditor.ValueAuditRuntimeMetadata; -import gobblin.audit.values.policy.column.ColumnProjectionPolicy; +import org.apache.gobblin.annotation.Alias; +import org.apache.gobblin.audit.values.auditor.ValueAuditRuntimeMetadata; +import org.apache.gobblin.audit.values.policy.column.ColumnProjectionPolicy; /** * A {@link RowSelectionPolicy} that selects all rows for auditing http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/sink/AuditSink.java ---------------------------------------------------------------------- diff --git a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/sink/AuditSink.java b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/sink/AuditSink.java index 8ccabcb..b35a427 100644 --- a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/sink/AuditSink.java +++ b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/sink/AuditSink.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.audit.values.sink; +package org.apache.gobblin.audit.values.sink; import java.io.Closeable; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/sink/DefaultAuditSinkFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/sink/DefaultAuditSinkFactory.java b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/sink/DefaultAuditSinkFactory.java index ba3e425..443fbde 100644 --- a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/sink/DefaultAuditSinkFactory.java +++ b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/sink/DefaultAuditSinkFactory.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.audit.values.sink; +package org.apache.gobblin.audit.values.sink; import java.lang.reflect.InvocationTargetException; @@ -24,8 +24,8 @@ import org.apache.commons.lang3.reflect.ConstructorUtils; import com.typesafe.config.Config; -import gobblin.audit.values.auditor.ValueAuditRuntimeMetadata; -import gobblin.util.ClassAliasResolver; +import org.apache.gobblin.audit.values.auditor.ValueAuditRuntimeMetadata; +import org.apache.gobblin.util.ClassAliasResolver; /** * Default factory class to create new {@link AuditSink}s http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/sink/FsAuditSink.java ---------------------------------------------------------------------- diff --git a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/sink/FsAuditSink.java b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/sink/FsAuditSink.java index 2952afc..78d21d6 100644 --- a/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/sink/FsAuditSink.java +++ b/gobblin-audit/src/main/java/org/apache/gobblin/audit/values/sink/FsAuditSink.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.audit.values.sink; +package org.apache.gobblin.audit.values.sink; import java.io.IOException; import java.io.OutputStream; @@ -32,11 +32,11 @@ import org.apache.hadoop.fs.Path; import com.google.common.io.Closer; import com.typesafe.config.Config; -import gobblin.annotation.Alias; -import gobblin.audit.values.auditor.ValueAuditRuntimeMetadata; -import gobblin.configuration.ConfigurationKeys; -import gobblin.util.ConfigUtils; -import gobblin.util.PathUtils; +import org.apache.gobblin.annotation.Alias; +import org.apache.gobblin.audit.values.auditor.ValueAuditRuntimeMetadata; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.util.PathUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/FsAuditSinkTest.java ---------------------------------------------------------------------- diff --git a/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/FsAuditSinkTest.java b/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/FsAuditSinkTest.java index c259c15..2085ec7 100644 --- a/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/FsAuditSinkTest.java +++ b/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/FsAuditSinkTest.java @@ -14,10 +14,10 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.audit.values; +package org.apache.gobblin.audit.values; -import gobblin.audit.values.auditor.ValueAuditRuntimeMetadata; -import gobblin.audit.values.sink.FsAuditSink; +import org.apache.gobblin.audit.values.auditor.ValueAuditRuntimeMetadata; +import org.apache.gobblin.audit.values.sink.FsAuditSink; import java.io.File; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/MockSink.java ---------------------------------------------------------------------- diff --git a/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/MockSink.java b/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/MockSink.java index 907e20c..02ed6b1 100644 --- a/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/MockSink.java +++ b/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/MockSink.java @@ -14,11 +14,11 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.audit.values; +package org.apache.gobblin.audit.values; -import gobblin.annotation.Alias; -import gobblin.audit.values.auditor.ValueAuditRuntimeMetadata; -import gobblin.audit.values.sink.AuditSink; +import org.apache.gobblin.annotation.Alias; +import org.apache.gobblin.audit.values.auditor.ValueAuditRuntimeMetadata; +import org.apache.gobblin.audit.values.sink.AuditSink; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/ValueAuditGeneratorTest.java ---------------------------------------------------------------------- diff --git a/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/ValueAuditGeneratorTest.java b/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/ValueAuditGeneratorTest.java index b3db7b0..7618720 100644 --- a/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/ValueAuditGeneratorTest.java +++ b/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/ValueAuditGeneratorTest.java @@ -14,13 +14,13 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.audit.values; +package org.apache.gobblin.audit.values; import static org.mockito.Mockito.mock; -import gobblin.audit.values.auditor.ValueAuditGenerator; -import gobblin.audit.values.auditor.ValueAuditRuntimeMetadata; -import gobblin.audit.values.policy.column.ProjectAllColumnProjectionPolicy; -import gobblin.audit.values.policy.row.SelectAllRowSelectionPolicy; +import org.apache.gobblin.audit.values.auditor.ValueAuditGenerator; +import org.apache.gobblin.audit.values.auditor.ValueAuditRuntimeMetadata; +import org.apache.gobblin.audit.values.policy.column.ProjectAllColumnProjectionPolicy; +import org.apache.gobblin.audit.values.policy.row.SelectAllRowSelectionPolicy; import org.apache.avro.generic.GenericRecord; import org.mockito.Mockito; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/ValueAuditRuntimeMetadataTest.java ---------------------------------------------------------------------- diff --git a/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/ValueAuditRuntimeMetadataTest.java b/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/ValueAuditRuntimeMetadataTest.java index 68d7fdf..b51dd42 100644 --- a/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/ValueAuditRuntimeMetadataTest.java +++ b/gobblin-audit/src/test/java/org/apache/gobblin/audit/values/ValueAuditRuntimeMetadataTest.java @@ -14,11 +14,11 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.audit.values; +package org.apache.gobblin.audit.values; import static org.mockito.Mockito.mock; -import gobblin.audit.values.auditor.ValueAuditRuntimeMetadata; -import gobblin.audit.values.auditor.ValueAuditRuntimeMetadata.Phase; +import org.apache.gobblin.audit.values.auditor.ValueAuditRuntimeMetadata; +import org.apache.gobblin.audit.values.auditor.ValueAuditRuntimeMetadata.Phase; import org.apache.avro.Schema; import org.mockito.Mockito; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSClusterSecurityManager.java ---------------------------------------------------------------------- diff --git a/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSClusterSecurityManager.java b/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSClusterSecurityManager.java index 9217720..ecd50af 100644 --- a/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSClusterSecurityManager.java +++ b/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSClusterSecurityManager.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.aws; +package org.apache.gobblin.aws; import java.util.concurrent.TimeUnit; @@ -33,9 +33,9 @@ import com.amazonaws.auth.profile.ProfileCredentialsProvider; import com.amazonaws.util.StringUtils; import com.typesafe.config.Config; -import gobblin.annotation.Alpha; -import gobblin.password.PasswordManager; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.password.PasswordManager; +import org.apache.gobblin.util.ConfigUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSJobConfigurationManager.java ---------------------------------------------------------------------- diff --git a/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSJobConfigurationManager.java b/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSJobConfigurationManager.java index 524d1b9..58f4c9f 100644 --- a/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSJobConfigurationManager.java +++ b/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSJobConfigurationManager.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.aws; +package org.apache.gobblin.aws; import java.io.File; import java.io.FileOutputStream; @@ -44,16 +44,16 @@ import com.google.common.collect.Maps; import com.google.common.eventbus.EventBus; import com.typesafe.config.Config; -import gobblin.annotation.Alpha; -import gobblin.cluster.GobblinClusterConfigurationKeys; -import gobblin.cluster.GobblinHelixJobScheduler; -import gobblin.cluster.JobConfigurationManager; -import gobblin.cluster.event.NewJobConfigArrivalEvent; -import gobblin.configuration.ConfigurationKeys; -import gobblin.util.ExecutorsUtils; -import gobblin.util.SchedulerUtils; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.cluster.GobblinClusterConfigurationKeys; +import org.apache.gobblin.cluster.GobblinHelixJobScheduler; +import org.apache.gobblin.cluster.JobConfigurationManager; +import org.apache.gobblin.cluster.event.NewJobConfigArrivalEvent; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.util.ExecutorsUtils; +import org.apache.gobblin.util.SchedulerUtils; -import static gobblin.aws.GobblinAWSUtils.appendSlash; +import static org.apache.gobblin.aws.GobblinAWSUtils.appendSlash; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSSdkClient.java ---------------------------------------------------------------------- diff --git a/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSSdkClient.java b/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSSdkClient.java index 89d93dc..5066e63 100644 --- a/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSSdkClient.java +++ b/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSSdkClient.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.aws; +package org.apache.gobblin.aws; import java.io.File; import java.io.IOException; @@ -68,7 +68,7 @@ import com.google.common.base.Supplier; import com.google.common.base.Suppliers; import com.google.common.collect.Lists; -import gobblin.annotation.Alpha; +import org.apache.gobblin.annotation.Alpha; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSShutdownHandler.java ---------------------------------------------------------------------- diff --git a/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSShutdownHandler.java b/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSShutdownHandler.java index c57e804..3afe94a 100644 --- a/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSShutdownHandler.java +++ b/gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSShutdownHandler.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.aws; +package org.apache.gobblin.aws; import java.util.List; @@ -25,7 +25,7 @@ import org.slf4j.LoggerFactory; import com.google.common.base.Optional; -import gobblin.annotation.Alpha; +import org.apache.gobblin.annotation.Alpha; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-aws/src/main/java/org/apache/gobblin/aws/CloudInitScriptBuilder.java ---------------------------------------------------------------------- diff --git a/gobblin-aws/src/main/java/org/apache/gobblin/aws/CloudInitScriptBuilder.java b/gobblin-aws/src/main/java/org/apache/gobblin/aws/CloudInitScriptBuilder.java index aad4930..fa65f5b 100644 --- a/gobblin-aws/src/main/java/org/apache/gobblin/aws/CloudInitScriptBuilder.java +++ b/gobblin-aws/src/main/java/org/apache/gobblin/aws/CloudInitScriptBuilder.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.aws; +package org.apache.gobblin.aws; import java.io.File; import java.util.List; @@ -26,10 +26,10 @@ import org.slf4j.LoggerFactory; import com.google.common.base.Optional; import com.google.common.base.Splitter; -import gobblin.annotation.Alpha; -import gobblin.cluster.GobblinClusterConfigurationKeys; -import gobblin.util.JvmUtils; -import static gobblin.aws.GobblinAWSUtils.encodeBase64; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.cluster.GobblinClusterConfigurationKeys; +import org.apache.gobblin.util.JvmUtils; +import static org.apache.gobblin.aws.GobblinAWSUtils.encodeBase64; /**
