gobblin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a...@apache.org
Subject [14/77] [abbrv] incubator-gobblin git commit: Updated package names, imports and shell scripts
Date Mon, 31 Jul 2017 07:52:32 GMT
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;
 
 /**
  *


Mime
View raw message