http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/ConfluentKafkaSchemaRegistry.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/ConfluentKafkaSchemaRegistry.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/ConfluentKafkaSchemaRegistry.java index fcc1012..fbad64e 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/ConfluentKafkaSchemaRegistry.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/ConfluentKafkaSchemaRegistry.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor.extract.kafka; +package org.apache.gobblin.source.extractor.extract.kafka; import java.io.IOException; import java.util.Properties; @@ -31,8 +31,8 @@ import io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientExcept import lombok.Getter; import lombok.extern.slf4j.Slf4j; -import gobblin.metrics.kafka.KafkaSchemaRegistry; -import gobblin.metrics.kafka.SchemaRegistryException; +import org.apache.gobblin.metrics.kafka.KafkaSchemaRegistry; +import org.apache.gobblin.metrics.kafka.SchemaRegistryException; /**
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/FixedSchemaKafkaAvroExtractor.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/FixedSchemaKafkaAvroExtractor.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/FixedSchemaKafkaAvroExtractor.java index ce258da..71e7e6e 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/FixedSchemaKafkaAvroExtractor.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/FixedSchemaKafkaAvroExtractor.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor.extract.kafka; +package org.apache.gobblin.source.extractor.extract.kafka; import org.apache.avro.Schema; import org.apache.avro.io.Decoder; @@ -23,8 +23,8 @@ import org.apache.avro.io.DecoderFactory; import com.google.common.base.Preconditions; -import gobblin.annotation.Alias; -import gobblin.configuration.WorkUnitState; +import org.apache.gobblin.annotation.Alias; +import org.apache.gobblin.configuration.WorkUnitState; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaAvroExtractor.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaAvroExtractor.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaAvroExtractor.java index 5052f70..4547cfe 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaAvroExtractor.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaAvroExtractor.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor.extract.kafka; +package org.apache.gobblin.source.extractor.extract.kafka; import java.io.IOException; @@ -31,13 +31,13 @@ import org.apache.avro.io.Decoder; import com.google.common.base.Optional; import com.google.common.base.Preconditions; -import gobblin.configuration.WorkUnitState; -import gobblin.kafka.client.ByteArrayBasedKafkaRecord; -import gobblin.metrics.kafka.KafkaSchemaRegistry; -import gobblin.metrics.kafka.SchemaRegistryException; -import gobblin.source.extractor.DataRecordException; -import gobblin.source.extractor.Extractor; -import gobblin.util.AvroUtils; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.kafka.client.ByteArrayBasedKafkaRecord; +import org.apache.gobblin.metrics.kafka.KafkaSchemaRegistry; +import org.apache.gobblin.metrics.kafka.SchemaRegistryException; +import org.apache.gobblin.source.extractor.DataRecordException; +import org.apache.gobblin.source.extractor.Extractor; +import org.apache.gobblin.util.AvroUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaExtractor.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaExtractor.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaExtractor.java index ef47b0f..ac1a7f2 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaExtractor.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaExtractor.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor.extract.kafka; +package org.apache.gobblin.source.extractor.extract.kafka; import java.io.IOException; import java.util.Iterator; @@ -33,21 +33,21 @@ import com.google.common.collect.Lists; import com.google.common.collect.Maps; import com.google.common.collect.Sets; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.kafka.client.ByteArrayBasedKafkaRecord; -import gobblin.kafka.client.DecodeableKafkaRecord; -import gobblin.kafka.client.GobblinKafkaConsumerClient; -import gobblin.kafka.client.GobblinKafkaConsumerClient.GobblinKafkaConsumerClientFactory; -import gobblin.kafka.client.KafkaConsumerRecord; -import gobblin.metrics.Tag; -import gobblin.metrics.event.EventSubmitter; -import gobblin.source.extractor.DataRecordException; -import gobblin.source.extractor.Extractor; -import gobblin.source.extractor.extract.EventBasedExtractor; -import gobblin.util.ClassAliasResolver; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.kafka.client.ByteArrayBasedKafkaRecord; +import org.apache.gobblin.kafka.client.DecodeableKafkaRecord; +import org.apache.gobblin.kafka.client.GobblinKafkaConsumerClient; +import org.apache.gobblin.kafka.client.GobblinKafkaConsumerClient.GobblinKafkaConsumerClientFactory; +import org.apache.gobblin.kafka.client.KafkaConsumerRecord; +import org.apache.gobblin.metrics.Tag; +import org.apache.gobblin.metrics.event.EventSubmitter; +import org.apache.gobblin.source.extractor.DataRecordException; +import org.apache.gobblin.source.extractor.Extractor; +import org.apache.gobblin.source.extractor.extract.EventBasedExtractor; +import org.apache.gobblin.util.ClassAliasResolver; +import org.apache.gobblin.util.ConfigUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaOffsetRetrievalFailureException.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaOffsetRetrievalFailureException.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaOffsetRetrievalFailureException.java index 644c295..b042e92 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaOffsetRetrievalFailureException.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaOffsetRetrievalFailureException.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor.extract.kafka; +package org.apache.gobblin.source.extractor.extract.kafka; @SuppressWarnings("serial") public class KafkaOffsetRetrievalFailureException extends Exception { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaPartition.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaPartition.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaPartition.java index 6b4c2e1..0a11bbf 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaPartition.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaPartition.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor.extract.kafka; +package org.apache.gobblin.source.extractor.extract.kafka; import com.google.common.net.HostAndPort; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaRecord.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaRecord.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaRecord.java index c76b6f4..995d441 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaRecord.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaRecord.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor.extract.kafka; +package org.apache.gobblin.source.extractor.extract.kafka; import lombok.Getter; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSimpleExtractor.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSimpleExtractor.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSimpleExtractor.java index c4de5a9..28c56e5 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSimpleExtractor.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSimpleExtractor.java @@ -15,14 +15,14 @@ * limitations under the License. */ -package gobblin.source.extractor.extract.kafka; +package org.apache.gobblin.source.extractor.extract.kafka; import java.io.IOException; -import gobblin.configuration.WorkUnitState; -import gobblin.kafka.client.ByteArrayBasedKafkaRecord; -import gobblin.metrics.kafka.KafkaSchemaRegistry; -import gobblin.metrics.kafka.SchemaRegistryException; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.kafka.client.ByteArrayBasedKafkaRecord; +import org.apache.gobblin.metrics.kafka.KafkaSchemaRegistry; +import org.apache.gobblin.metrics.kafka.SchemaRegistryException; /** * An implementation of {@link KafkaExtractor} from which reads and returns records as an array of bytes. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSimpleJsonExtractor.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSimpleJsonExtractor.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSimpleJsonExtractor.java index 9001df1..44a2674 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSimpleJsonExtractor.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSimpleJsonExtractor.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor.extract.kafka; +package org.apache.gobblin.source.extractor.extract.kafka; import java.io.IOException; import java.nio.charset.Charset; @@ -23,9 +23,9 @@ import java.nio.charset.StandardCharsets; import com.google.gson.Gson; -import gobblin.configuration.WorkUnitState; -import gobblin.kafka.client.ByteArrayBasedKafkaRecord; -import gobblin.source.extractor.Extractor; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.kafka.client.ByteArrayBasedKafkaRecord; +import org.apache.gobblin.source.extractor.Extractor; public class KafkaSimpleJsonExtractor extends KafkaSimpleExtractor implements Extractor<String, byte[]> { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSimpleSource.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSimpleSource.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSimpleSource.java index 9b0a6da..6bbd69c 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSimpleSource.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSimpleSource.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package gobblin.source.extractor.extract.kafka; +package org.apache.gobblin.source.extractor.extract.kafka; -import gobblin.configuration.WorkUnitState; -import gobblin.source.extractor.Extractor; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.source.extractor.Extractor; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSource.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSource.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSource.java index b68faeb..4fa9fb4 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSource.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSource.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor.extract.kafka; +package org.apache.gobblin.source.extractor.extract.kafka; import java.io.IOException; import java.util.ArrayList; @@ -47,27 +47,27 @@ import com.google.common.collect.Maps; import com.google.common.collect.Sets; import com.typesafe.config.Config; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.SourceState; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.kafka.client.GobblinKafkaConsumerClient; -import gobblin.kafka.client.GobblinKafkaConsumerClient.GobblinKafkaConsumerClientFactory; -import gobblin.source.extractor.extract.EventBasedSource; -import gobblin.source.extractor.extract.kafka.workunit.packer.KafkaWorkUnitPacker; -import gobblin.source.extractor.limiter.LimiterConfigurationKeys; -import gobblin.source.workunit.Extract; -import gobblin.source.workunit.MultiWorkUnit; -import gobblin.source.workunit.WorkUnit; -import gobblin.util.ClassAliasResolver; -import gobblin.util.ConfigUtils; -import gobblin.util.DatasetFilterUtils; -import gobblin.util.ExecutorsUtils; -import gobblin.util.dataset.DatasetUtils; -import gobblin.instrumented.Instrumented; -import gobblin.metrics.MetricContext; -import gobblin.source.extractor.limiter.LimiterConfigurationKeys; -import gobblin.source.workunit.MultiWorkUnit; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.SourceState; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.kafka.client.GobblinKafkaConsumerClient; +import org.apache.gobblin.kafka.client.GobblinKafkaConsumerClient.GobblinKafkaConsumerClientFactory; +import org.apache.gobblin.source.extractor.extract.EventBasedSource; +import org.apache.gobblin.source.extractor.extract.kafka.workunit.packer.KafkaWorkUnitPacker; +import org.apache.gobblin.source.extractor.limiter.LimiterConfigurationKeys; +import org.apache.gobblin.source.workunit.Extract; +import org.apache.gobblin.source.workunit.MultiWorkUnit; +import org.apache.gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.util.ClassAliasResolver; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.util.DatasetFilterUtils; +import org.apache.gobblin.util.ExecutorsUtils; +import org.apache.gobblin.util.dataset.DatasetUtils; +import org.apache.gobblin.instrumented.Instrumented; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.source.extractor.limiter.LimiterConfigurationKeys; +import org.apache.gobblin.source.workunit.MultiWorkUnit; import lombok.Getter; import lombok.Setter; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaTopic.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaTopic.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaTopic.java index d782257..d8de232 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaTopic.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaTopic.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor.extract.kafka; +package org.apache.gobblin.source.extractor.extract.kafka; import java.util.Collections; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaUtils.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaUtils.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaUtils.java index acc0de2..55ecab4 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaUtils.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaUtils.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package gobblin.source.extractor.extract.kafka; +package org.apache.gobblin.source.extractor.extract.kafka; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/MultiLongWatermark.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/MultiLongWatermark.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/MultiLongWatermark.java index 5e36747..0f35db0 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/MultiLongWatermark.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/MultiLongWatermark.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor.extract.kafka; +package org.apache.gobblin.source.extractor.extract.kafka; import java.math.RoundingMode; import java.util.List; @@ -26,7 +26,7 @@ import com.google.common.math.LongMath; import com.google.gson.Gson; import com.google.gson.JsonElement; -import gobblin.source.extractor.Watermark; +import org.apache.gobblin.source.extractor.Watermark; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/PreviousOffsetNotFoundException.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/PreviousOffsetNotFoundException.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/PreviousOffsetNotFoundException.java index be74e5b..7495640 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/PreviousOffsetNotFoundException.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/PreviousOffsetNotFoundException.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor.extract.kafka; +package org.apache.gobblin.source.extractor.extract.kafka; @SuppressWarnings("serial") public class PreviousOffsetNotFoundException extends Exception { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/SimpleKafkaSchemaRegistry.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/SimpleKafkaSchemaRegistry.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/SimpleKafkaSchemaRegistry.java index 765231e..9740512 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/SimpleKafkaSchemaRegistry.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/SimpleKafkaSchemaRegistry.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package gobblin.source.extractor.extract.kafka; +package org.apache.gobblin.source.extractor.extract.kafka; import java.util.Properties; -import gobblin.metrics.kafka.KafkaSchemaRegistry; -import gobblin.metrics.kafka.SchemaRegistryException; +import org.apache.gobblin.metrics.kafka.KafkaSchemaRegistry; +import org.apache.gobblin.metrics.kafka.SchemaRegistryException; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/StartOffsetOutOfRangeException.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/StartOffsetOutOfRangeException.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/StartOffsetOutOfRangeException.java index 39befb2..a6d10bb 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/StartOffsetOutOfRangeException.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/StartOffsetOutOfRangeException.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor.extract.kafka; +package org.apache.gobblin.source.extractor.extract.kafka; @SuppressWarnings("serial") public class StartOffsetOutOfRangeException extends Exception { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/UniversalKafkaSource.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/UniversalKafkaSource.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/UniversalKafkaSource.java index 89350a3..87714d7 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/UniversalKafkaSource.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/UniversalKafkaSource.java @@ -15,16 +15,16 @@ * limitations under the License. */ -package gobblin.source.extractor.extract.kafka; +package org.apache.gobblin.source.extractor.extract.kafka; import java.io.IOException; import com.google.common.base.Preconditions; -import gobblin.configuration.WorkUnitState; -import gobblin.source.extractor.Extractor; -import gobblin.util.ClassAliasResolver; -import gobblin.util.reflection.GobblinConstructorUtils; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.source.extractor.Extractor; +import org.apache.gobblin.util.ClassAliasResolver; +import org.apache.gobblin.util.reflection.GobblinConstructorUtils; import lombok.AllArgsConstructor; import lombok.Getter; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/workunit/packer/KafkaAvgRecordSizeBasedWorkUnitSizeEstimator.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/workunit/packer/KafkaAvgRecordSizeBasedWorkUnitSizeEstimator.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/workunit/packer/KafkaAvgRecordSizeBasedWorkUnitSizeEstimator.java index e64abd8..f80c7c4 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/workunit/packer/KafkaAvgRecordSizeBasedWorkUnitSizeEstimator.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/workunit/packer/KafkaAvgRecordSizeBasedWorkUnitSizeEstimator.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor.extract.kafka.workunit.packer; +package org.apache.gobblin.source.extractor.extract.kafka.workunit.packer; import java.util.List; import java.util.Map; @@ -25,12 +25,12 @@ import org.slf4j.LoggerFactory; import com.google.common.collect.Maps; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.SourceState; -import gobblin.configuration.WorkUnitState; -import gobblin.source.extractor.extract.kafka.KafkaPartition; -import gobblin.source.extractor.extract.kafka.KafkaUtils; -import gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.SourceState; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.source.extractor.extract.kafka.KafkaPartition; +import org.apache.gobblin.source.extractor.extract.kafka.KafkaUtils; +import org.apache.gobblin.source.workunit.WorkUnit; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/workunit/packer/KafkaAvgRecordTimeBasedWorkUnitSizeEstimator.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/workunit/packer/KafkaAvgRecordTimeBasedWorkUnitSizeEstimator.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/workunit/packer/KafkaAvgRecordTimeBasedWorkUnitSizeEstimator.java index 1eb60e2..e0539a5 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/workunit/packer/KafkaAvgRecordTimeBasedWorkUnitSizeEstimator.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/workunit/packer/KafkaAvgRecordTimeBasedWorkUnitSizeEstimator.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor.extract.kafka.workunit.packer; +package org.apache.gobblin.source.extractor.extract.kafka.workunit.packer; import java.util.List; import java.util.Map; @@ -28,12 +28,12 @@ import com.google.common.base.Preconditions; import com.google.common.collect.Lists; import com.google.common.collect.Maps; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.SourceState; -import gobblin.configuration.WorkUnitState; -import gobblin.source.extractor.extract.kafka.KafkaPartition; -import gobblin.source.extractor.extract.kafka.KafkaUtils; -import gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.SourceState; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.source.extractor.extract.kafka.KafkaPartition; +import org.apache.gobblin.source.extractor.extract.kafka.KafkaUtils; +import org.apache.gobblin.source.workunit.WorkUnit; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/workunit/packer/KafkaBiLevelWorkUnitPacker.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/workunit/packer/KafkaBiLevelWorkUnitPacker.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/workunit/packer/KafkaBiLevelWorkUnitPacker.java index af38c3a..ae06c67 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/workunit/packer/KafkaBiLevelWorkUnitPacker.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/workunit/packer/KafkaBiLevelWorkUnitPacker.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor.extract.kafka.workunit.packer; +package org.apache.gobblin.source.extractor.extract.kafka.workunit.packer; import java.util.Collections; import java.util.List; @@ -24,11 +24,11 @@ import java.util.PriorityQueue; import com.google.common.collect.Lists; -import gobblin.configuration.SourceState; -import gobblin.configuration.State; -import gobblin.source.extractor.extract.AbstractSource; -import gobblin.source.workunit.MultiWorkUnit; -import gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.configuration.SourceState; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.source.extractor.extract.AbstractSource; +import org.apache.gobblin.source.workunit.MultiWorkUnit; +import org.apache.gobblin.source.workunit.WorkUnit; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/workunit/packer/KafkaSingleLevelWorkUnitPacker.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/workunit/packer/KafkaSingleLevelWorkUnitPacker.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/workunit/packer/KafkaSingleLevelWorkUnitPacker.java index b3d9cfa..b731e96 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/workunit/packer/KafkaSingleLevelWorkUnitPacker.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/workunit/packer/KafkaSingleLevelWorkUnitPacker.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor.extract.kafka.workunit.packer; +package org.apache.gobblin.source.extractor.extract.kafka.workunit.packer; import java.util.List; import java.util.Map; @@ -23,10 +23,10 @@ import java.util.Map; import com.google.common.collect.Lists; import com.google.common.math.DoubleMath; -import gobblin.configuration.SourceState; -import gobblin.source.extractor.extract.AbstractSource; -import gobblin.source.workunit.MultiWorkUnit; -import gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.configuration.SourceState; +import org.apache.gobblin.source.extractor.extract.AbstractSource; +import org.apache.gobblin.source.workunit.MultiWorkUnit; +import org.apache.gobblin.source.workunit.WorkUnit; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.java index 2ebb720..38d050d 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor.extract.kafka.workunit.packer; +package org.apache.gobblin.source.extractor.extract.kafka.workunit.packer; import java.util.Collections; import java.util.Comparator; @@ -32,19 +32,19 @@ import com.google.common.collect.Lists; import com.google.common.collect.MinMaxPriorityQueue; import com.google.common.primitives.Doubles; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.SourceState; -import gobblin.metrics.GobblinMetrics; -import gobblin.metrics.Tag; -import gobblin.source.extractor.WatermarkInterval; -import gobblin.source.extractor.extract.AbstractSource; -import gobblin.source.extractor.extract.kafka.KafkaPartition; -import gobblin.source.extractor.extract.kafka.KafkaSource; -import gobblin.source.extractor.extract.kafka.KafkaUtils; -import gobblin.source.extractor.extract.kafka.MultiLongWatermark; -import gobblin.source.workunit.Extract; -import gobblin.source.workunit.MultiWorkUnit; -import gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.SourceState; +import org.apache.gobblin.metrics.GobblinMetrics; +import org.apache.gobblin.metrics.Tag; +import org.apache.gobblin.source.extractor.WatermarkInterval; +import org.apache.gobblin.source.extractor.extract.AbstractSource; +import org.apache.gobblin.source.extractor.extract.kafka.KafkaPartition; +import org.apache.gobblin.source.extractor.extract.kafka.KafkaSource; +import org.apache.gobblin.source.extractor.extract.kafka.KafkaUtils; +import org.apache.gobblin.source.extractor.extract.kafka.MultiLongWatermark; +import org.apache.gobblin.source.workunit.Extract; +import org.apache.gobblin.source.workunit.MultiWorkUnit; +import org.apache.gobblin.source.workunit.WorkUnit; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitSizeEstimator.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitSizeEstimator.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitSizeEstimator.java index 8181339..892ee83 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitSizeEstimator.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitSizeEstimator.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.source.extractor.extract.kafka.workunit.packer; +package org.apache.gobblin.source.extractor.extract.kafka.workunit.packer; -import gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.source.workunit.WorkUnit; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/test/java/org/apache/gobblin/converter/EnvelopeSchemaConverterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/test/java/org/apache/gobblin/converter/EnvelopeSchemaConverterTest.java b/gobblin-modules/gobblin-kafka-common/src/test/java/org/apache/gobblin/converter/EnvelopeSchemaConverterTest.java index 87e3abb..a00e2c0 100644 --- a/gobblin-modules/gobblin-kafka-common/src/test/java/org/apache/gobblin/converter/EnvelopeSchemaConverterTest.java +++ b/gobblin-modules/gobblin-kafka-common/src/test/java/org/apache/gobblin/converter/EnvelopeSchemaConverterTest.java @@ -15,11 +15,11 @@ * limitations under the License. */ -package gobblin.converter; +package org.apache.gobblin.converter; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.metrics.kafka.KafkaSchemaRegistryFactory; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.metrics.kafka.KafkaSchemaRegistryFactory; import org.apache.avro.Schema; import org.apache.avro.generic.GenericRecord; import org.testng.Assert; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/test/java/org/apache/gobblin/converter/KafkaAvroSchemaRegistryForTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/test/java/org/apache/gobblin/converter/KafkaAvroSchemaRegistryForTest.java b/gobblin-modules/gobblin-kafka-common/src/test/java/org/apache/gobblin/converter/KafkaAvroSchemaRegistryForTest.java index b81eec4..ea960db 100644 --- a/gobblin-modules/gobblin-kafka-common/src/test/java/org/apache/gobblin/converter/KafkaAvroSchemaRegistryForTest.java +++ b/gobblin-modules/gobblin-kafka-common/src/test/java/org/apache/gobblin/converter/KafkaAvroSchemaRegistryForTest.java @@ -15,11 +15,11 @@ * limitations under the License. */ -package gobblin.converter; +package org.apache.gobblin.converter; -import gobblin.metrics.kafka.KafkaAvroSchemaRegistry; -import gobblin.metrics.kafka.KafkaSchemaRegistry; -import gobblin.metrics.kafka.KafkaSchemaRegistryFactory; +import org.apache.gobblin.metrics.kafka.KafkaAvroSchemaRegistry; +import org.apache.gobblin.metrics.kafka.KafkaSchemaRegistry; +import org.apache.gobblin.metrics.kafka.KafkaSchemaRegistryFactory; import java.util.Properties; import org.apache.avro.Schema; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/test/java/org/apache/gobblin/kafka/schemareg/CachingKafkaSchemaRegistryTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/test/java/org/apache/gobblin/kafka/schemareg/CachingKafkaSchemaRegistryTest.java b/gobblin-modules/gobblin-kafka-common/src/test/java/org/apache/gobblin/kafka/schemareg/CachingKafkaSchemaRegistryTest.java index ca31ed0..4ce24d7 100644 --- a/gobblin-modules/gobblin-kafka-common/src/test/java/org/apache/gobblin/kafka/schemareg/CachingKafkaSchemaRegistryTest.java +++ b/gobblin-modules/gobblin-kafka-common/src/test/java/org/apache/gobblin/kafka/schemareg/CachingKafkaSchemaRegistryTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.kafka.schemareg; +package org.apache.gobblin.kafka.schemareg; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/test/java/org/apache/gobblin/kafka/serialize/MD5DigestTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/test/java/org/apache/gobblin/kafka/serialize/MD5DigestTest.java b/gobblin-modules/gobblin-kafka-common/src/test/java/org/apache/gobblin/kafka/serialize/MD5DigestTest.java index dfbebb5..6ffa111 100644 --- a/gobblin-modules/gobblin-kafka-common/src/test/java/org/apache/gobblin/kafka/serialize/MD5DigestTest.java +++ b/gobblin-modules/gobblin-kafka-common/src/test/java/org/apache/gobblin/kafka/serialize/MD5DigestTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.kafka.serialize; +package org.apache.gobblin.kafka.serialize; import java.io.UnsupportedEncodingException; import java.security.MessageDigest; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/converter/MetadataConverterWrapper.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/converter/MetadataConverterWrapper.java b/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/converter/MetadataConverterWrapper.java index 55ea9b2..55395b2 100644 --- a/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/converter/MetadataConverterWrapper.java +++ b/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/converter/MetadataConverterWrapper.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.converter; +package org.apache.gobblin.converter; import java.io.IOException; @@ -23,10 +23,10 @@ import com.google.common.collect.Iterables; import javax.annotation.Nullable; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.metadata.types.Metadata; -import gobblin.type.RecordWithMetadata; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.metadata.types.Metadata; +import org.apache.gobblin.type.RecordWithMetadata; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/converter/RecordWithMetadataToEnvelopedRecordWithMetadata.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/converter/RecordWithMetadataToEnvelopedRecordWithMetadata.java b/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/converter/RecordWithMetadataToEnvelopedRecordWithMetadata.java index 7985fd8..3f3b4f8 100644 --- a/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/converter/RecordWithMetadataToEnvelopedRecordWithMetadata.java +++ b/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/converter/RecordWithMetadataToEnvelopedRecordWithMetadata.java @@ -17,7 +17,7 @@ * under the License. */ -package gobblin.converter; +package org.apache.gobblin.converter; import java.io.ByteArrayOutputStream; import java.io.IOException; @@ -28,10 +28,10 @@ import org.codehaus.jackson.JsonFactory; import org.codehaus.jackson.JsonGenerator; import org.codehaus.jackson.map.ObjectMapper; -import gobblin.configuration.WorkUnitState; -import gobblin.metadata.types.GlobalMetadata; -import gobblin.type.ContentTypeUtils; -import gobblin.type.RecordWithMetadata; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.metadata.types.GlobalMetadata; +import org.apache.gobblin.type.ContentTypeUtils; +import org.apache.gobblin.type.RecordWithMetadata; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/GlobalMetadataCollector.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/GlobalMetadataCollector.java b/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/GlobalMetadataCollector.java index 502cfb0..f8d3f48 100644 --- a/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/GlobalMetadataCollector.java +++ b/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/GlobalMetadataCollector.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.metadata; +package org.apache.gobblin.metadata; import java.util.Collections; import java.util.Iterator; @@ -23,7 +23,7 @@ import java.util.Set; import com.google.common.base.Preconditions; -import gobblin.metadata.types.GlobalMetadata; +import org.apache.gobblin.metadata.types.GlobalMetadata; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/provider/DatasetAwareFsMetadataProvider.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/provider/DatasetAwareFsMetadataProvider.java b/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/provider/DatasetAwareFsMetadataProvider.java index e3dc6b6..d8eed42 100644 --- a/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/provider/DatasetAwareFsMetadataProvider.java +++ b/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/provider/DatasetAwareFsMetadataProvider.java @@ -15,11 +15,11 @@ * limitations under the License. */ -package gobblin.metadata.provider; +package org.apache.gobblin.metadata.provider; import org.apache.hadoop.fs.Path; -import gobblin.metadata.types.GlobalMetadata; +import org.apache.gobblin.metadata.types.GlobalMetadata; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/provider/DatasetAwareMetadataProvider.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/provider/DatasetAwareMetadataProvider.java b/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/provider/DatasetAwareMetadataProvider.java index a28c467..1537cc5 100644 --- a/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/provider/DatasetAwareMetadataProvider.java +++ b/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/provider/DatasetAwareMetadataProvider.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package gobblin.metadata.provider; +package org.apache.gobblin.metadata.provider; -import gobblin.annotation.Alpha; -import gobblin.metadata.types.GlobalMetadata; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.metadata.types.GlobalMetadata; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/provider/DatasetAwareMetadataProviderFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/provider/DatasetAwareMetadataProviderFactory.java b/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/provider/DatasetAwareMetadataProviderFactory.java index 8b88bdf..1e1aea8 100644 --- a/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/provider/DatasetAwareMetadataProviderFactory.java +++ b/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/provider/DatasetAwareMetadataProviderFactory.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metadata.provider; +package org.apache.gobblin.metadata.provider; import com.typesafe.config.Config; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/provider/MetadataAwareFileSystem.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/provider/MetadataAwareFileSystem.java b/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/provider/MetadataAwareFileSystem.java index 4121756..177d582 100644 --- a/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/provider/MetadataAwareFileSystem.java +++ b/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/provider/MetadataAwareFileSystem.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metadata.provider; +package org.apache.gobblin.metadata.provider; import java.io.IOException; @@ -27,15 +27,15 @@ import org.apache.hadoop.util.Progressable; import com.typesafe.config.Config; -import gobblin.broker.iface.ConfigView; -import gobblin.broker.iface.ScopeType; -import gobblin.broker.iface.SharedResourcesBroker; -import gobblin.configuration.ConfigurationKeys; -import gobblin.util.ClassAliasResolver; -import gobblin.util.ConfigUtils; -import gobblin.util.filesystem.FileSystemInstrumentation; -import gobblin.util.filesystem.FileSystemInstrumentationFactory; -import gobblin.util.filesystem.FileSystemKey; +import org.apache.gobblin.broker.iface.ConfigView; +import org.apache.gobblin.broker.iface.ScopeType; +import org.apache.gobblin.broker.iface.SharedResourcesBroker; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.util.ClassAliasResolver; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.util.filesystem.FileSystemInstrumentation; +import org.apache.gobblin.util.filesystem.FileSystemInstrumentationFactory; +import org.apache.gobblin.util.filesystem.FileSystemKey; import lombok.extern.slf4j.Slf4j; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/provider/PermissionMetadataParser.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/provider/PermissionMetadataParser.java b/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/provider/PermissionMetadataParser.java index 7e51e8e..8143a4b 100644 --- a/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/provider/PermissionMetadataParser.java +++ b/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/provider/PermissionMetadataParser.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.metadata.provider; +package org.apache.gobblin.metadata.provider; -import gobblin.metadata.types.GlobalMetadata; +import org.apache.gobblin.metadata.types.GlobalMetadata; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/provider/SimpleConfigMetadataProvider.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/provider/SimpleConfigMetadataProvider.java b/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/provider/SimpleConfigMetadataProvider.java index 3fc54fc..570c23e 100644 --- a/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/provider/SimpleConfigMetadataProvider.java +++ b/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/provider/SimpleConfigMetadataProvider.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package gobblin.metadata.provider; +package org.apache.gobblin.metadata.provider; import org.apache.hadoop.fs.Path; -import gobblin.annotation.Alpha; -import gobblin.metadata.types.GlobalMetadata; +import org.apache.gobblin.annotation.Alpha; +import org.apache.gobblin.metadata.types.GlobalMetadata; import lombok.RequiredArgsConstructor; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/provider/SimpleMetadataProviderFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/provider/SimpleMetadataProviderFactory.java b/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/provider/SimpleMetadataProviderFactory.java index c331c38..fd2f097 100644 --- a/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/provider/SimpleMetadataProviderFactory.java +++ b/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/provider/SimpleMetadataProviderFactory.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package gobblin.metadata.provider; +package org.apache.gobblin.metadata.provider; import com.typesafe.config.Config; -import gobblin.annotation.Alias; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.annotation.Alias; +import org.apache.gobblin.util.ConfigUtils; import lombok.extern.slf4j.Slf4j; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/types/GlobalMetadata.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/types/GlobalMetadata.java b/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/types/GlobalMetadata.java index 681fadc..4dde2f3 100644 --- a/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/types/GlobalMetadata.java +++ b/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/types/GlobalMetadata.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.metadata.types; +package org.apache.gobblin.metadata.types; import java.io.ByteArrayOutputStream; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/types/GlobalMetadataJsonMerger.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/types/GlobalMetadataJsonMerger.java b/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/types/GlobalMetadataJsonMerger.java index 797c436..d4e68bb 100644 --- a/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/types/GlobalMetadataJsonMerger.java +++ b/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/types/GlobalMetadataJsonMerger.java @@ -14,12 +14,12 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.metadata.types; +package org.apache.gobblin.metadata.types; import java.io.IOException; -import gobblin.metadata.MetadataMerger; -import gobblin.writer.FsWriterMetrics; +import org.apache.gobblin.metadata.MetadataMerger; +import org.apache.gobblin.writer.FsWriterMetrics; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/types/Metadata.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/types/Metadata.java b/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/types/Metadata.java index 4e11064..4fe2a7e 100644 --- a/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/types/Metadata.java +++ b/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/types/Metadata.java @@ -1,4 +1,4 @@ -package gobblin.metadata.types; +package org.apache.gobblin.metadata.types; import java.util.HashMap; import java.util.Map; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/types/StaticStringMetadataMerger.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/types/StaticStringMetadataMerger.java b/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/types/StaticStringMetadataMerger.java index 55d19c2..41b96fb 100644 --- a/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/types/StaticStringMetadataMerger.java +++ b/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/types/StaticStringMetadataMerger.java @@ -14,10 +14,10 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.metadata.types; +package org.apache.gobblin.metadata.types; -import gobblin.metadata.MetadataMerger; -import gobblin.writer.FsWriterMetrics; +import org.apache.gobblin.metadata.MetadataMerger; +import org.apache.gobblin.writer.FsWriterMetrics; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/type/ContentTypeUtils.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/type/ContentTypeUtils.java b/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/type/ContentTypeUtils.java index 3c32470..36e52d0 100644 --- a/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/type/ContentTypeUtils.java +++ b/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/type/ContentTypeUtils.java @@ -16,14 +16,14 @@ * specific language governing permissions and limitations * under the License. */ -package gobblin.type; +package org.apache.gobblin.type; import java.util.List; import java.util.concurrent.ConcurrentHashMap; import lombok.extern.slf4j.Slf4j; -import gobblin.metadata.types.Metadata; +import org.apache.gobblin.metadata.types.Metadata; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/type/RecordWithMetadata.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/type/RecordWithMetadata.java b/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/type/RecordWithMetadata.java index 14c3ed1..5d014d6 100644 --- a/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/type/RecordWithMetadata.java +++ b/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/type/RecordWithMetadata.java @@ -17,14 +17,14 @@ * under the License. */ -package gobblin.type; +package org.apache.gobblin.type; import java.util.Map; import lombok.AllArgsConstructor; import lombok.Getter; -import gobblin.metadata.types.Metadata; +import org.apache.gobblin.metadata.types.Metadata; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/type/SerializedRecordWithMetadata.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/type/SerializedRecordWithMetadata.java b/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/type/SerializedRecordWithMetadata.java index 570610c..0041004 100644 --- a/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/type/SerializedRecordWithMetadata.java +++ b/gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/type/SerializedRecordWithMetadata.java @@ -17,14 +17,14 @@ * under the License. */ -package gobblin.type; +package org.apache.gobblin.type; import java.util.List; import java.util.Map; import com.google.common.collect.ImmutableList; -import gobblin.metadata.types.Metadata; +import org.apache.gobblin.metadata.types.Metadata; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metadata/src/test/java/org/apache/gobblin/converter/MetadataConverterWrapperTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metadata/src/test/java/org/apache/gobblin/converter/MetadataConverterWrapperTest.java b/gobblin-modules/gobblin-metadata/src/test/java/org/apache/gobblin/converter/MetadataConverterWrapperTest.java index 59956d3..03672b2 100644 --- a/gobblin-modules/gobblin-metadata/src/test/java/org/apache/gobblin/converter/MetadataConverterWrapperTest.java +++ b/gobblin-modules/gobblin-metadata/src/test/java/org/apache/gobblin/converter/MetadataConverterWrapperTest.java @@ -16,7 +16,7 @@ * specific language governing permissions and limitations * under the License. */ -package gobblin.converter; +package org.apache.gobblin.converter; import java.util.ArrayList; import java.util.Iterator; @@ -25,9 +25,9 @@ import java.util.List; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.configuration.WorkUnitState; -import gobblin.metadata.types.Metadata; -import gobblin.type.RecordWithMetadata; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.metadata.types.Metadata; +import org.apache.gobblin.type.RecordWithMetadata; public class MetadataConverterWrapperTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metadata/src/test/java/org/apache/gobblin/converter/RecordWithMetadataToEnvelopedRecordWithMetadataTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metadata/src/test/java/org/apache/gobblin/converter/RecordWithMetadataToEnvelopedRecordWithMetadataTest.java b/gobblin-modules/gobblin-metadata/src/test/java/org/apache/gobblin/converter/RecordWithMetadataToEnvelopedRecordWithMetadataTest.java index 3f17dce..f2359e4 100644 --- a/gobblin-modules/gobblin-metadata/src/test/java/org/apache/gobblin/converter/RecordWithMetadataToEnvelopedRecordWithMetadataTest.java +++ b/gobblin-modules/gobblin-metadata/src/test/java/org/apache/gobblin/converter/RecordWithMetadataToEnvelopedRecordWithMetadataTest.java @@ -17,7 +17,7 @@ * under the License. */ -package gobblin.converter; +package org.apache.gobblin.converter; import java.io.IOException; import java.nio.charset.StandardCharsets; @@ -29,8 +29,8 @@ import org.codehaus.jackson.map.ObjectMapper; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.metadata.types.Metadata; -import gobblin.type.RecordWithMetadata; +import org.apache.gobblin.metadata.types.Metadata; +import org.apache.gobblin.type.RecordWithMetadata; @Test http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metadata/src/test/java/org/apache/gobblin/metadata/GlobalMetadataCollectorTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metadata/src/test/java/org/apache/gobblin/metadata/GlobalMetadataCollectorTest.java b/gobblin-modules/gobblin-metadata/src/test/java/org/apache/gobblin/metadata/GlobalMetadataCollectorTest.java index c31cd5e..3a00f7c 100644 --- a/gobblin-modules/gobblin-metadata/src/test/java/org/apache/gobblin/metadata/GlobalMetadataCollectorTest.java +++ b/gobblin-modules/gobblin-metadata/src/test/java/org/apache/gobblin/metadata/GlobalMetadataCollectorTest.java @@ -1,11 +1,11 @@ -package gobblin.metadata; +package org.apache.gobblin.metadata; import java.util.Set; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.metadata.types.GlobalMetadata; +import org.apache.gobblin.metadata.types.GlobalMetadata; public class GlobalMetadataCollectorTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metadata/src/test/java/org/apache/gobblin/metadata/types/GlobalMetadataTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metadata/src/test/java/org/apache/gobblin/metadata/types/GlobalMetadataTest.java b/gobblin-modules/gobblin-metadata/src/test/java/org/apache/gobblin/metadata/types/GlobalMetadataTest.java index c3501cc..29838c2 100644 --- a/gobblin-modules/gobblin-metadata/src/test/java/org/apache/gobblin/metadata/types/GlobalMetadataTest.java +++ b/gobblin-modules/gobblin-metadata/src/test/java/org/apache/gobblin/metadata/types/GlobalMetadataTest.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.metadata.types; +package org.apache.gobblin.metadata.types; import java.io.IOException; import java.nio.charset.StandardCharsets; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphiteConnectionType.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphiteConnectionType.java b/gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphiteConnectionType.java index 5dadf8b..a8a063a 100644 --- a/gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphiteConnectionType.java +++ b/gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphiteConnectionType.java @@ -17,7 +17,7 @@ -package gobblin.metrics.graphite; +package org.apache.gobblin.metrics.graphite; import java.net.InetSocketAddress; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphiteEventReporter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphiteEventReporter.java b/gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphiteEventReporter.java index 97590fb..ab9d3dc 100644 --- a/gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphiteEventReporter.java +++ b/gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphiteEventReporter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.graphite; +package org.apache.gobblin.metrics.graphite; import java.io.IOException; import java.util.Map; @@ -27,16 +27,16 @@ import org.slf4j.LoggerFactory; import com.google.common.base.Optional; -import gobblin.configuration.ConfigurationKeys; -import gobblin.metrics.GobblinTrackingEvent; -import gobblin.metrics.MetricContext; -import gobblin.metrics.event.MultiPartEvent; -import gobblin.metrics.event.EventSubmitter; -import gobblin.metrics.event.JobEvent; -import gobblin.metrics.event.TaskEvent; -import gobblin.metrics.reporter.EventReporter; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.metrics.GobblinTrackingEvent; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.event.MultiPartEvent; +import org.apache.gobblin.metrics.event.EventSubmitter; +import org.apache.gobblin.metrics.event.JobEvent; +import org.apache.gobblin.metrics.event.TaskEvent; +import org.apache.gobblin.metrics.reporter.EventReporter; -import static gobblin.metrics.event.TimingEvent.METADATA_DURATION; +import static org.apache.gobblin.metrics.event.TimingEvent.METADATA_DURATION; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphitePusher.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphitePusher.java b/gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphitePusher.java index d6a8e12..77b546b 100644 --- a/gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphitePusher.java +++ b/gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphitePusher.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.graphite; +package org.apache.gobblin.metrics.graphite; import java.io.Closeable; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphiteReporter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphiteReporter.java b/gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphiteReporter.java index 9aa315a..5170524 100644 --- a/gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphiteReporter.java +++ b/gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphiteReporter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.graphite; +package org.apache.gobblin.metrics.graphite; import java.io.IOException; import java.util.Map; @@ -37,11 +37,11 @@ import com.codahale.metrics.Timer; import com.google.common.base.Optional; import com.typesafe.config.Config; -import gobblin.configuration.ConfigurationKeys; -import gobblin.metrics.Measurements; -import gobblin.metrics.reporter.ConfiguredScheduledReporter; -import gobblin.util.ConfigUtils; -import static gobblin.metrics.Measurements.*; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.metrics.Measurements; +import org.apache.gobblin.metrics.reporter.ConfiguredScheduledReporter; +import org.apache.gobblin.util.ConfigUtils; +import static org.apache.gobblin.metrics.Measurements.*; /** * Graphite reporter for metrics http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metrics-graphite/src/test/java/org/apache/gobblin/metrics/graphite/GraphiteEventReporterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metrics-graphite/src/test/java/org/apache/gobblin/metrics/graphite/GraphiteEventReporterTest.java b/gobblin-modules/gobblin-metrics-graphite/src/test/java/org/apache/gobblin/metrics/graphite/GraphiteEventReporterTest.java index 79a2483..bea0c17 100644 --- a/gobblin-modules/gobblin-metrics-graphite/src/test/java/org/apache/gobblin/metrics/graphite/GraphiteEventReporterTest.java +++ b/gobblin-modules/gobblin-metrics-graphite/src/test/java/org/apache/gobblin/metrics/graphite/GraphiteEventReporterTest.java @@ -15,15 +15,15 @@ * limitations under the License. */ -package gobblin.metrics.graphite; - -import gobblin.metrics.GobblinTrackingEvent; -import gobblin.metrics.MetricContext; -import gobblin.metrics.event.EventSubmitter; -import gobblin.metrics.event.JobEvent; -import gobblin.metrics.event.MultiPartEvent; -import gobblin.metrics.event.TaskEvent; -import gobblin.metrics.test.TimestampedValue; +package org.apache.gobblin.metrics.graphite; + +import org.apache.gobblin.metrics.GobblinTrackingEvent; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.event.EventSubmitter; +import org.apache.gobblin.metrics.event.JobEvent; +import org.apache.gobblin.metrics.event.MultiPartEvent; +import org.apache.gobblin.metrics.event.TaskEvent; +import org.apache.gobblin.metrics.test.TimestampedValue; import java.io.IOException; import java.util.Map; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metrics-graphite/src/test/java/org/apache/gobblin/metrics/graphite/GraphiteReporterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metrics-graphite/src/test/java/org/apache/gobblin/metrics/graphite/GraphiteReporterTest.java b/gobblin-modules/gobblin-metrics-graphite/src/test/java/org/apache/gobblin/metrics/graphite/GraphiteReporterTest.java index 20b95fc..ef5a6ef 100644 --- a/gobblin-modules/gobblin-metrics-graphite/src/test/java/org/apache/gobblin/metrics/graphite/GraphiteReporterTest.java +++ b/gobblin-modules/gobblin-metrics-graphite/src/test/java/org/apache/gobblin/metrics/graphite/GraphiteReporterTest.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package gobblin.metrics.graphite; +package org.apache.gobblin.metrics.graphite; -import gobblin.metrics.ContextAwareGauge; -import gobblin.metrics.Measurements; -import gobblin.metrics.MetricContext; -import gobblin.metrics.Tag; +import org.apache.gobblin.metrics.ContextAwareGauge; +import org.apache.gobblin.metrics.Measurements; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.Tag; import java.io.IOException; import java.util.Properties; @@ -39,13 +39,13 @@ import com.codahale.metrics.Meter; import com.codahale.metrics.MetricRegistry; import com.codahale.metrics.Timer; -import static gobblin.metrics.test.TestConstants.METRIC_PREFIX; -import static gobblin.metrics.test.TestConstants.GAUGE; -import static gobblin.metrics.test.TestConstants.COUNTER; -import static gobblin.metrics.test.TestConstants.METER; -import static gobblin.metrics.test.TestConstants.HISTOGRAM; -import static gobblin.metrics.test.TestConstants.TIMER; -import static gobblin.metrics.test.TestConstants.CONTEXT_NAME; +import static org.apache.gobblin.metrics.test.TestConstants.METRIC_PREFIX; +import static org.apache.gobblin.metrics.test.TestConstants.GAUGE; +import static org.apache.gobblin.metrics.test.TestConstants.COUNTER; +import static org.apache.gobblin.metrics.test.TestConstants.METER; +import static org.apache.gobblin.metrics.test.TestConstants.HISTOGRAM; +import static org.apache.gobblin.metrics.test.TestConstants.TIMER; +import static org.apache.gobblin.metrics.test.TestConstants.CONTEXT_NAME; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metrics-graphite/src/test/java/org/apache/gobblin/metrics/graphite/TestGraphiteSender.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metrics-graphite/src/test/java/org/apache/gobblin/metrics/graphite/TestGraphiteSender.java b/gobblin-modules/gobblin-metrics-graphite/src/test/java/org/apache/gobblin/metrics/graphite/TestGraphiteSender.java index d9a9812..a09f0ce 100644 --- a/gobblin-modules/gobblin-metrics-graphite/src/test/java/org/apache/gobblin/metrics/graphite/TestGraphiteSender.java +++ b/gobblin-modules/gobblin-metrics-graphite/src/test/java/org/apache/gobblin/metrics/graphite/TestGraphiteSender.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.metrics.graphite; +package org.apache.gobblin.metrics.graphite; -import gobblin.metrics.test.TimestampedValue; +import org.apache.gobblin.metrics.test.TimestampedValue; import java.io.IOException; import java.util.Map; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metrics-hadoop/src/main/java/org/apache/gobblin/metrics/hadoop/AbstractHadoopCounterReporter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metrics-hadoop/src/main/java/org/apache/gobblin/metrics/hadoop/AbstractHadoopCounterReporter.java b/gobblin-modules/gobblin-metrics-hadoop/src/main/java/org/apache/gobblin/metrics/hadoop/AbstractHadoopCounterReporter.java index ef212bf..6a00709 100644 --- a/gobblin-modules/gobblin-metrics-hadoop/src/main/java/org/apache/gobblin/metrics/hadoop/AbstractHadoopCounterReporter.java +++ b/gobblin-modules/gobblin-metrics-hadoop/src/main/java/org/apache/gobblin/metrics/hadoop/AbstractHadoopCounterReporter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.hadoop; +package org.apache.gobblin.metrics.hadoop; import java.util.Map; import java.util.SortedMap; @@ -31,9 +31,9 @@ import com.codahale.metrics.Timer; import com.google.common.collect.Maps; -import gobblin.metrics.reporter.ContextAwareScheduledReporter; -import gobblin.metrics.Measurements; -import gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.reporter.ContextAwareScheduledReporter; +import org.apache.gobblin.metrics.Measurements; +import org.apache.gobblin.metrics.MetricContext; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metrics-hadoop/src/main/java/org/apache/gobblin/metrics/hadoop/HadoopCounterReporter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metrics-hadoop/src/main/java/org/apache/gobblin/metrics/hadoop/HadoopCounterReporter.java b/gobblin-modules/gobblin-metrics-hadoop/src/main/java/org/apache/gobblin/metrics/hadoop/HadoopCounterReporter.java index df4f56b..d70507c 100644 --- a/gobblin-modules/gobblin-metrics-hadoop/src/main/java/org/apache/gobblin/metrics/hadoop/HadoopCounterReporter.java +++ b/gobblin-modules/gobblin-metrics-hadoop/src/main/java/org/apache/gobblin/metrics/hadoop/HadoopCounterReporter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.hadoop; +package org.apache.gobblin.metrics.hadoop; import java.util.concurrent.TimeUnit; @@ -23,8 +23,8 @@ import org.apache.hadoop.mapred.Reporter; import com.codahale.metrics.MetricFilter; -import gobblin.metrics.reporter.ContextAwareScheduledReporter; -import gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.reporter.ContextAwareScheduledReporter; +import org.apache.gobblin.metrics.MetricContext; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metrics-hadoop/src/main/java/org/apache/gobblin/metrics/hadoop/NewAPIHadoopCounterReporter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metrics-hadoop/src/main/java/org/apache/gobblin/metrics/hadoop/NewAPIHadoopCounterReporter.java b/gobblin-modules/gobblin-metrics-hadoop/src/main/java/org/apache/gobblin/metrics/hadoop/NewAPIHadoopCounterReporter.java index f508062..b17bb2d 100644 --- a/gobblin-modules/gobblin-metrics-hadoop/src/main/java/org/apache/gobblin/metrics/hadoop/NewAPIHadoopCounterReporter.java +++ b/gobblin-modules/gobblin-metrics-hadoop/src/main/java/org/apache/gobblin/metrics/hadoop/NewAPIHadoopCounterReporter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.hadoop; +package org.apache.gobblin.metrics.hadoop; import java.util.concurrent.TimeUnit; @@ -23,8 +23,8 @@ import org.apache.hadoop.mapreduce.TaskInputOutputContext; import com.codahale.metrics.MetricFilter; -import gobblin.metrics.reporter.ContextAwareScheduledReporter; -import gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.reporter.ContextAwareScheduledReporter; +import org.apache.gobblin.metrics.MetricContext; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metrics-hadoop/src/test/java/org/apache/gobblin/metrics/hadoop/HadoopCounterReporterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metrics-hadoop/src/test/java/org/apache/gobblin/metrics/hadoop/HadoopCounterReporterTest.java b/gobblin-modules/gobblin-metrics-hadoop/src/test/java/org/apache/gobblin/metrics/hadoop/HadoopCounterReporterTest.java index bbe282e..66d9ff9 100644 --- a/gobblin-modules/gobblin-metrics-hadoop/src/test/java/org/apache/gobblin/metrics/hadoop/HadoopCounterReporterTest.java +++ b/gobblin-modules/gobblin-metrics-hadoop/src/test/java/org/apache/gobblin/metrics/hadoop/HadoopCounterReporterTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.hadoop; +package org.apache.gobblin.metrics.hadoop; import java.util.SortedMap; import java.util.UUID; @@ -40,9 +40,9 @@ import com.codahale.metrics.Timer; import com.google.common.collect.ImmutableSortedMap; -import gobblin.metrics.Measurements; -import gobblin.metrics.MetricContext; -import static gobblin.metrics.test.TestConstants.*; +import org.apache.gobblin.metrics.Measurements; +import org.apache.gobblin.metrics.MetricContext; +import static org.apache.gobblin.metrics.test.TestConstants.*; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metrics-hadoop/src/test/java/org/apache/gobblin/metrics/hadoop/NewAPIHadoopCounterReporterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metrics-hadoop/src/test/java/org/apache/gobblin/metrics/hadoop/NewAPIHadoopCounterReporterTest.java b/gobblin-modules/gobblin-metrics-hadoop/src/test/java/org/apache/gobblin/metrics/hadoop/NewAPIHadoopCounterReporterTest.java index 53cafe4..8bff876 100644 --- a/gobblin-modules/gobblin-metrics-hadoop/src/test/java/org/apache/gobblin/metrics/hadoop/NewAPIHadoopCounterReporterTest.java +++ b/gobblin-modules/gobblin-metrics-hadoop/src/test/java/org/apache/gobblin/metrics/hadoop/NewAPIHadoopCounterReporterTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.hadoop; +package org.apache.gobblin.metrics.hadoop; import java.util.SortedMap; import java.util.UUID; @@ -39,9 +39,9 @@ import com.codahale.metrics.Timer; import com.google.common.collect.ImmutableSortedMap; -import gobblin.metrics.Measurements; -import gobblin.metrics.MetricContext; -import static gobblin.metrics.test.TestConstants.*; +import org.apache.gobblin.metrics.Measurements; +import org.apache.gobblin.metrics.MetricContext; +import static org.apache.gobblin.metrics.test.TestConstants.*; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb/InfluxDBConnectionType.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb/InfluxDBConnectionType.java b/gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb/InfluxDBConnectionType.java index 39a0f62..064495f 100644 --- a/gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb/InfluxDBConnectionType.java +++ b/gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb/InfluxDBConnectionType.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.influxdb; +package org.apache.gobblin.metrics.influxdb; import org.influxdb.InfluxDB; import org.influxdb.InfluxDBFactory; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb/InfluxDBEventReporter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb/InfluxDBEventReporter.java b/gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb/InfluxDBEventReporter.java index 5ed2d87..79382d9 100644 --- a/gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb/InfluxDBEventReporter.java +++ b/gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb/InfluxDBEventReporter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.influxdb; +package org.apache.gobblin.metrics.influxdb; import java.io.IOException; import java.util.List; @@ -31,13 +31,13 @@ import com.google.common.base.Optional; import com.google.common.collect.Lists; import com.google.common.primitives.Doubles; -import gobblin.metrics.GobblinTrackingEvent; -import gobblin.metrics.MetricContext; -import gobblin.metrics.event.MultiPartEvent; -import gobblin.metrics.event.EventSubmitter; -import gobblin.metrics.reporter.EventReporter; +import org.apache.gobblin.metrics.GobblinTrackingEvent; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.event.MultiPartEvent; +import org.apache.gobblin.metrics.event.EventSubmitter; +import org.apache.gobblin.metrics.reporter.EventReporter; -import static gobblin.metrics.event.TimingEvent.METADATA_DURATION; +import static org.apache.gobblin.metrics.event.TimingEvent.METADATA_DURATION; /** *
