http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaAvroEventReporterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaAvroEventReporterTest.java b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaAvroEventReporterTest.java index 4b0b466..066dce4 100644 --- a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaAvroEventReporterTest.java +++ b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaAvroEventReporterTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.reporter; +package org.apache.gobblin.metrics.reporter; import java.io.IOException; import java.util.Iterator; @@ -23,12 +23,12 @@ import java.util.Iterator; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.metrics.GobblinTrackingEvent; -import gobblin.metrics.MetricContext; -import gobblin.metrics.reporter.util.EventUtils; -import gobblin.metrics.kafka.KafkaAvroEventReporter; -import gobblin.metrics.kafka.KafkaEventReporter; -import gobblin.metrics.kafka.KafkaPusher; +import org.apache.gobblin.metrics.GobblinTrackingEvent; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.reporter.util.EventUtils; +import org.apache.gobblin.metrics.kafka.KafkaAvroEventReporter; +import org.apache.gobblin.metrics.kafka.KafkaEventReporter; +import org.apache.gobblin.metrics.kafka.KafkaPusher; @Test(groups = {"gobblin.metrics"})
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaAvroEventReporterWithSchemaRegistryTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaAvroEventReporterWithSchemaRegistryTest.java b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaAvroEventReporterWithSchemaRegistryTest.java index dde9429..9d418da 100644 --- a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaAvroEventReporterWithSchemaRegistryTest.java +++ b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaAvroEventReporterWithSchemaRegistryTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.reporter; +package org.apache.gobblin.metrics.reporter; import java.io.ByteArrayInputStream; import java.io.DataInputStream; @@ -32,12 +32,12 @@ import org.testng.annotations.Test; import com.google.common.collect.Maps; -import gobblin.metrics.GobblinTrackingEvent; -import gobblin.metrics.MetricContext; -import gobblin.metrics.kafka.KafkaAvroEventReporter; -import gobblin.metrics.kafka.KafkaAvroSchemaRegistry; -import gobblin.metrics.kafka.KafkaEventReporter; -import gobblin.metrics.kafka.SchemaRegistryException; +import org.apache.gobblin.metrics.GobblinTrackingEvent; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.kafka.KafkaAvroEventReporter; +import org.apache.gobblin.metrics.kafka.KafkaAvroSchemaRegistry; +import org.apache.gobblin.metrics.kafka.KafkaEventReporter; +import org.apache.gobblin.metrics.kafka.SchemaRegistryException; public class KafkaAvroEventReporterWithSchemaRegistryTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaAvroReporterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaAvroReporterTest.java b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaAvroReporterTest.java index 81aae3c..bbf2646 100644 --- a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaAvroReporterTest.java +++ b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaAvroReporterTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.reporter; +package org.apache.gobblin.metrics.reporter; import java.io.IOException; import java.util.Iterator; @@ -23,11 +23,11 @@ import java.util.Iterator; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.metrics.MetricReport; -import gobblin.metrics.reporter.util.MetricReportUtils; -import gobblin.metrics.kafka.KafkaAvroReporter; -import gobblin.metrics.kafka.KafkaPusher; -import gobblin.metrics.kafka.KafkaReporter; +import org.apache.gobblin.metrics.MetricReport; +import org.apache.gobblin.metrics.reporter.util.MetricReportUtils; +import org.apache.gobblin.metrics.kafka.KafkaAvroReporter; +import org.apache.gobblin.metrics.kafka.KafkaPusher; +import org.apache.gobblin.metrics.kafka.KafkaReporter; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaEventReporterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaEventReporterTest.java b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaEventReporterTest.java index f9acc78..177f8d3 100644 --- a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaEventReporterTest.java +++ b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaEventReporterTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.reporter; +package org.apache.gobblin.metrics.reporter; import java.io.IOException; import java.util.Iterator; @@ -26,12 +26,12 @@ import org.testng.annotations.Test; import com.google.common.collect.Maps; -import gobblin.metrics.GobblinTrackingEvent; -import gobblin.metrics.MetricContext; -import gobblin.metrics.Tag; -import gobblin.metrics.reporter.util.EventUtils; -import gobblin.metrics.kafka.KafkaEventReporter; -import gobblin.metrics.kafka.KafkaPusher; +import org.apache.gobblin.metrics.GobblinTrackingEvent; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.Tag; +import org.apache.gobblin.metrics.reporter.util.EventUtils; +import org.apache.gobblin.metrics.kafka.KafkaEventReporter; +import org.apache.gobblin.metrics.kafka.KafkaPusher; @Test(groups = {"gobblin.metrics"}) http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaPusherTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaPusherTest.java b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaPusherTest.java index c2e3c8c..551a0f3 100644 --- a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaPusherTest.java +++ b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaPusherTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.reporter; +package org.apache.gobblin.metrics.reporter; import java.io.IOException; @@ -26,7 +26,7 @@ import org.testng.annotations.Test; import com.google.common.collect.Lists; -import gobblin.metrics.kafka.KafkaPusher; +import org.apache.gobblin.metrics.kafka.KafkaPusher; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaReporterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaReporterTest.java b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaReporterTest.java index 0e567a2..c431cb0 100644 --- a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaReporterTest.java +++ b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaReporterTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.reporter; +package org.apache.gobblin.metrics.reporter; import java.io.IOException; import java.util.Iterator; @@ -35,14 +35,14 @@ import com.codahale.metrics.Meter; import com.google.common.collect.Lists; -import gobblin.metrics.Measurements; -import gobblin.metrics.Metric; -import gobblin.metrics.MetricContext; -import gobblin.metrics.MetricReport; -import gobblin.metrics.Tag; -import gobblin.metrics.kafka.KafkaPusher; -import gobblin.metrics.kafka.KafkaReporter; -import gobblin.metrics.reporter.util.MetricReportUtils; +import org.apache.gobblin.metrics.Measurements; +import org.apache.gobblin.metrics.Metric; +import org.apache.gobblin.metrics.MetricContext; +import org.apache.gobblin.metrics.MetricReport; +import org.apache.gobblin.metrics.Tag; +import org.apache.gobblin.metrics.kafka.KafkaPusher; +import org.apache.gobblin.metrics.kafka.KafkaReporter; +import org.apache.gobblin.metrics.reporter.util.MetricReportUtils; @Test(groups = { "gobblin.metrics" }) http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaTestBase.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaTestBase.java b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaTestBase.java index f18ec28..11aa603 100644 --- a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaTestBase.java +++ b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/KafkaTestBase.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.reporter; +package org.apache.gobblin.metrics.reporter; import java.io.Closeable; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/MockKafkaPusher.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/MockKafkaPusher.java b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/MockKafkaPusher.java index b13053e..8c3f04f 100644 --- a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/MockKafkaPusher.java +++ b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/metrics/reporter/MockKafkaPusher.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.reporter; +package org.apache.gobblin.metrics.reporter; import java.io.IOException; import java.util.Iterator; @@ -26,8 +26,8 @@ import com.google.common.collect.Queues; import kafka.producer.ProducerConfig; -import gobblin.metrics.kafka.KafkaPusher; -import gobblin.metrics.kafka.ProducerCloseable; +import org.apache.gobblin.metrics.kafka.KafkaPusher; +import org.apache.gobblin.metrics.kafka.ProducerCloseable; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/service/SimpleKafkaSpecExecutorInstanceTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/service/SimpleKafkaSpecExecutorInstanceTest.java b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/service/SimpleKafkaSpecExecutorInstanceTest.java index 6ce1fa7..58c5d72 100644 --- a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/service/SimpleKafkaSpecExecutorInstanceTest.java +++ b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/service/SimpleKafkaSpecExecutorInstanceTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.service; +package org.apache.gobblin.service; import java.net.URI; import java.util.List; @@ -31,14 +31,14 @@ import org.testng.annotations.AfterSuite; import org.testng.annotations.Test; import com.google.common.io.Closer; -import gobblin.configuration.ConfigurationKeys; -import gobblin.kafka.writer.KafkaWriterConfigurationKeys; -import gobblin.metrics.reporter.KafkaTestBase; -import gobblin.runtime.api.JobSpec; -import gobblin.runtime.api.Spec; -import gobblin.runtime.api.SpecExecutorInstance; -import gobblin.util.ConfigUtils; -import gobblin.writer.WriteResponse; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.kafka.writer.KafkaWriterConfigurationKeys; +import org.apache.gobblin.metrics.reporter.KafkaTestBase; +import org.apache.gobblin.runtime.api.JobSpec; +import org.apache.gobblin.runtime.api.Spec; +import org.apache.gobblin.runtime.api.SpecExecutorInstance; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.writer.WriteResponse; @Slf4j http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/service/StreamingKafkaSpecExecutorInstanceTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/service/StreamingKafkaSpecExecutorInstanceTest.java b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/service/StreamingKafkaSpecExecutorInstanceTest.java index 550b4e5..939aafa 100644 --- a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/service/StreamingKafkaSpecExecutorInstanceTest.java +++ b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/service/StreamingKafkaSpecExecutorInstanceTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.service; +package org.apache.gobblin.service; import java.io.File; import java.io.IOException; @@ -35,15 +35,15 @@ import org.testng.annotations.Test; import com.google.common.io.Closer; import com.typesafe.config.Config; -import gobblin.configuration.ConfigurationKeys; -import gobblin.kafka.writer.KafkaWriterConfigurationKeys; -import gobblin.metrics.reporter.KafkaTestBase; -import gobblin.runtime.api.JobSpec; -import gobblin.runtime.api.Spec; -import gobblin.runtime.api.SpecExecutorInstance; -import gobblin.runtime.job_catalog.NonObservingFSJobCatalog; -import gobblin.util.ConfigUtils; -import gobblin.writer.WriteResponse; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.kafka.writer.KafkaWriterConfigurationKeys; +import org.apache.gobblin.metrics.reporter.KafkaTestBase; +import org.apache.gobblin.runtime.api.JobSpec; +import org.apache.gobblin.runtime.api.Spec; +import org.apache.gobblin.runtime.api.SpecExecutorInstance; +import org.apache.gobblin.runtime.job_catalog.NonObservingFSJobCatalog; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.writer.WriteResponse; import lombok.extern.slf4j.Slf4j; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/source/extractor/extract/kafka/ConfluentKafkaSchemaRegistryTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/source/extractor/extract/kafka/ConfluentKafkaSchemaRegistryTest.java b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/source/extractor/extract/kafka/ConfluentKafkaSchemaRegistryTest.java index 550c78c..15f3e87 100644 --- a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/source/extractor/extract/kafka/ConfluentKafkaSchemaRegistryTest.java +++ b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/source/extractor/extract/kafka/ConfluentKafkaSchemaRegistryTest.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.Properties; @@ -28,8 +28,8 @@ import org.testng.annotations.Test; import io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient; import io.confluent.kafka.schemaregistry.client.SchemaRegistryClient; -import gobblin.metrics.kafka.KafkaSchemaRegistry; -import gobblin.metrics.kafka.SchemaRegistryException; +import org.apache.gobblin.metrics.kafka.KafkaSchemaRegistry; +import org.apache.gobblin.metrics.kafka.SchemaRegistryException; @Test(groups = { "gobblin.source.extractor.extract.kafka" }) http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaDeserializerExtractorTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaDeserializerExtractorTest.java b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaDeserializerExtractorTest.java index 4af4a8d..cdf7b51 100644 --- a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaDeserializerExtractorTest.java +++ b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaDeserializerExtractorTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.source.extractor.extract.kafka; +package org.apache.gobblin.source.extractor.extract.kafka; import static org.mockito.Matchers.any; import static org.mockito.Mockito.mock; @@ -51,17 +51,17 @@ import org.testng.annotations.Test; import com.google.common.base.Optional; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.kafka.client.ByteArrayBasedKafkaRecord; -import gobblin.kafka.client.Kafka08ConsumerClient.Kafka08ConsumerRecord; -import gobblin.metrics.kafka.KafkaSchemaRegistry; -import gobblin.metrics.kafka.SchemaRegistryException; -import gobblin.source.extractor.WatermarkInterval; -import gobblin.source.extractor.extract.kafka.KafkaDeserializerExtractor.Deserializers; -import gobblin.source.workunit.WorkUnit; -import gobblin.util.PropertiesUtils; +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.Kafka08ConsumerClient.Kafka08ConsumerRecord; +import org.apache.gobblin.metrics.kafka.KafkaSchemaRegistry; +import org.apache.gobblin.metrics.kafka.SchemaRegistryException; +import org.apache.gobblin.source.extractor.WatermarkInterval; +import org.apache.gobblin.source.extractor.extract.kafka.KafkaDeserializerExtractor.Deserializers; +import org.apache.gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.util.PropertiesUtils; @Test(groups = { "gobblin.source.extractor.extract.kafka" }) @@ -107,7 +107,7 @@ public class KafkaDeserializerExtractorTest { Assert.assertEquals(kafkaDecoderExtractor.getKafkaSchemaRegistry().getClass(), KafkaDeserializerExtractor.Deserializers.STRING.getSchemaRegistryClass()); } - + @Test public void testBuiltInGsonDeserializer() throws ReflectiveOperationException { WorkUnitState mockWorkUnitState = getMockWorkUnitState(); @@ -121,7 +121,7 @@ public class KafkaDeserializerExtractorTest { Assert.assertEquals(kafkaDecoderExtractor.getKafkaSchemaRegistry().getClass(), KafkaDeserializerExtractor.Deserializers.GSON.getSchemaRegistryClass()); } - + @Test public void testBuiltInConfluentAvroDeserializer() throws ReflectiveOperationException { WorkUnitState mockWorkUnitState = getMockWorkUnitState(); @@ -166,7 +166,7 @@ public class KafkaDeserializerExtractorTest { .namespace(TEST_NAMESPACE).fields() .name(TEST_FIELD_NAME).type().stringType().noDefault() .endRecord(); - + GenericRecord testGenericRecord = new GenericRecordBuilder(schema).set(TEST_FIELD_NAME, "testValue").build(); SchemaRegistryClient mockSchemaRegistryClient = mock(SchemaRegistryClient.class); @@ -179,15 +179,15 @@ public class KafkaDeserializerExtractorTest { ByteBuffer.wrap(kafkaEncoder.serialize(TEST_TOPIC_NAME, testGenericRecord)); KafkaSchemaRegistry<Integer, Schema> mockKafkaSchemaRegistry = mock(KafkaSchemaRegistry.class); - KafkaDeserializerExtractor kafkaDecoderExtractor = - new KafkaDeserializerExtractor(mockWorkUnitState, + KafkaDeserializerExtractor kafkaDecoderExtractor = + new KafkaDeserializerExtractor(mockWorkUnitState, Optional.fromNullable(Deserializers.CONFLUENT_AVRO), kafkaDecoder, mockKafkaSchemaRegistry); ByteArrayBasedKafkaRecord mockMessageAndOffset = getMockMessageAndOffset(testGenericRecordByteBuffer); Assert.assertEquals(kafkaDecoderExtractor.decodeRecord(mockMessageAndOffset), testGenericRecord); } - + @Test public void testConfluentAvroDeserializerForSchemaEvolution() throws IOException, RestClientException, SchemaRegistryException { WorkUnitState mockWorkUnitState = getMockWorkUnitState(); @@ -197,12 +197,12 @@ public class KafkaDeserializerExtractorTest { .namespace(TEST_NAMESPACE).fields() .name(TEST_FIELD_NAME).type().stringType().noDefault() .endRecord(); - + Schema schemaV2 = SchemaBuilder.record(TEST_RECORD_NAME) .namespace(TEST_NAMESPACE).fields() .name(TEST_FIELD_NAME).type().stringType().noDefault() .optionalString(TEST_FIELD_NAME2).endRecord(); - + GenericRecord testGenericRecord = new GenericRecordBuilder(schemaV1).set(TEST_FIELD_NAME, "testValue").build(); SchemaRegistryClient mockSchemaRegistryClient = mock(SchemaRegistryClient.class); @@ -216,16 +216,16 @@ public class KafkaDeserializerExtractorTest { KafkaSchemaRegistry<Integer, Schema> mockKafkaSchemaRegistry = mock(KafkaSchemaRegistry.class); when(mockKafkaSchemaRegistry.getLatestSchemaByTopic(TEST_TOPIC_NAME)).thenReturn(schemaV2); - + KafkaDeserializerExtractor kafkaDecoderExtractor = new KafkaDeserializerExtractor(mockWorkUnitState, Optional.fromNullable(Deserializers.CONFLUENT_AVRO), kafkaDecoder, mockKafkaSchemaRegistry); when(kafkaDecoderExtractor.getSchema()).thenReturn(schemaV2); - + ByteArrayBasedKafkaRecord mockMessageAndOffset = getMockMessageAndOffset(testGenericRecordByteBuffer); GenericRecord received = (GenericRecord) kafkaDecoderExtractor.decodeRecord(mockMessageAndOffset); Assert.assertEquals(received.toString(), "{\"testField\": \"testValue\", \"testField2\": null}"); - + } @Test @@ -245,7 +245,7 @@ public class KafkaDeserializerExtractorTest { KafkaSchemaRegistry<?, ?> mockKafkaSchemaRegistry = mock(KafkaSchemaRegistry.class); KafkaDeserializerExtractor kafkaDecoderExtractor = - new KafkaDeserializerExtractor(mockWorkUnitState, + new KafkaDeserializerExtractor(mockWorkUnitState, Optional.fromNullable(Deserializers.CONFLUENT_JSON), kafkaDecoder, mockKafkaSchemaRegistry); ByteArrayBasedKafkaRecord mockMessageAndOffset = getMockMessageAndOffset(testKafkaRecordByteBuffer); http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaGsonDeserializerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaGsonDeserializerTest.java b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaGsonDeserializerTest.java index 33e3631..14d1711 100644 --- a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaGsonDeserializerTest.java +++ b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaGsonDeserializerTest.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.kafka.common.serialization.Deserializer; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaWrapperTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaWrapperTest.java b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaWrapperTest.java index 12b3182..bbc7410 100644 --- a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaWrapperTest.java +++ b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaWrapperTest.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.Properties; @@ -24,8 +24,8 @@ import org.testng.annotations.Test; import lombok.extern.slf4j.Slf4j; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; @Slf4j public class KafkaWrapperTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/source/extractor/extract/kafka/SimpleKafkaSchemaRegistryTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/source/extractor/extract/kafka/SimpleKafkaSchemaRegistryTest.java b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/source/extractor/extract/kafka/SimpleKafkaSchemaRegistryTest.java index e88bb18..057a8f0 100644 --- a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/source/extractor/extract/kafka/SimpleKafkaSchemaRegistryTest.java +++ b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/source/extractor/extract/kafka/SimpleKafkaSchemaRegistryTest.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.util.Properties; import org.testng.Assert; import org.testng.annotations.Test; -import gobblin.metrics.kafka.SchemaRegistryException; +import org.apache.gobblin.metrics.kafka.SchemaRegistryException; @Test(groups = { "gobblin.source.extractor.extract.kafka" }) http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/client/Kafka09ConsumerClient.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/client/Kafka09ConsumerClient.java b/gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/client/Kafka09ConsumerClient.java index 77c65b2..b6cd35d 100644 --- a/gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/client/Kafka09ConsumerClient.java +++ b/gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/client/Kafka09ConsumerClient.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.kafka.client; +package org.apache.gobblin.kafka.client; import java.io.IOException; import java.util.Iterator; @@ -44,11 +44,11 @@ import com.google.common.collect.Iterators; import com.google.common.collect.Lists; import com.typesafe.config.Config; -import gobblin.source.extractor.extract.kafka.KafkaOffsetRetrievalFailureException; -import gobblin.source.extractor.extract.kafka.KafkaPartition; -import gobblin.source.extractor.extract.kafka.KafkaTopic; -import gobblin.util.ConfigUtils; -import gobblin.util.DatasetFilterUtils; +import org.apache.gobblin.source.extractor.extract.kafka.KafkaOffsetRetrievalFailureException; +import org.apache.gobblin.source.extractor.extract.kafka.KafkaPartition; +import org.apache.gobblin.source.extractor.extract.kafka.KafkaTopic; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.util.DatasetFilterUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroDeserializer.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroDeserializer.java b/gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroDeserializer.java index 71a2e3b..78cd932 100644 --- a/gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroDeserializer.java +++ b/gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroDeserializer.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.kafka.serialize; +package org.apache.gobblin.kafka.serialize; import java.io.IOException; import java.util.Map; @@ -34,9 +34,9 @@ import com.google.common.base.Preconditions; import lombok.extern.slf4j.Slf4j; -import gobblin.kafka.schemareg.KafkaSchemaRegistry; -import gobblin.kafka.schemareg.KafkaSchemaRegistryFactory; -import gobblin.kafka.schemareg.SchemaRegistryException; +import org.apache.gobblin.kafka.schemareg.KafkaSchemaRegistry; +import org.apache.gobblin.kafka.schemareg.KafkaSchemaRegistryFactory; +import org.apache.gobblin.kafka.schemareg.SchemaRegistryException; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroSerializer.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroSerializer.java b/gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroSerializer.java index 4dc0add..6bf812a 100644 --- a/gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroSerializer.java +++ b/gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroSerializer.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.kafka.serialize; +package org.apache.gobblin.kafka.serialize; import java.io.IOException; @@ -23,7 +23,7 @@ import org.apache.avro.generic.GenericRecord; import org.apache.kafka.common.errors.SerializationException; import org.apache.kafka.common.serialization.Serializer; -import gobblin.kafka.schemareg.SchemaRegistryException; +import org.apache.gobblin.kafka.schemareg.SchemaRegistryException; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/writer/Kafka09DataWriter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/writer/Kafka09DataWriter.java b/gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/writer/Kafka09DataWriter.java index 1e79efa..40a8a4c 100644 --- a/gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/writer/Kafka09DataWriter.java +++ b/gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/writer/Kafka09DataWriter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.kafka.writer; +package org.apache.gobblin.kafka.writer; import java.io.IOException; import java.util.Properties; @@ -33,11 +33,11 @@ import com.typesafe.config.ConfigFactory; import lombok.extern.slf4j.Slf4j; -import gobblin.writer.AsyncDataWriter; -import gobblin.writer.WriteCallback; -import gobblin.writer.WriteResponse; -import gobblin.writer.WriteResponseFuture; -import gobblin.writer.WriteResponseMapper; +import org.apache.gobblin.writer.AsyncDataWriter; +import org.apache.gobblin.writer.WriteCallback; +import org.apache.gobblin.writer.WriteResponse; +import org.apache.gobblin.writer.WriteResponseFuture; +import org.apache.gobblin.writer.WriteResponseMapper; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/writer/KafkaDataWriterBuilder.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/writer/KafkaDataWriterBuilder.java b/gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/writer/KafkaDataWriterBuilder.java index 3e99e4f..754f5a4 100644 --- a/gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/writer/KafkaDataWriterBuilder.java +++ b/gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/writer/KafkaDataWriterBuilder.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package gobblin.kafka.writer; +package org.apache.gobblin.kafka.writer; import java.util.Properties; import org.apache.avro.generic.GenericRecord; -import gobblin.writer.AsyncDataWriter; +import org.apache.gobblin.writer.AsyncDataWriter; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.java b/gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.java index fd553c8..2737264 100644 --- a/gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.java +++ b/gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.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.channels.ClosedChannelException; @@ -37,23 +37,23 @@ import com.google.common.base.Optional; import com.google.common.base.Preconditions; import com.google.gson.JsonElement; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.kafka.client.AbstractBaseKafkaConsumerClient; -import gobblin.metrics.Tag; -import gobblin.metrics.kafka.KafkaSchemaRegistry; -import gobblin.metrics.kafka.SchemaRegistryException; -import gobblin.source.extractor.CheckpointableWatermark; -import gobblin.source.extractor.ComparableWatermark; -import gobblin.source.extractor.DataRecordException; -import gobblin.stream.RecordEnvelope; -import gobblin.source.extractor.StreamingExtractor; -import gobblin.source.extractor.Watermark; -import gobblin.source.extractor.WatermarkSerializerHelper; -import gobblin.source.extractor.extract.EventBasedExtractor; -import gobblin.source.extractor.extract.LongWatermark; -import gobblin.util.ConfigUtils; -import gobblin.writer.WatermarkStorage; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.kafka.client.AbstractBaseKafkaConsumerClient; +import org.apache.gobblin.metrics.Tag; +import org.apache.gobblin.metrics.kafka.KafkaSchemaRegistry; +import org.apache.gobblin.metrics.kafka.SchemaRegistryException; +import org.apache.gobblin.source.extractor.CheckpointableWatermark; +import org.apache.gobblin.source.extractor.ComparableWatermark; +import org.apache.gobblin.source.extractor.DataRecordException; +import org.apache.gobblin.stream.RecordEnvelope; +import org.apache.gobblin.source.extractor.StreamingExtractor; +import org.apache.gobblin.source.extractor.Watermark; +import org.apache.gobblin.source.extractor.WatermarkSerializerHelper; +import org.apache.gobblin.source.extractor.extract.EventBasedExtractor; +import org.apache.gobblin.source.extractor.extract.LongWatermark; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.writer.WatermarkStorage; import lombok.ToString; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingSource.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingSource.java b/gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingSource.java index f8ddc15..72e0778 100644 --- a/gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingSource.java +++ b/gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingSource.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; @@ -35,16 +35,16 @@ import com.google.common.base.Throwables; import com.google.common.io.Closer; import com.typesafe.config.Config; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.SourceState; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.source.extractor.Extractor; -import gobblin.stream.RecordEnvelope; -import gobblin.source.extractor.extract.EventBasedSource; -import gobblin.source.workunit.Extract; -import gobblin.source.workunit.WorkUnit; -import gobblin.util.ConfigUtils; +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.source.extractor.Extractor; +import org.apache.gobblin.stream.RecordEnvelope; +import org.apache.gobblin.source.extractor.extract.EventBasedSource; +import org.apache.gobblin.source.workunit.Extract; +import org.apache.gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.util.ConfigUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-09/src/test/java/org/apache/gobblin/kafka/KafkaTestBase.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-09/src/test/java/org/apache/gobblin/kafka/KafkaTestBase.java b/gobblin-modules/gobblin-kafka-09/src/test/java/org/apache/gobblin/kafka/KafkaTestBase.java index 1cceeb5..f99680c 100644 --- a/gobblin-modules/gobblin-kafka-09/src/test/java/org/apache/gobblin/kafka/KafkaTestBase.java +++ b/gobblin-modules/gobblin-kafka-09/src/test/java/org/apache/gobblin/kafka/KafkaTestBase.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.kafka; +package org.apache.gobblin.kafka; import java.io.Closeable; import java.io.IOException; @@ -45,7 +45,7 @@ import kafka.utils.ZkUtils; import kafka.zk.EmbeddedZookeeper; import lombok.extern.slf4j.Slf4j; -import gobblin.test.TestUtils; +import org.apache.gobblin.test.TestUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-09/src/test/java/org/apache/gobblin/kafka/client/Kafka09ConsumerClientTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-09/src/test/java/org/apache/gobblin/kafka/client/Kafka09ConsumerClientTest.java b/gobblin-modules/gobblin-kafka-09/src/test/java/org/apache/gobblin/kafka/client/Kafka09ConsumerClientTest.java index b44c3a0..296ade2 100644 --- a/gobblin-modules/gobblin-kafka-09/src/test/java/org/apache/gobblin/kafka/client/Kafka09ConsumerClientTest.java +++ b/gobblin-modules/gobblin-kafka-09/src/test/java/org/apache/gobblin/kafka/client/Kafka09ConsumerClientTest.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.kafka.client; +package org.apache.gobblin.kafka.client; import java.util.Arrays; import java.util.HashMap; @@ -33,9 +33,9 @@ import com.google.common.collect.Sets; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.configuration.ConfigurationKeys; -import gobblin.source.extractor.extract.kafka.KafkaPartition; -import gobblin.kafka.client.Kafka09ConsumerClient.Kafka09ConsumerRecord; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.source.extractor.extract.kafka.KafkaPartition; +import org.apache.gobblin.kafka.client.Kafka09ConsumerClient.Kafka09ConsumerRecord; public class Kafka09ConsumerClientTest { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-09/src/test/java/org/apache/gobblin/kafka/source/extractor/extract/kafka/KafkaSimpleStreamingTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-09/src/test/java/org/apache/gobblin/kafka/source/extractor/extract/kafka/KafkaSimpleStreamingTest.java b/gobblin-modules/gobblin-kafka-09/src/test/java/org/apache/gobblin/kafka/source/extractor/extract/kafka/KafkaSimpleStreamingTest.java index 3f2b511..db66a85 100644 --- a/gobblin-modules/gobblin-kafka-09/src/test/java/org/apache/gobblin/kafka/source/extractor/extract/kafka/KafkaSimpleStreamingTest.java +++ b/gobblin-modules/gobblin-kafka-09/src/test/java/org/apache/gobblin/kafka/source/extractor/extract/kafka/KafkaSimpleStreamingTest.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.kafka.source.extractor.extract.kafka; +package org.apache.gobblin.kafka.source.extractor.extract.kafka; import java.io.IOException; import java.lang.management.ManagementFactory; @@ -36,19 +36,19 @@ import org.testng.annotations.Test; import lombok.extern.slf4j.Slf4j; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.SourceState; -import gobblin.configuration.State; -import gobblin.configuration.WorkUnitState; -import gobblin.kafka.KafkaTestBase; -import gobblin.source.extractor.CheckpointableWatermark; -import gobblin.source.extractor.DataRecordException; -import gobblin.stream.RecordEnvelope; -import gobblin.source.extractor.extract.LongWatermark; -import gobblin.source.extractor.extract.kafka.KafkaSimpleStreamingExtractor; -import gobblin.source.extractor.extract.kafka.KafkaSimpleStreamingSource; -import gobblin.source.workunit.WorkUnit; -import gobblin.writer.WatermarkStorage; +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.KafkaTestBase; +import org.apache.gobblin.source.extractor.CheckpointableWatermark; +import org.apache.gobblin.source.extractor.DataRecordException; +import org.apache.gobblin.stream.RecordEnvelope; +import org.apache.gobblin.source.extractor.extract.LongWatermark; +import org.apache.gobblin.source.extractor.extract.kafka.KafkaSimpleStreamingExtractor; +import org.apache.gobblin.source.extractor.extract.kafka.KafkaSimpleStreamingSource; +import org.apache.gobblin.source.workunit.WorkUnit; +import org.apache.gobblin.writer.WatermarkStorage; import static org.mockito.Matchers.any; import static org.mockito.Mockito.mock; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-09/src/test/java/org/apache/gobblin/kafka/writer/Kafka09DataWriterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-09/src/test/java/org/apache/gobblin/kafka/writer/Kafka09DataWriterTest.java b/gobblin-modules/gobblin-kafka-09/src/test/java/org/apache/gobblin/kafka/writer/Kafka09DataWriterTest.java index 3186b67..45b865d 100644 --- a/gobblin-modules/gobblin-kafka-09/src/test/java/org/apache/gobblin/kafka/writer/Kafka09DataWriterTest.java +++ b/gobblin-modules/gobblin-kafka-09/src/test/java/org/apache/gobblin/kafka/writer/Kafka09DataWriterTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.kafka.writer; +package org.apache.gobblin.kafka.writer; import java.io.IOException; import java.lang.management.ManagementFactory; @@ -33,16 +33,16 @@ import org.testng.annotations.Test; import kafka.security.auth.Write; import lombok.extern.slf4j.Slf4j; -import gobblin.kafka.KafkaTestBase; -import gobblin.kafka.schemareg.ConfigDrivenMd5SchemaRegistry; -import gobblin.kafka.schemareg.KafkaSchemaRegistryConfigurationKeys; -import gobblin.kafka.schemareg.SchemaRegistryException; -//import gobblin.kafka.serialize.LiAvroDeserializer; -import gobblin.kafka.serialize.LiAvroDeserializer; -import gobblin.kafka.serialize.LiAvroSerializer; -import gobblin.test.TestUtils; -import gobblin.writer.WriteCallback; -import gobblin.writer.WriteResponse; +import org.apache.gobblin.kafka.KafkaTestBase; +import org.apache.gobblin.kafka.schemareg.ConfigDrivenMd5SchemaRegistry; +import org.apache.gobblin.kafka.schemareg.KafkaSchemaRegistryConfigurationKeys; +import org.apache.gobblin.kafka.schemareg.SchemaRegistryException; +//import org.apache.gobblin.kafka.serialize.LiAvroDeserializer; +import org.apache.gobblin.kafka.serialize.LiAvroDeserializer; +import org.apache.gobblin.kafka.serialize.LiAvroSerializer; +import org.apache.gobblin.test.TestUtils; +import org.apache.gobblin.writer.WriteCallback; +import org.apache.gobblin.writer.WriteResponse; import static org.mockito.Matchers.isA; import static org.mockito.Mockito.mock; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/converter/EnvelopeSchemaConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/converter/EnvelopeSchemaConverter.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/converter/EnvelopeSchemaConverter.java index 2055256..8c1bf7f 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/converter/EnvelopeSchemaConverter.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/converter/EnvelopeSchemaConverter.java @@ -15,20 +15,20 @@ * limitations under the License. */ -package gobblin.converter; +package org.apache.gobblin.converter; import com.google.common.base.Optional; import com.google.common.cache.CacheBuilder; import com.google.common.cache.CacheLoader; import com.google.common.cache.LoadingCache; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.WorkUnitState; -import gobblin.converter.filter.AvroProjectionConverter; -import gobblin.converter.filter.AvroSchemaFieldRemover; -import gobblin.metrics.kafka.KafkaSchemaRegistry; -import gobblin.metrics.kafka.KafkaSchemaRegistryFactory; -import gobblin.metrics.kafka.SchemaRegistryException; -import gobblin.util.AvroUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.converter.filter.AvroProjectionConverter; +import org.apache.gobblin.converter.filter.AvroSchemaFieldRemover; +import org.apache.gobblin.metrics.kafka.KafkaSchemaRegistry; +import org.apache.gobblin.metrics.kafka.KafkaSchemaRegistryFactory; +import org.apache.gobblin.metrics.kafka.SchemaRegistryException; +import org.apache.gobblin.util.AvroUtils; import java.io.IOException; import java.nio.ByteBuffer; import java.nio.charset.StandardCharsets; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/converter/LiKafkaByteArrayMsgToAvroConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/converter/LiKafkaByteArrayMsgToAvroConverter.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/converter/LiKafkaByteArrayMsgToAvroConverter.java index 8ec174a..61eedd3 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/converter/LiKafkaByteArrayMsgToAvroConverter.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/converter/LiKafkaByteArrayMsgToAvroConverter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.converter; +package org.apache.gobblin.converter; import java.io.IOException; @@ -24,14 +24,14 @@ import org.apache.avro.generic.GenericRecord; import com.google.common.base.Preconditions; -import gobblin.configuration.WorkUnitState; -import gobblin.kafka.schemareg.KafkaSchemaRegistry; -import gobblin.kafka.schemareg.KafkaSchemaRegistryFactory; -import gobblin.kafka.schemareg.SchemaRegistryException; -import gobblin.kafka.serialize.LiAvroDeserializerBase; -import gobblin.kafka.serialize.SerializationException; -import gobblin.source.extractor.extract.kafka.KafkaSource; -import gobblin.util.EmptyIterable; +import org.apache.gobblin.configuration.WorkUnitState; +import org.apache.gobblin.kafka.schemareg.KafkaSchemaRegistry; +import org.apache.gobblin.kafka.schemareg.KafkaSchemaRegistryFactory; +import org.apache.gobblin.kafka.schemareg.SchemaRegistryException; +import org.apache.gobblin.kafka.serialize.LiAvroDeserializerBase; +import org.apache.gobblin.kafka.serialize.SerializationException; +import org.apache.gobblin.source.extractor.extract.kafka.KafkaSource; +import org.apache.gobblin.util.EmptyIterable; import lombok.extern.slf4j.Slf4j; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/client/AbstractBaseKafkaConsumerClient.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/client/AbstractBaseKafkaConsumerClient.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/client/AbstractBaseKafkaConsumerClient.java index 49ee820..00b751b 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/client/AbstractBaseKafkaConsumerClient.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/client/AbstractBaseKafkaConsumerClient.java @@ -14,22 +14,22 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.kafka.client; +package org.apache.gobblin.kafka.client; import com.google.common.base.Function; import com.google.common.base.Predicate; import com.google.common.collect.FluentIterable; import com.google.common.collect.Iterables; import com.google.common.collect.Lists; -import gobblin.source.extractor.extract.kafka.KafkaTopic; -import gobblin.util.DatasetFilterUtils; +import org.apache.gobblin.source.extractor.extract.kafka.KafkaTopic; +import org.apache.gobblin.util.DatasetFilterUtils; import java.util.List; import com.google.common.base.Preconditions; import com.typesafe.config.Config; -import gobblin.configuration.ConfigurationKeys; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.util.ConfigUtils; import java.util.Map; import java.util.regex.Pattern; import javax.annotation.Nonnull; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/client/BaseKafkaConsumerRecord.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/client/BaseKafkaConsumerRecord.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/client/BaseKafkaConsumerRecord.java index 90bd788..017a166 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/client/BaseKafkaConsumerRecord.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/client/BaseKafkaConsumerRecord.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.kafka.client; +package org.apache.gobblin.kafka.client; import lombok.AllArgsConstructor; import lombok.EqualsAndHashCode; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/client/ByteArrayBasedKafkaRecord.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/client/ByteArrayBasedKafkaRecord.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/client/ByteArrayBasedKafkaRecord.java index 2dce0ef..548b610 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/client/ByteArrayBasedKafkaRecord.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/client/ByteArrayBasedKafkaRecord.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.kafka.client; +package org.apache.gobblin.kafka.client; /** * A kafka record that provides getters for raw bytes of key and value . This record type can be used to wrap kafka http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/client/DecodeableKafkaRecord.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/client/DecodeableKafkaRecord.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/client/DecodeableKafkaRecord.java index 30b8c1d..e974127 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/client/DecodeableKafkaRecord.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/client/DecodeableKafkaRecord.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.kafka.client; +package org.apache.gobblin.kafka.client; /** * A kafka record that provides getters for deserialized key and value. This record type can be used to wrap kafka records http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/client/GobblinKafkaConsumerClient.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/client/GobblinKafkaConsumerClient.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/client/GobblinKafkaConsumerClient.java index 9e23707..a23e557 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/client/GobblinKafkaConsumerClient.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/client/GobblinKafkaConsumerClient.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.kafka.client; +package org.apache.gobblin.kafka.client; import java.io.Closeable; import java.util.Iterator; @@ -23,10 +23,10 @@ import java.util.regex.Pattern; import com.typesafe.config.Config; -import gobblin.source.extractor.extract.kafka.KafkaOffsetRetrievalFailureException; -import gobblin.source.extractor.extract.kafka.KafkaPartition; -import gobblin.source.extractor.extract.kafka.KafkaTopic; -import gobblin.util.DatasetFilterUtils; +import org.apache.gobblin.source.extractor.extract.kafka.KafkaOffsetRetrievalFailureException; +import org.apache.gobblin.source.extractor.extract.kafka.KafkaPartition; +import org.apache.gobblin.source.extractor.extract.kafka.KafkaTopic; +import org.apache.gobblin.util.DatasetFilterUtils; /** * A simplified, generic wrapper client to communicate with Kafka. This class is (AND MUST never) depend on classes http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/client/KafkaConsumerRecord.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/client/KafkaConsumerRecord.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/client/KafkaConsumerRecord.java index 9f70ec5..5308a18 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/client/KafkaConsumerRecord.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/client/KafkaConsumerRecord.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.kafka.client; +package org.apache.gobblin.kafka.client; /** * A kafka message/record consumed from {@link GobblinKafkaConsumerClient}. This interface provides APIs to read message http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/CachingKafkaSchemaRegistry.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/CachingKafkaSchemaRegistry.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/CachingKafkaSchemaRegistry.java index 868e8ef..4ef3e64 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/CachingKafkaSchemaRegistry.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/CachingKafkaSchemaRegistry.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.kafka.schemareg; +package org.apache.gobblin.kafka.schemareg; import java.io.IOException; import java.util.HashMap; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/ConfigDrivenMd5SchemaRegistry.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/ConfigDrivenMd5SchemaRegistry.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/ConfigDrivenMd5SchemaRegistry.java index b80e845..8dcdde1 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/ConfigDrivenMd5SchemaRegistry.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/ConfigDrivenMd5SchemaRegistry.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.kafka.schemareg; +package org.apache.gobblin.kafka.schemareg; import java.io.IOException; import java.io.UnsupportedEncodingException; @@ -29,9 +29,9 @@ import org.apache.avro.Schema; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.kafka.schemareg.KafkaSchemaRegistry; -import gobblin.kafka.schemareg.SchemaRegistryException; -import gobblin.kafka.serialize.MD5Digest; +import org.apache.gobblin.kafka.schemareg.KafkaSchemaRegistry; +import org.apache.gobblin.kafka.schemareg.SchemaRegistryException; +import org.apache.gobblin.kafka.serialize.MD5Digest; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/HttpClientFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/HttpClientFactory.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/HttpClientFactory.java index 3c9a237..8c7b3a0 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/HttpClientFactory.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/HttpClientFactory.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.kafka.schemareg; +package org.apache.gobblin.kafka.schemareg; import org.apache.commons.httpclient.HttpClient; import org.apache.commons.pool2.BasePooledObjectFactory; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/KafkaSchemaRegistry.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/KafkaSchemaRegistry.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/KafkaSchemaRegistry.java index a3eb46b..9820097 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/KafkaSchemaRegistry.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/KafkaSchemaRegistry.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/main/java/org/apache/gobblin/kafka/schemareg/KafkaSchemaRegistryConfigurationKeys.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/KafkaSchemaRegistryConfigurationKeys.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/KafkaSchemaRegistryConfigurationKeys.java index 0d6db98..d6f023b 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/KafkaSchemaRegistryConfigurationKeys.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/KafkaSchemaRegistryConfigurationKeys.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.kafka.schemareg; +package org.apache.gobblin.kafka.schemareg; /** * Configuration keys for a kafka schema registry http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/KafkaSchemaRegistryFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/KafkaSchemaRegistryFactory.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/KafkaSchemaRegistryFactory.java index c43d4f8..13ae5c8 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/KafkaSchemaRegistryFactory.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/KafkaSchemaRegistryFactory.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.kafka.schemareg; +package org.apache.gobblin.kafka.schemareg; import java.lang.reflect.InvocationTargetException; import java.util.Properties; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/LiKafkaSchemaRegistry.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/LiKafkaSchemaRegistry.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/LiKafkaSchemaRegistry.java index 0c8a010..2ea7075 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/LiKafkaSchemaRegistry.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/LiKafkaSchemaRegistry.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.kafka.schemareg; +package org.apache.gobblin.kafka.schemareg; import java.io.IOException; import java.util.Properties; @@ -34,9 +34,9 @@ import org.slf4j.LoggerFactory; import com.google.common.base.Preconditions; -import gobblin.configuration.ConfigurationKeys; -import gobblin.kafka.serialize.MD5Digest; -import gobblin.util.AvroUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.kafka.serialize.MD5Digest; +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/kafka/schemareg/SchemaRegistryException.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/SchemaRegistryException.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/SchemaRegistryException.java index 87e3bbd..bc2b248 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/SchemaRegistryException.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/SchemaRegistryException.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.kafka.schemareg; +package org.apache.gobblin.kafka.schemareg; public class SchemaRegistryException extends Exception { public SchemaRegistryException(String message) { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroDeserializerBase.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroDeserializerBase.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroDeserializerBase.java index 0037321..5d841ed 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroDeserializerBase.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroDeserializerBase.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.kafka.serialize; +package org.apache.gobblin.kafka.serialize; import java.io.IOException; import java.util.Map; @@ -32,9 +32,9 @@ import com.google.common.base.Preconditions; import lombok.extern.slf4j.Slf4j; -import gobblin.kafka.schemareg.KafkaSchemaRegistry; -import gobblin.kafka.schemareg.KafkaSchemaRegistryFactory; -import gobblin.kafka.schemareg.SchemaRegistryException; +import org.apache.gobblin.kafka.schemareg.KafkaSchemaRegistry; +import org.apache.gobblin.kafka.schemareg.KafkaSchemaRegistryFactory; +import org.apache.gobblin.kafka.schemareg.SchemaRegistryException; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroSerDeHelper.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroSerDeHelper.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroSerDeHelper.java index 9b1827b..18cdd56 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroSerDeHelper.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroSerDeHelper.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package gobblin.kafka.serialize; +package org.apache.gobblin.kafka.serialize; import java.util.Map; import java.util.Properties; -import gobblin.kafka.schemareg.KafkaSchemaRegistry; -import gobblin.kafka.schemareg.KafkaSchemaRegistryFactory; +import org.apache.gobblin.kafka.schemareg.KafkaSchemaRegistry; +import org.apache.gobblin.kafka.schemareg.KafkaSchemaRegistryFactory; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroSerializerBase.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroSerializerBase.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroSerializerBase.java index b4daf23..361158c 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroSerializerBase.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroSerializerBase.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.kafka.serialize; +package org.apache.gobblin.kafka.serialize; import java.io.ByteArrayOutputStream; import java.io.IOException; @@ -28,8 +28,8 @@ import org.apache.avro.io.BinaryEncoder; import org.apache.avro.io.DatumWriter; import org.apache.avro.io.EncoderFactory; -import gobblin.kafka.schemareg.KafkaSchemaRegistry; -import gobblin.kafka.schemareg.SchemaRegistryException; +import org.apache.gobblin.kafka.schemareg.KafkaSchemaRegistry; +import org.apache.gobblin.kafka.schemareg.SchemaRegistryException; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/serialize/MD5Digest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/serialize/MD5Digest.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/serialize/MD5Digest.java index a275517..0f5a28e 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/serialize/MD5Digest.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/serialize/MD5Digest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.kafka.serialize; +package org.apache.gobblin.kafka.serialize; import java.util.Arrays; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/serialize/SerializationException.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/serialize/SerializationException.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/serialize/SerializationException.java index b1b051b..9727f6a 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/serialize/SerializationException.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/serialize/SerializationException.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.kafka.serialize; +package org.apache.gobblin.kafka.serialize; public class SerializationException extends Exception { public SerializationException(String message) { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/writer/BaseKafkaDataWriterBuilder.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/writer/BaseKafkaDataWriterBuilder.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/writer/BaseKafkaDataWriterBuilder.java index 7d7084c..8e5e9b0 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/writer/BaseKafkaDataWriterBuilder.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/writer/BaseKafkaDataWriterBuilder.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.kafka.writer; +package org.apache.gobblin.kafka.writer; import java.io.IOException; import java.util.Properties; @@ -25,12 +25,12 @@ import org.apache.avro.generic.GenericRecord; import com.typesafe.config.Config; -import gobblin.configuration.State; -import gobblin.util.ConfigUtils; -import gobblin.writer.AsyncWriterManager; -import gobblin.writer.AsyncDataWriter; -import gobblin.writer.DataWriter; -import gobblin.writer.DataWriterBuilder; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.writer.AsyncWriterManager; +import org.apache.gobblin.writer.AsyncDataWriter; +import org.apache.gobblin.writer.DataWriter; +import org.apache.gobblin.writer.DataWriterBuilder; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/writer/KafkaWriterConfigurationKeys.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/writer/KafkaWriterConfigurationKeys.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/writer/KafkaWriterConfigurationKeys.java index 000c1f0..0303341 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/writer/KafkaWriterConfigurationKeys.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/writer/KafkaWriterConfigurationKeys.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.kafka.writer; +package org.apache.gobblin.kafka.writer; /** * Configuration keys for a KafkaWriter. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/writer/KafkaWriterHelper.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/writer/KafkaWriterHelper.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/writer/KafkaWriterHelper.java index 4600c64..b717d43 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/writer/KafkaWriterHelper.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/writer/KafkaWriterHelper.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.kafka.writer; +package org.apache.gobblin.kafka.writer; import java.lang.reflect.InvocationTargetException; import java.util.Properties; @@ -28,10 +28,10 @@ import com.typesafe.config.ConfigFactory; import lombok.extern.slf4j.Slf4j; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.util.ConfigUtils; -import static gobblin.kafka.writer.KafkaWriterConfigurationKeys.*; -import static gobblin.kafka.writer.KafkaWriterConfigurationKeys.CLIENT_ID_DEFAULT; +import static org.apache.gobblin.kafka.writer.KafkaWriterConfigurationKeys.*; +import static org.apache.gobblin.kafka.writer.KafkaWriterConfigurationKeys.CLIENT_ID_DEFAULT; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/writer/KafkaWriterMetricNames.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/writer/KafkaWriterMetricNames.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/writer/KafkaWriterMetricNames.java index 4960fc2..067b96f 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/writer/KafkaWriterMetricNames.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/writer/KafkaWriterMetricNames.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.kafka.writer; +package org.apache.gobblin.kafka.writer; /** * Listing of Metrics names used by the {@link KafkaDataWriter} http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroSchemaRegistry.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroSchemaRegistry.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroSchemaRegistry.java index dd56f95..d391ef3 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroSchemaRegistry.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroSchemaRegistry.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.kafka; +package org.apache.gobblin.metrics.kafka; import java.io.IOException; import java.util.Properties; @@ -35,9 +35,9 @@ import org.slf4j.LoggerFactory; import com.google.common.base.Preconditions; -import gobblin.configuration.ConfigurationKeys; -import gobblin.kafka.schemareg.HttpClientFactory; -import gobblin.util.AvroUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.kafka.schemareg.HttpClientFactory; +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/metrics/kafka/KafkaAvroSchemaRegistryFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroSchemaRegistryFactory.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroSchemaRegistryFactory.java index 018fda1..04d9ffc 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroSchemaRegistryFactory.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroSchemaRegistryFactory.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.kafka; +package org.apache.gobblin.metrics.kafka; import java.util.Properties; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/kafka/KafkaSchemaRegistry.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/kafka/KafkaSchemaRegistry.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/kafka/KafkaSchemaRegistry.java index 0f042c3..ac5efc2 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/kafka/KafkaSchemaRegistry.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/kafka/KafkaSchemaRegistry.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.kafka; +package org.apache.gobblin.metrics.kafka; import java.lang.reflect.InvocationTargetException; import java.util.Properties; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/kafka/KafkaSchemaRegistryFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/kafka/KafkaSchemaRegistryFactory.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/kafka/KafkaSchemaRegistryFactory.java index 4751746..d4e5071 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/kafka/KafkaSchemaRegistryFactory.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/kafka/KafkaSchemaRegistryFactory.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.kafka; +package org.apache.gobblin.metrics.kafka; import java.util.Properties; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/kafka/SchemaRegistryException.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/kafka/SchemaRegistryException.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/kafka/SchemaRegistryException.java index 4add903..6cd5346 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/kafka/SchemaRegistryException.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/kafka/SchemaRegistryException.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.kafka; +package org.apache.gobblin.metrics.kafka; public class SchemaRegistryException 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/metrics/reporter/util/SchemaRegistryVersionWriter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/reporter/util/SchemaRegistryVersionWriter.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/reporter/util/SchemaRegistryVersionWriter.java index bd4802c..62439dc 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/reporter/util/SchemaRegistryVersionWriter.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/reporter/util/SchemaRegistryVersionWriter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.metrics.reporter.util; +package org.apache.gobblin.metrics.reporter.util; import java.io.DataInputStream; import java.io.DataOutputStream; @@ -31,9 +31,9 @@ import com.google.common.base.Throwables; import com.google.common.collect.Maps; import com.typesafe.config.Config; -import gobblin.metrics.kafka.KafkaAvroSchemaRegistry; -import gobblin.metrics.kafka.SchemaRegistryException; -import gobblin.util.ConfigUtils; +import org.apache.gobblin.metrics.kafka.KafkaAvroSchemaRegistry; +import org.apache.gobblin.metrics.kafka.SchemaRegistryException; +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/ConfigStoreUtils.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/ConfigStoreUtils.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/ConfigStoreUtils.java index 3160943..4eea468 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/ConfigStoreUtils.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/ConfigStoreUtils.java @@ -14,22 +14,22 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package gobblin.source.extractor.extract.kafka; +package org.apache.gobblin.source.extractor.extract.kafka; import com.google.common.base.Optional; import com.google.common.base.Preconditions; import com.typesafe.config.Config; -import gobblin.config.client.ConfigClient; -import gobblin.config.client.ConfigClientUtils; -import gobblin.config.client.api.ConfigStoreFactoryDoesNotExistsException; -import gobblin.config.client.api.VersionStabilityPolicy; -import gobblin.config.store.api.ConfigStoreCreationException; -import gobblin.configuration.ConfigurationKeys; -import gobblin.configuration.State; -import gobblin.kafka.client.GobblinKafkaConsumerClient; -import gobblin.util.ConfigUtils; -import gobblin.util.DatasetFilterUtils; -import gobblin.util.PathUtils; +import org.apache.gobblin.config.client.ConfigClient; +import org.apache.gobblin.config.client.ConfigClientUtils; +import org.apache.gobblin.config.client.api.ConfigStoreFactoryDoesNotExistsException; +import org.apache.gobblin.config.client.api.VersionStabilityPolicy; +import org.apache.gobblin.config.store.api.ConfigStoreCreationException; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.configuration.State; +import org.apache.gobblin.kafka.client.GobblinKafkaConsumerClient; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.util.DatasetFilterUtils; +import org.apache.gobblin.util.PathUtils; import java.net.URI; import java.net.URISyntaxException; import java.util.ArrayList;
