gobblin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a...@apache.org
Subject [33/77] [abbrv] incubator-gobblin git commit: Updated package names, imports and shell scripts
Date Mon, 31 Jul 2017 07:52:51 GMT
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/verify/DataCompletenessVerifier.java
----------------------------------------------------------------------
diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/verify/DataCompletenessVerifier.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/verify/DataCompletenessVerifier.java
index 0c878b9..370a59c 100644
--- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/verify/DataCompletenessVerifier.java
+++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/verify/DataCompletenessVerifier.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.compaction.verify;
+package org.apache.gobblin.compaction.verify;
 
 import java.io.Closeable;
 import java.io.IOException;
@@ -34,11 +34,11 @@ import com.google.common.collect.ImmutableMap;
 import com.google.common.util.concurrent.ListenableFuture;
 import com.google.common.util.concurrent.ListeningExecutorService;
 
-import gobblin.compaction.dataset.Dataset;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.util.ExecutorsUtils;
-import gobblin.util.executors.ScalingThreadPoolExecutor;
+import org.apache.gobblin.compaction.dataset.Dataset;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.util.ExecutorsUtils;
+import org.apache.gobblin.util.executors.ScalingThreadPoolExecutor;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/verify/InputRecordCountHelper.java
----------------------------------------------------------------------
diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/verify/InputRecordCountHelper.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/verify/InputRecordCountHelper.java
index 9e7a210..53fd05d 100644
--- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/verify/InputRecordCountHelper.java
+++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/verify/InputRecordCountHelper.java
@@ -1,14 +1,14 @@
-package gobblin.compaction.verify;
+package org.apache.gobblin.compaction.verify;
 
 import com.google.common.base.Charsets;
 import com.google.common.collect.Lists;
-import gobblin.compaction.dataset.DatasetHelper;
-import gobblin.compaction.mapreduce.MRCompactor;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.util.HadoopUtils;
-import gobblin.util.RecordCountProvider;
-import gobblin.util.recordcount.IngestionRecordCountProvider;
+import org.apache.gobblin.compaction.dataset.DatasetHelper;
+import org.apache.gobblin.compaction.mapreduce.MRCompactor;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.util.HadoopUtils;
+import org.apache.gobblin.util.RecordCountProvider;
+import org.apache.gobblin.util.recordcount.IngestionRecordCountProvider;
 import lombok.Getter;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.hadoop.conf.Configuration;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/MRCompactionTaskTest.java
----------------------------------------------------------------------
diff --git a/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/MRCompactionTaskTest.java b/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/MRCompactionTaskTest.java
index 27e03e3..3fed3e5 100644
--- a/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/MRCompactionTaskTest.java
+++ b/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/MRCompactionTaskTest.java
@@ -15,22 +15,22 @@
  * limitations under the License.
  */
 
-package gobblin.compaction.mapreduce;
+package org.apache.gobblin.compaction.mapreduce;
 
 import com.google.common.io.Files;
-import gobblin.compaction.audit.AuditCountClientFactory;
-import gobblin.compaction.dataset.TimeBasedSubDirDatasetsFinder;
-import gobblin.compaction.source.CompactionSource;
-import gobblin.data.management.dataset.SimpleDatasetHierarchicalPrioritizer;
-import gobblin.compaction.suite.TestCompactionSuiteFactories;
-import gobblin.compaction.verify.CompactionAuditCountVerifier;
-import gobblin.compaction.verify.CompactionVerifier;
-import gobblin.compaction.verify.InputRecordCountHelper;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.data.management.copy.CopyConfiguration;
-import gobblin.data.management.retention.profile.ConfigurableGlobDatasetFinder;
-import gobblin.runtime.api.JobExecutionResult;
-import gobblin.runtime.embedded.EmbeddedGobblin;
+import org.apache.gobblin.compaction.audit.AuditCountClientFactory;
+import org.apache.gobblin.compaction.dataset.TimeBasedSubDirDatasetsFinder;
+import org.apache.gobblin.compaction.source.CompactionSource;
+import org.apache.gobblin.data.management.dataset.SimpleDatasetHierarchicalPrioritizer;
+import org.apache.gobblin.compaction.suite.TestCompactionSuiteFactories;
+import org.apache.gobblin.compaction.verify.CompactionAuditCountVerifier;
+import org.apache.gobblin.compaction.verify.CompactionVerifier;
+import org.apache.gobblin.compaction.verify.InputRecordCountHelper;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.data.management.copy.CopyConfiguration;
+import org.apache.gobblin.data.management.retention.profile.ConfigurableGlobDatasetFinder;
+import org.apache.gobblin.runtime.api.JobExecutionResult;
+import org.apache.gobblin.runtime.embedded.EmbeddedGobblin;
 
 import org.apache.avro.Schema;
 import org.apache.avro.file.DataFileWriter;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/MRCompactorJobRunnerFilenameRecordCountProviderTest.java
----------------------------------------------------------------------
diff --git a/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/MRCompactorJobRunnerFilenameRecordCountProviderTest.java b/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/MRCompactorJobRunnerFilenameRecordCountProviderTest.java
index f78d683..c4020fe 100644
--- a/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/MRCompactorJobRunnerFilenameRecordCountProviderTest.java
+++ b/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/MRCompactorJobRunnerFilenameRecordCountProviderTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.compaction.mapreduce;
+package org.apache.gobblin.compaction.mapreduce;
 
 import java.io.IOException;
 import java.util.regex.Pattern;
@@ -28,9 +28,9 @@ import org.testng.annotations.Test;
 
 import com.google.common.io.Files;
 
-import gobblin.util.RecordCountProvider;
-import gobblin.util.recordcount.IngestionRecordCountProvider;
-import gobblin.util.recordcount.LateFileRecordCountProvider;
+import org.apache.gobblin.util.RecordCountProvider;
+import org.apache.gobblin.util.recordcount.IngestionRecordCountProvider;
+import org.apache.gobblin.util.recordcount.LateFileRecordCountProvider;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/RenameSourceDirectoryTest.java
----------------------------------------------------------------------
diff --git a/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/RenameSourceDirectoryTest.java b/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/RenameSourceDirectoryTest.java
index 342fd73..e5207aa 100644
--- a/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/RenameSourceDirectoryTest.java
+++ b/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/RenameSourceDirectoryTest.java
@@ -1,5 +1,5 @@
-package gobblin.compaction.mapreduce;
-import gobblin.compaction.dataset.Dataset;
+package org.apache.gobblin.compaction.mapreduce;
+import org.apache.gobblin.compaction.dataset.Dataset;
 
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.FileSystem;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/avro/AvroKeyDedupReducerTest.java
----------------------------------------------------------------------
diff --git a/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/avro/AvroKeyDedupReducerTest.java b/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/avro/AvroKeyDedupReducerTest.java
index dbdcac8..2de03d1 100644
--- a/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/avro/AvroKeyDedupReducerTest.java
+++ b/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/avro/AvroKeyDedupReducerTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.compaction.mapreduce.avro;
+package org.apache.gobblin.compaction.mapreduce.avro;
 
 import java.io.IOException;
 import java.util.List;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/avro/ConfBasedDeltaFieldProviderTest.java
----------------------------------------------------------------------
diff --git a/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/avro/ConfBasedDeltaFieldProviderTest.java b/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/avro/ConfBasedDeltaFieldProviderTest.java
index e7d8c6d..150eee0 100644
--- a/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/avro/ConfBasedDeltaFieldProviderTest.java
+++ b/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/avro/ConfBasedDeltaFieldProviderTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.compaction.mapreduce.avro;
+package org.apache.gobblin.compaction.mapreduce.avro;
 
 import java.util.List;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/avro/FieldAttributeBasedDeltaFieldsProviderTest.java
----------------------------------------------------------------------
diff --git a/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/avro/FieldAttributeBasedDeltaFieldsProviderTest.java b/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/avro/FieldAttributeBasedDeltaFieldsProviderTest.java
index 9a26828..8557a8c 100644
--- a/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/avro/FieldAttributeBasedDeltaFieldsProviderTest.java
+++ b/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/avro/FieldAttributeBasedDeltaFieldsProviderTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.compaction.mapreduce.avro;
+package org.apache.gobblin.compaction.mapreduce.avro;
 
 import java.util.List;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/avro/MRCompactorAvroKeyDedupJobRunnerTest.java
----------------------------------------------------------------------
diff --git a/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/avro/MRCompactorAvroKeyDedupJobRunnerTest.java b/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/avro/MRCompactorAvroKeyDedupJobRunnerTest.java
index a280dab..a6b8b41 100644
--- a/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/avro/MRCompactorAvroKeyDedupJobRunnerTest.java
+++ b/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/avro/MRCompactorAvroKeyDedupJobRunnerTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.compaction.mapreduce.avro;
+package org.apache.gobblin.compaction.mapreduce.avro;
 
 import java.io.IOException;
 import java.io.InputStream;
@@ -29,11 +29,11 @@ import org.testng.Assert;
 import org.testng.annotations.BeforeClass;
 import org.testng.annotations.Test;
 
-import gobblin.compaction.dataset.Dataset;
-import gobblin.compaction.mapreduce.MRCompactor;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.util.AvroUtils;
+import org.apache.gobblin.compaction.dataset.Dataset;
+import org.apache.gobblin.compaction.mapreduce.MRCompactor;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.util.AvroUtils;
 
 
 @Test(groups = { "gobblin.compaction" })

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/conditions/RecompactionConditionTest.java
----------------------------------------------------------------------
diff --git a/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/conditions/RecompactionConditionTest.java b/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/conditions/RecompactionConditionTest.java
index 12396c6..f57193b 100644
--- a/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/conditions/RecompactionConditionTest.java
+++ b/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/mapreduce/conditions/RecompactionConditionTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.compaction.mapreduce.conditions;
+package org.apache.gobblin.compaction.mapreduce.conditions;
 
 import java.io.IOException;
 import java.util.Arrays;
@@ -38,15 +38,15 @@ import org.testng.annotations.Test;
 
 import com.google.common.collect.Lists;
 import com.google.common.base.Optional;
-import gobblin.compaction.conditions.RecompactionCondition;
-import gobblin.compaction.conditions.RecompactionCombineCondition;
-import gobblin.compaction.conditions.RecompactionConditionBasedOnDuration;
-import gobblin.compaction.conditions.RecompactionConditionBasedOnFileCount;
-import gobblin.compaction.conditions.RecompactionConditionBasedOnRatio;
-import gobblin.compaction.conditions.RecompactionConditionFactory;
-import gobblin.compaction.dataset.Dataset;
-import gobblin.compaction.dataset.DatasetHelper;
-import gobblin.compaction.mapreduce.MRCompactor;
+import org.apache.gobblin.compaction.conditions.RecompactionCondition;
+import org.apache.gobblin.compaction.conditions.RecompactionCombineCondition;
+import org.apache.gobblin.compaction.conditions.RecompactionConditionBasedOnDuration;
+import org.apache.gobblin.compaction.conditions.RecompactionConditionBasedOnFileCount;
+import org.apache.gobblin.compaction.conditions.RecompactionConditionBasedOnRatio;
+import org.apache.gobblin.compaction.conditions.RecompactionConditionFactory;
+import org.apache.gobblin.compaction.dataset.Dataset;
+import org.apache.gobblin.compaction.dataset.DatasetHelper;
+import org.apache.gobblin.compaction.mapreduce.MRCompactor;
 
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.when;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/suite/TestCompactionSuiteFactories.java
----------------------------------------------------------------------
diff --git a/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/suite/TestCompactionSuiteFactories.java b/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/suite/TestCompactionSuiteFactories.java
index 3cfcf86..6354d5d 100644
--- a/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/suite/TestCompactionSuiteFactories.java
+++ b/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/suite/TestCompactionSuiteFactories.java
@@ -1,7 +1,7 @@
-package gobblin.compaction.suite;
+package org.apache.gobblin.compaction.suite;
 
-import gobblin.annotation.Alias;
-import gobblin.configuration.State;
+import org.apache.gobblin.annotation.Alias;
+import org.apache.gobblin.configuration.State;
 
 
 public class TestCompactionSuiteFactories {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/suite/TestCompactionSuites.java
----------------------------------------------------------------------
diff --git a/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/suite/TestCompactionSuites.java b/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/suite/TestCompactionSuites.java
index 973f9c0..87d41d2 100644
--- a/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/suite/TestCompactionSuites.java
+++ b/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/suite/TestCompactionSuites.java
@@ -15,16 +15,16 @@
  * limitations under the License.
  */
 
-package gobblin.compaction.suite;
+package org.apache.gobblin.compaction.suite;
 
 import java.util.ArrayList;
 import java.util.List;
 
 import lombok.extern.slf4j.Slf4j;
 
-import gobblin.compaction.action.CompactionCompleteAction;
-import gobblin.configuration.State;
-import gobblin.dataset.FileSystemDataset;
+import org.apache.gobblin.compaction.action.CompactionCompleteAction;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.dataset.FileSystemDataset;
 
 @Slf4j
 public class TestCompactionSuites {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/verify/PinotAuditCountVerifierTest.java
----------------------------------------------------------------------
diff --git a/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/verify/PinotAuditCountVerifierTest.java b/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/verify/PinotAuditCountVerifierTest.java
index 3a545d0..4160100 100644
--- a/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/verify/PinotAuditCountVerifierTest.java
+++ b/gobblin-compaction/src/test/java/org/apache/gobblin/compaction/verify/PinotAuditCountVerifierTest.java
@@ -1,12 +1,12 @@
-package gobblin.compaction.verify;
+package org.apache.gobblin.compaction.verify;
 
 import com.google.common.collect.ImmutableMap;
 import com.google.common.collect.Maps;
-import gobblin.compaction.audit.AuditCountClient;
-import gobblin.compaction.dataset.TimeBasedSubDirDatasetsFinder;
-import gobblin.compaction.mapreduce.MRCompactor;
-import gobblin.configuration.State;
-import gobblin.dataset.FileSystemDataset;
+import org.apache.gobblin.compaction.audit.AuditCountClient;
+import org.apache.gobblin.compaction.dataset.TimeBasedSubDirDatasetsFinder;
+import org.apache.gobblin.compaction.mapreduce.MRCompactor;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.dataset.FileSystemDataset;
 import lombok.Getter;
 import lombok.Setter;
 import org.apache.hadoop.fs.Path;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-compaction/src/test/resources/dedup-schema/dedup-schema-with-pkey.avsc
----------------------------------------------------------------------
diff --git a/gobblin-compaction/src/test/resources/dedup-schema/dedup-schema-with-pkey.avsc b/gobblin-compaction/src/test/resources/dedup-schema/dedup-schema-with-pkey.avsc
index 36544cb..a3fc5fd 100644
--- a/gobblin-compaction/src/test/resources/dedup-schema/dedup-schema-with-pkey.avsc
+++ b/gobblin-compaction/src/test/resources/dedup-schema/dedup-schema-with-pkey.avsc
@@ -1,7 +1,7 @@
 {
   "type" : "record",
   "name" : "GobblinCompactionTestEvent",
-  "namespace" : "gobblin.compaction.test.events",
+  "namespace" : "org.apache.gobblin.compaction.test.events",
   "fields" : [ {
     "name" : "header",
     "type" : {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-compaction/src/test/resources/dedup-schema/dedup-schema-without-pkey.avsc
----------------------------------------------------------------------
diff --git a/gobblin-compaction/src/test/resources/dedup-schema/dedup-schema-without-pkey.avsc b/gobblin-compaction/src/test/resources/dedup-schema/dedup-schema-without-pkey.avsc
index 39357c6..506e10c 100644
--- a/gobblin-compaction/src/test/resources/dedup-schema/dedup-schema-without-pkey.avsc
+++ b/gobblin-compaction/src/test/resources/dedup-schema/dedup-schema-without-pkey.avsc
@@ -1,7 +1,7 @@
 {
   "type" : "record",
   "name" : "GobblinCompactionTestEvent",
-  "namespace" : "gobblin.compaction.test.events",
+  "namespace" : "org.apache.gobblin.compaction.test.events",
   "fields" : [ {
     "name" : "header",
     "type" : {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-client/src/main/java/org/apache/gobblin/config/client/ConfigClient.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-client/src/main/java/org/apache/gobblin/config/client/ConfigClient.java b/gobblin-config-management/gobblin-config-client/src/main/java/org/apache/gobblin/config/client/ConfigClient.java
index cee2d12..c125129 100644
--- a/gobblin-config-management/gobblin-config-client/src/main/java/org/apache/gobblin/config/client/ConfigClient.java
+++ b/gobblin-config-management/gobblin-config-client/src/main/java/org/apache/gobblin/config/client/ConfigClient.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.config.client;
+package org.apache.gobblin.config.client;
 
 import java.lang.annotation.Annotation;
 import java.net.URI;
@@ -35,20 +35,20 @@ import com.google.common.collect.ArrayListMultimap;
 import com.google.common.collect.Multimap;
 import com.typesafe.config.Config;
 
-import gobblin.config.client.api.ConfigStoreFactoryDoesNotExistsException;
-import gobblin.config.client.api.VersionStabilityPolicy;
-import gobblin.config.common.impl.ConfigStoreBackedTopology;
-import gobblin.config.common.impl.ConfigStoreBackedValueInspector;
-import gobblin.config.common.impl.ConfigStoreTopologyInspector;
-import gobblin.config.common.impl.ConfigStoreValueInspector;
-import gobblin.config.common.impl.InMemoryTopology;
-import gobblin.config.common.impl.InMemoryValueInspector;
-import gobblin.config.store.api.ConfigKeyPath;
-import gobblin.config.store.api.ConfigStore;
-import gobblin.config.store.api.ConfigStoreCreationException;
-import gobblin.config.store.api.ConfigStoreFactory;
-import gobblin.config.store.api.ConfigStoreWithStableVersioning;
-import gobblin.config.store.api.VersionDoesNotExistException;
+import org.apache.gobblin.config.client.api.ConfigStoreFactoryDoesNotExistsException;
+import org.apache.gobblin.config.client.api.VersionStabilityPolicy;
+import org.apache.gobblin.config.common.impl.ConfigStoreBackedTopology;
+import org.apache.gobblin.config.common.impl.ConfigStoreBackedValueInspector;
+import org.apache.gobblin.config.common.impl.ConfigStoreTopologyInspector;
+import org.apache.gobblin.config.common.impl.ConfigStoreValueInspector;
+import org.apache.gobblin.config.common.impl.InMemoryTopology;
+import org.apache.gobblin.config.common.impl.InMemoryValueInspector;
+import org.apache.gobblin.config.store.api.ConfigKeyPath;
+import org.apache.gobblin.config.store.api.ConfigStore;
+import org.apache.gobblin.config.store.api.ConfigStoreCreationException;
+import org.apache.gobblin.config.store.api.ConfigStoreFactory;
+import org.apache.gobblin.config.store.api.ConfigStoreWithStableVersioning;
+import org.apache.gobblin.config.store.api.VersionDoesNotExistException;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-client/src/main/java/org/apache/gobblin/config/client/ConfigClientCLI.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-client/src/main/java/org/apache/gobblin/config/client/ConfigClientCLI.java b/gobblin-config-management/gobblin-config-client/src/main/java/org/apache/gobblin/config/client/ConfigClientCLI.java
index 9011618..1e28518 100644
--- a/gobblin-config-management/gobblin-config-client/src/main/java/org/apache/gobblin/config/client/ConfigClientCLI.java
+++ b/gobblin-config-management/gobblin-config-client/src/main/java/org/apache/gobblin/config/client/ConfigClientCLI.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.config.client;
+package org.apache.gobblin.config.client;
 
 import java.net.URI;
 import java.net.URISyntaxException;
@@ -23,12 +23,12 @@ import java.net.URISyntaxException;
 import com.typesafe.config.Config;
 import com.typesafe.config.ConfigRenderOptions;
 
-import gobblin.annotation.Alias;
-import gobblin.config.client.api.VersionStabilityPolicy;
-import gobblin.runtime.cli.CliApplication;
-import gobblin.runtime.cli.CliObjectFactory;
-import gobblin.runtime.cli.CliObjectSupport;
-import gobblin.runtime.cli.ConstructorAndPublicMethodsCliObjectFactory;
+import org.apache.gobblin.annotation.Alias;
+import org.apache.gobblin.config.client.api.VersionStabilityPolicy;
+import org.apache.gobblin.runtime.cli.CliApplication;
+import org.apache.gobblin.runtime.cli.CliObjectFactory;
+import org.apache.gobblin.runtime.cli.CliObjectSupport;
+import org.apache.gobblin.runtime.cli.ConstructorAndPublicMethodsCliObjectFactory;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-client/src/main/java/org/apache/gobblin/config/client/ConfigClientCache.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-client/src/main/java/org/apache/gobblin/config/client/ConfigClientCache.java b/gobblin-config-management/gobblin-config-client/src/main/java/org/apache/gobblin/config/client/ConfigClientCache.java
index 693120d..f6e32a2 100644
--- a/gobblin-config-management/gobblin-config-client/src/main/java/org/apache/gobblin/config/client/ConfigClientCache.java
+++ b/gobblin-config-management/gobblin-config-client/src/main/java/org/apache/gobblin/config/client/ConfigClientCache.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.config.client;
+package org.apache.gobblin.config.client;
 
 import java.util.concurrent.Callable;
 import java.util.concurrent.ExecutionException;
@@ -22,7 +22,7 @@ import java.util.concurrent.ExecutionException;
 import com.google.common.cache.Cache;
 import com.google.common.cache.CacheBuilder;
 
-import gobblin.config.client.api.VersionStabilityPolicy;
+import org.apache.gobblin.config.client.api.VersionStabilityPolicy;
 
 /**
  * Caches {@link ConfigClient}s for every {@link VersionStabilityPolicy}.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-client/src/main/java/org/apache/gobblin/config/client/ConfigClientUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-client/src/main/java/org/apache/gobblin/config/client/ConfigClientUtils.java b/gobblin-config-management/gobblin-config-client/src/main/java/org/apache/gobblin/config/client/ConfigClientUtils.java
index f9a6702..4eb3231 100644
--- a/gobblin-config-management/gobblin-config-client/src/main/java/org/apache/gobblin/config/client/ConfigClientUtils.java
+++ b/gobblin-config-management/gobblin-config-client/src/main/java/org/apache/gobblin/config/client/ConfigClientUtils.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.config.client;
+package org.apache.gobblin.config.client;
 
 import java.net.URI;
 import java.net.URISyntaxException;
@@ -31,11 +31,11 @@ import com.google.common.base.Optional;
 import com.google.common.base.Preconditions;
 import com.typesafe.config.Config;
 
-import gobblin.config.common.impl.SingleLinkedListConfigKeyPath;
-import gobblin.config.store.api.ConfigKeyPath;
-import gobblin.config.store.api.ConfigStore;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.util.ConfigUtils;
+import org.apache.gobblin.config.common.impl.SingleLinkedListConfigKeyPath;
+import org.apache.gobblin.config.store.api.ConfigKeyPath;
+import org.apache.gobblin.config.store.api.ConfigStore;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.util.ConfigUtils;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-client/src/main/java/org/apache/gobblin/config/client/ConfigStoreFactoryRegister.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-client/src/main/java/org/apache/gobblin/config/client/ConfigStoreFactoryRegister.java b/gobblin-config-management/gobblin-config-client/src/main/java/org/apache/gobblin/config/client/ConfigStoreFactoryRegister.java
index 3e1614c..dc3fe3b 100644
--- a/gobblin-config-management/gobblin-config-client/src/main/java/org/apache/gobblin/config/client/ConfigStoreFactoryRegister.java
+++ b/gobblin-config-management/gobblin-config-client/src/main/java/org/apache/gobblin/config/client/ConfigStoreFactoryRegister.java
@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package gobblin.config.client;
+package org.apache.gobblin.config.client;
 
-import gobblin.config.store.api.ConfigStoreFactory;
+import org.apache.gobblin.config.store.api.ConfigStoreFactory;
 
 import java.util.HashMap;
 import java.util.Map;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-client/src/main/java/org/apache/gobblin/config/client/package-info.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-client/src/main/java/org/apache/gobblin/config/client/package-info.java b/gobblin-config-management/gobblin-config-client/src/main/java/org/apache/gobblin/config/client/package-info.java
index 5b5b6dd..6fab764 100644
--- a/gobblin-config-management/gobblin-config-client/src/main/java/org/apache/gobblin/config/client/package-info.java
+++ b/gobblin-config-management/gobblin-config-client/src/main/java/org/apache/gobblin/config/client/package-info.java
@@ -18,7 +18,7 @@
 /**
  * This package contains the config config client implementation for Gobblin config management.
  */
-package gobblin.config.client;
+package org.apache.gobblin.config.client;
 
 //TODO: Remove once we commit any other classes
 class DummyClassForJavadoc {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-client/src/test/java/org/apache/gobblin/config/client/TestConfigClient.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-client/src/test/java/org/apache/gobblin/config/client/TestConfigClient.java b/gobblin-config-management/gobblin-config-client/src/test/java/org/apache/gobblin/config/client/TestConfigClient.java
index c0ab283..f4371b2 100644
--- a/gobblin-config-management/gobblin-config-client/src/test/java/org/apache/gobblin/config/client/TestConfigClient.java
+++ b/gobblin-config-management/gobblin-config-client/src/test/java/org/apache/gobblin/config/client/TestConfigClient.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.config.client;
+package org.apache.gobblin.config.client;
 
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.when;
@@ -38,11 +38,11 @@ import com.typesafe.config.Config;
 import com.typesafe.config.ConfigFactory;
 import com.typesafe.config.ConfigValue;
 
-import gobblin.config.client.api.VersionStabilityPolicy;
-import gobblin.config.common.impl.SingleLinkedListConfigKeyPath;
-import gobblin.config.store.api.ConfigKeyPath;
-import gobblin.config.store.api.ConfigStore;
-import gobblin.config.store.api.ConfigStoreFactory;
+import org.apache.gobblin.config.client.api.VersionStabilityPolicy;
+import org.apache.gobblin.config.common.impl.SingleLinkedListConfigKeyPath;
+import org.apache.gobblin.config.store.api.ConfigKeyPath;
+import org.apache.gobblin.config.store.api.ConfigStore;
+import org.apache.gobblin.config.store.api.ConfigStoreFactory;
 
 @Test(groups = { "gobblin.config.common.impl" })
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-client/src/test/java/org/apache/gobblin/config/client/TestConfigClientUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-client/src/test/java/org/apache/gobblin/config/client/TestConfigClientUtils.java b/gobblin-config-management/gobblin-config-client/src/test/java/org/apache/gobblin/config/client/TestConfigClientUtils.java
index 79e49c8..6448d3e 100644
--- a/gobblin-config-management/gobblin-config-client/src/test/java/org/apache/gobblin/config/client/TestConfigClientUtils.java
+++ b/gobblin-config-management/gobblin-config-client/src/test/java/org/apache/gobblin/config/client/TestConfigClientUtils.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.config.client;
+package org.apache.gobblin.config.client;
 
 import java.net.URI;
 import java.net.URISyntaxException;
@@ -29,9 +29,9 @@ import org.testng.Assert;
 import org.testng.annotations.BeforeClass;
 import org.testng.annotations.Test;
 
-import gobblin.config.common.impl.SingleLinkedListConfigKeyPath;
-import gobblin.config.store.api.ConfigKeyPath;
-import gobblin.config.store.api.ConfigStore;
+import org.apache.gobblin.config.common.impl.SingleLinkedListConfigKeyPath;
+import org.apache.gobblin.config.store.api.ConfigKeyPath;
+import org.apache.gobblin.config.store.api.ConfigStore;
 
 @Test(groups = { "gobblin.config.client.api" })
 public class TestConfigClientUtils {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/client/api/ConfigStoreFactoryDoesNotExistsException.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/client/api/ConfigStoreFactoryDoesNotExistsException.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/client/api/ConfigStoreFactoryDoesNotExistsException.java
index 8265951..31de050 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/client/api/ConfigStoreFactoryDoesNotExistsException.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/client/api/ConfigStoreFactoryDoesNotExistsException.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.config.client.api;
+package org.apache.gobblin.config.client.api;
 
 /**
  * ConfigStoreFactoryDoesNotExistsException indicate the requested {@link ConfigStoreFactory} can not

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/client/api/VersionStabilityPolicy.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/client/api/VersionStabilityPolicy.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/client/api/VersionStabilityPolicy.java
index 485aca6..f8eb8ad 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/client/api/VersionStabilityPolicy.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/client/api/VersionStabilityPolicy.java
@@ -14,10 +14,10 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.config.client.api;
+package org.apache.gobblin.config.client.api;
 
-import gobblin.annotation.Alpha;
-import gobblin.config.store.api.ConfigStoreWithStableVersioning;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.config.store.api.ConfigStoreWithStableVersioning;
 
 /**
  * This policy specifies the behavior expected by the client application when making repeated

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/CircularDependencyException.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/CircularDependencyException.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/CircularDependencyException.java
index 284a462..aa3cdca 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/CircularDependencyException.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/CircularDependencyException.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.config.common.impl;
+package org.apache.gobblin.config.common.impl;
 
 /** Denotes that circular chain is detected by follow the imports path in {@link ConfigStore}. */
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/ConfigStoreBackedTopology.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/ConfigStoreBackedTopology.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/ConfigStoreBackedTopology.java
index 7300112..b19fa94 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/ConfigStoreBackedTopology.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/ConfigStoreBackedTopology.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.config.common.impl;
+package org.apache.gobblin.config.common.impl;
 
 import java.util.Collection;
 import java.util.List;
@@ -23,11 +23,11 @@ import java.util.List;
 import com.google.common.base.Optional;
 import com.typesafe.config.Config;
 
-import gobblin.config.store.api.ConfigKeyPath;
-import gobblin.config.store.api.ConfigStore;
-import gobblin.config.store.api.ConfigStoreWithImportedBy;
-import gobblin.config.store.api.ConfigStoreWithImportedByRecursively;
-import gobblin.config.store.api.ConfigStoreWithResolution;
+import org.apache.gobblin.config.store.api.ConfigKeyPath;
+import org.apache.gobblin.config.store.api.ConfigStore;
+import org.apache.gobblin.config.store.api.ConfigStoreWithImportedBy;
+import org.apache.gobblin.config.store.api.ConfigStoreWithImportedByRecursively;
+import org.apache.gobblin.config.store.api.ConfigStoreWithResolution;
 
 public class ConfigStoreBackedTopology implements ConfigStoreTopologyInspector {
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/ConfigStoreBackedValueInspector.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/ConfigStoreBackedValueInspector.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/ConfigStoreBackedValueInspector.java
index 84cf761..c7e40bd 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/ConfigStoreBackedValueInspector.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/ConfigStoreBackedValueInspector.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.config.common.impl;
+package org.apache.gobblin.config.common.impl;
 
 import java.util.Collection;
 import java.util.HashMap;
@@ -30,10 +30,10 @@ import com.typesafe.config.ConfigFactory;
 
 import edu.umd.cs.findbugs.annotations.SuppressWarnings;
 
-import gobblin.config.store.api.ConfigKeyPath;
-import gobblin.config.store.api.ConfigStore;
-import gobblin.config.store.api.ConfigStoreWithBatchFetches;
-import gobblin.config.store.api.ConfigStoreWithResolution;
+import org.apache.gobblin.config.store.api.ConfigKeyPath;
+import org.apache.gobblin.config.store.api.ConfigStore;
+import org.apache.gobblin.config.store.api.ConfigStoreWithBatchFetches;
+import org.apache.gobblin.config.store.api.ConfigStoreWithResolution;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/ConfigStoreTopologyInspector.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/ConfigStoreTopologyInspector.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/ConfigStoreTopologyInspector.java
index 8a7d64e..f1afa4a 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/ConfigStoreTopologyInspector.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/ConfigStoreTopologyInspector.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.config.common.impl;
+package org.apache.gobblin.config.common.impl;
 
 import java.util.Collection;
 import java.util.List;
@@ -23,7 +23,7 @@ import java.util.List;
 import com.google.common.base.Optional;
 import com.typesafe.config.Config;
 
-import gobblin.config.store.api.ConfigKeyPath;
+import org.apache.gobblin.config.store.api.ConfigKeyPath;
 
 /**
  * The ConfigStoreTopology interface used to describe the topology of a configuration store.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/ConfigStoreValueInspector.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/ConfigStoreValueInspector.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/ConfigStoreValueInspector.java
index e0e1412..43239cd 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/ConfigStoreValueInspector.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/ConfigStoreValueInspector.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.config.common.impl;
+package org.apache.gobblin.config.common.impl;
 
 import java.util.Collection;
 import java.util.Map;
@@ -23,7 +23,7 @@ import java.util.Map;
 import com.google.common.base.Optional;
 import com.typesafe.config.Config;
 
-import gobblin.config.store.api.ConfigKeyPath;
+import org.apache.gobblin.config.store.api.ConfigKeyPath;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/ImportTraverser.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/ImportTraverser.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/ImportTraverser.java
index ccf2aac..5014486 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/ImportTraverser.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/ImportTraverser.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.config.common.impl;
+package org.apache.gobblin.config.common.impl;
 
 import java.util.HashSet;
 import java.util.LinkedList;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/InMemoryTopology.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/InMemoryTopology.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/InMemoryTopology.java
index 2c3cdfb..b0a2f19 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/InMemoryTopology.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/InMemoryTopology.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.config.common.impl;
+package org.apache.gobblin.config.common.impl;
 
 import java.util.ArrayList;
 import java.util.Collection;
@@ -32,7 +32,7 @@ import com.google.common.collect.Lists;
 import com.google.common.util.concurrent.UncheckedExecutionException;
 import com.typesafe.config.Config;
 
-import gobblin.config.store.api.ConfigKeyPath;
+import org.apache.gobblin.config.store.api.ConfigKeyPath;
 
 import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/InMemoryValueInspector.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/InMemoryValueInspector.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/InMemoryValueInspector.java
index e856b3a..5e4a430 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/InMemoryValueInspector.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/InMemoryValueInspector.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.config.common.impl;
+package org.apache.gobblin.config.common.impl;
 
 import java.util.ArrayList;
 import java.util.Collection;
@@ -29,8 +29,8 @@ import com.google.common.cache.Cache;
 import com.google.common.cache.CacheBuilder;
 import com.typesafe.config.Config;
 
-import gobblin.config.store.api.ConfigKeyPath;
-import gobblin.config.store.api.ConfigStore;
+import org.apache.gobblin.config.store.api.ConfigKeyPath;
+import org.apache.gobblin.config.store.api.ConfigStore;
 
 /**
  * InMemoryValueInspector provide the caching layer for getting the {@link com.typesafe.config.Config} from {@link ConfigStore}

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/SingleLinkedListConfigKeyPath.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/SingleLinkedListConfigKeyPath.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/SingleLinkedListConfigKeyPath.java
index a682592..21275d5 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/SingleLinkedListConfigKeyPath.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/SingleLinkedListConfigKeyPath.java
@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package gobblin.config.common.impl;
+package org.apache.gobblin.config.common.impl;
 
-import gobblin.config.store.api.ConfigKeyPath;
+import org.apache.gobblin.config.store.api.ConfigKeyPath;
 
 
 public class SingleLinkedListConfigKeyPath implements ConfigKeyPath {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigKeyPath.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigKeyPath.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigKeyPath.java
index 6579452..4cf62f1 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigKeyPath.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigKeyPath.java
@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package gobblin.config.store.api;
+package org.apache.gobblin.config.store.api;
 
-import gobblin.annotation.Alpha;
+import org.apache.gobblin.annotation.Alpha;
 
 /**
  * The ConfigKeyPath is used to describe the relative path for a given configuration key URI to

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStore.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStore.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStore.java
index 859b2f4..24127fc 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStore.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStore.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.config.store.api;
+package org.apache.gobblin.config.store.api;
 
 import java.net.URI;
 import java.util.Collection;
@@ -24,7 +24,7 @@ import java.util.List;
 import com.google.common.base.Optional;
 import com.typesafe.config.Config;
 
-import gobblin.annotation.Alpha;
+import org.apache.gobblin.annotation.Alpha;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStoreCreationException.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStoreCreationException.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStoreCreationException.java
index 77a18c5..a22d812 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStoreCreationException.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStoreCreationException.java
@@ -15,11 +15,11 @@
  * limitations under the License.
  */
 
-package gobblin.config.store.api;
+package org.apache.gobblin.config.store.api;
 
 import java.net.URI;
 
-import gobblin.annotation.Alpha;
+import org.apache.gobblin.annotation.Alpha;
 
 @Alpha
 public class ConfigStoreCreationException extends Exception {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStoreFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStoreFactory.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStoreFactory.java
index 3704d7b..f5ee9c5 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStoreFactory.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStoreFactory.java
@@ -15,11 +15,11 @@
  * limitations under the License.
  */
 
-package gobblin.config.store.api;
+package org.apache.gobblin.config.store.api;
 
 import java.net.URI;
 
-import gobblin.annotation.Alpha;
+import org.apache.gobblin.annotation.Alpha;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStoreWithBatchFetches.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStoreWithBatchFetches.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStoreWithBatchFetches.java
index 4867c0d..b1a394f 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStoreWithBatchFetches.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStoreWithBatchFetches.java
@@ -15,14 +15,14 @@
  * limitations under the License.
  */
 
-package gobblin.config.store.api;
+package org.apache.gobblin.config.store.api;
 
 import java.util.Collection;
 import java.util.Map;
 
 import com.typesafe.config.Config;
 
-import gobblin.annotation.Alpha;
+import org.apache.gobblin.annotation.Alpha;
 
 /**
  * ConfigStoreWithBatchFetches indicate this {@link ConfigStore} support (efficient) fetching of

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStoreWithImportedBy.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStoreWithImportedBy.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStoreWithImportedBy.java
index ba4dafc..8876cdb 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStoreWithImportedBy.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStoreWithImportedBy.java
@@ -15,14 +15,14 @@
  * limitations under the License.
  */
 
-package gobblin.config.store.api;
+package org.apache.gobblin.config.store.api;
 
 import java.util.Collection;
 
 import com.google.common.base.Optional;
 import com.typesafe.config.Config;
 
-import gobblin.annotation.Alpha;
+import org.apache.gobblin.annotation.Alpha;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStoreWithImportedByRecursively.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStoreWithImportedByRecursively.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStoreWithImportedByRecursively.java
index e325b9f..32ce137 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStoreWithImportedByRecursively.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStoreWithImportedByRecursively.java
@@ -15,14 +15,14 @@
  * limitations under the License.
  */
 
-package gobblin.config.store.api;
+package org.apache.gobblin.config.store.api;
 
 import java.util.Collection;
 
 import com.google.common.base.Optional;
 import com.typesafe.config.Config;
 
-import gobblin.annotation.Alpha;
+import org.apache.gobblin.annotation.Alpha;
 
 /**
  * This is an extension of the {@link ConfigStoreWithImportedBy} interface which marks that

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStoreWithResolution.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStoreWithResolution.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStoreWithResolution.java
index 76761c3..60561e9 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStoreWithResolution.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStoreWithResolution.java
@@ -15,14 +15,14 @@
  * limitations under the License.
  */
 
-package gobblin.config.store.api;
+package org.apache.gobblin.config.store.api;
 
 import java.util.List;
 
 import com.google.common.base.Optional;
 import com.typesafe.config.Config;
 
-import gobblin.annotation.Alpha;
+import org.apache.gobblin.annotation.Alpha;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStoreWithStableVersioning.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStoreWithStableVersioning.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStoreWithStableVersioning.java
index 20545af..a6af0b5 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStoreWithStableVersioning.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/ConfigStoreWithStableVersioning.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.config.store.api;
+package org.apache.gobblin.config.store.api;
 
 import java.lang.annotation.Documented;
 import java.lang.annotation.ElementType;
@@ -23,8 +23,8 @@ import java.lang.annotation.Retention;
 import java.lang.annotation.RetentionPolicy;
 import java.lang.annotation.Target;
 
-import gobblin.annotation.Alpha;
-import gobblin.config.client.api.VersionStabilityPolicy;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.config.client.api.VersionStabilityPolicy;
 
 /**
  * The ConfigStoreWithStableVersioning annotation is used to indicate that the configuration store

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/VersionDoesNotExistException.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/VersionDoesNotExistException.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/VersionDoesNotExistException.java
index 7f106ad..7542f63 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/VersionDoesNotExistException.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/VersionDoesNotExistException.java
@@ -15,11 +15,11 @@
  * limitations under the License.
  */
 
-package gobblin.config.store.api;
+package org.apache.gobblin.config.store.api;
 
 import java.net.URI;
 
-import gobblin.annotation.Alpha;
+import org.apache.gobblin.annotation.Alpha;
 
 
 @Alpha

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/package-info.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/package-info.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/package-info.java
index 53142c5..8be4068 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/package-info.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/package-info.java
@@ -21,4 +21,4 @@
  * Configuration stores provide a low-level API for reading {@link com.typesafe.config.Config} objects. These
  * are generally accessed through the config client API.
  */
-package gobblin.config.store.api;
+package org.apache.gobblin.config.store.api;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/deploy/ClasspathConfigSource.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/deploy/ClasspathConfigSource.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/deploy/ClasspathConfigSource.java
index b5409f6..7dbfb14 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/deploy/ClasspathConfigSource.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/deploy/ClasspathConfigSource.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.config.store.deploy;
+package org.apache.gobblin.config.store.deploy;
 
 import java.io.IOException;
 import java.io.InputStream;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/deploy/ConfigStream.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/deploy/ConfigStream.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/deploy/ConfigStream.java
index b8caf5b..6e6e6fd 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/deploy/ConfigStream.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/deploy/ConfigStream.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.config.store.deploy;
+package org.apache.gobblin.config.store.deploy;
 
 import java.io.InputStream;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/deploy/Deployable.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/deploy/Deployable.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/deploy/Deployable.java
index 94a704f..2fdcd08 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/deploy/Deployable.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/deploy/Deployable.java
@@ -14,11 +14,11 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.config.store.deploy;
+package org.apache.gobblin.config.store.deploy;
 
 import java.io.IOException;
 
-import gobblin.config.store.api.ConfigStore;
+import org.apache.gobblin.config.store.api.ConfigStore;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/deploy/DeployableConfigSource.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/deploy/DeployableConfigSource.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/deploy/DeployableConfigSource.java
index fe65015..26678cf 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/deploy/DeployableConfigSource.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/deploy/DeployableConfigSource.java
@@ -14,13 +14,13 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.config.store.deploy;
+package org.apache.gobblin.config.store.deploy;
 
 import java.io.IOException;
 import java.io.InputStream;
 import java.util.Set;
 
-import gobblin.config.store.api.ConfigStore;
+import org.apache.gobblin.config.store.api.ConfigStore;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/deploy/DeploymentConfig.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/deploy/DeploymentConfig.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/deploy/DeploymentConfig.java
index c2c432b..823d8dc 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/deploy/DeploymentConfig.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/deploy/DeploymentConfig.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.config.store.deploy;
+package org.apache.gobblin.config.store.deploy;
 
 import lombok.AllArgsConstructor;
 import lombok.Getter;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/deploy/FsDeploymentConfig.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/deploy/FsDeploymentConfig.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/deploy/FsDeploymentConfig.java
index d2db2b1..4f75311 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/deploy/FsDeploymentConfig.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/deploy/FsDeploymentConfig.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.config.store.deploy;
+package org.apache.gobblin.config.store.deploy;
 
 import lombok.Getter;
 import lombok.NonNull;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/deploy/StoreDeployer.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/deploy/StoreDeployer.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/deploy/StoreDeployer.java
index b7b67fe..6a293fd 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/deploy/StoreDeployer.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/deploy/StoreDeployer.java
@@ -14,10 +14,10 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.config.store.deploy;
+package org.apache.gobblin.config.store.deploy;
 
-import gobblin.config.store.api.ConfigStore;
-import gobblin.config.store.api.ConfigStoreFactory;
+import org.apache.gobblin.config.store.api.ConfigStore;
+import org.apache.gobblin.config.store.api.ConfigStoreFactory;
 
 import java.net.URI;
 import java.util.ServiceLoader;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/DefaultCapableLocalConfigStoreFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/DefaultCapableLocalConfigStoreFactory.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/DefaultCapableLocalConfigStoreFactory.java
index b1c5c26..dd53837 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/DefaultCapableLocalConfigStoreFactory.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/DefaultCapableLocalConfigStoreFactory.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.config.store.hdfs;
+package org.apache.gobblin.config.store.hdfs;
 
 import java.net.URI;
 import java.net.URISyntaxException;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/SimpleHDFSConfigStoreFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/SimpleHDFSConfigStoreFactory.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/SimpleHDFSConfigStoreFactory.java
index 6ff459e..b20d1e2 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/SimpleHDFSConfigStoreFactory.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/SimpleHDFSConfigStoreFactory.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.config.store.hdfs;
+package org.apache.gobblin.config.store.hdfs;
 
 import java.io.IOException;
 import java.net.URI;
@@ -31,9 +31,9 @@ import com.google.common.base.Strings;
 import com.typesafe.config.Config;
 import com.typesafe.config.ConfigFactory;
 
-import gobblin.config.store.api.ConfigStoreCreationException;
-import gobblin.config.store.api.ConfigStoreFactory;
-import gobblin.util.ConfigUtils;
+import org.apache.gobblin.config.store.api.ConfigStoreCreationException;
+import org.apache.gobblin.config.store.api.ConfigStoreFactory;
+import org.apache.gobblin.util.ConfigUtils;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/SimpleHDFSStoreMetadata.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/SimpleHDFSStoreMetadata.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/SimpleHDFSStoreMetadata.java
index 735d432..98d79d2 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/SimpleHDFSStoreMetadata.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/SimpleHDFSStoreMetadata.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.config.store.hdfs;
+package org.apache.gobblin.config.store.hdfs;
 
 import java.io.IOException;
 import java.io.InputStream;
@@ -30,9 +30,9 @@ import com.typesafe.config.ConfigFactory;
 import com.typesafe.config.ConfigRenderOptions;
 import com.typesafe.config.ConfigValueFactory;
 
-import gobblin.config.store.api.ConfigStore;
-import gobblin.config.store.deploy.FsDeploymentConfig;
-import gobblin.util.HadoopUtils;
+import org.apache.gobblin.config.store.api.ConfigStore;
+import org.apache.gobblin.config.store.deploy.FsDeploymentConfig;
+import org.apache.gobblin.util.HadoopUtils;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/SimpleHadoopFilesystemConfigStore.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/SimpleHadoopFilesystemConfigStore.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/SimpleHadoopFilesystemConfigStore.java
index 85eef3a..da541e2 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/SimpleHadoopFilesystemConfigStore.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/SimpleHadoopFilesystemConfigStore.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.config.store.hdfs;
+package org.apache.gobblin.config.store.hdfs;
 
 import java.io.IOException;
 import java.io.InputStream;
@@ -52,19 +52,19 @@ import com.typesafe.config.ConfigFactory;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 
-import gobblin.config.common.impl.SingleLinkedListConfigKeyPath;
-import gobblin.config.store.api.ConfigKeyPath;
-import gobblin.config.store.api.ConfigStore;
-import gobblin.config.store.api.ConfigStoreWithStableVersioning;
-import gobblin.config.store.api.VersionDoesNotExistException;
-import gobblin.config.store.deploy.ConfigStream;
-import gobblin.config.store.deploy.Deployable;
-import gobblin.config.store.deploy.DeployableConfigSource;
-import gobblin.config.store.deploy.FsDeploymentConfig;
-import gobblin.util.FileListUtils;
-import gobblin.util.PathUtils;
-import gobblin.util.io.SeekableFSInputStream;
-import gobblin.util.io.StreamUtils;
+import org.apache.gobblin.config.common.impl.SingleLinkedListConfigKeyPath;
+import org.apache.gobblin.config.store.api.ConfigKeyPath;
+import org.apache.gobblin.config.store.api.ConfigStore;
+import org.apache.gobblin.config.store.api.ConfigStoreWithStableVersioning;
+import org.apache.gobblin.config.store.api.VersionDoesNotExistException;
+import org.apache.gobblin.config.store.deploy.ConfigStream;
+import org.apache.gobblin.config.store.deploy.Deployable;
+import org.apache.gobblin.config.store.deploy.DeployableConfigSource;
+import org.apache.gobblin.config.store.deploy.FsDeploymentConfig;
+import org.apache.gobblin.util.FileListUtils;
+import org.apache.gobblin.util.PathUtils;
+import org.apache.gobblin.util.io.SeekableFSInputStream;
+import org.apache.gobblin.util.io.StreamUtils;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/SimpleHadoopFilesystemConfigStoreFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/SimpleHadoopFilesystemConfigStoreFactory.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/SimpleHadoopFilesystemConfigStoreFactory.java
index 63e31bd..7e3d57a 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/SimpleHadoopFilesystemConfigStoreFactory.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/SimpleHadoopFilesystemConfigStoreFactory.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.config.store.hdfs;
+package org.apache.gobblin.config.store.hdfs;
 
 import java.io.IOException;
 import java.net.URI;
@@ -32,9 +32,9 @@ import com.google.common.base.Strings;
 import com.typesafe.config.Config;
 import com.typesafe.config.ConfigFactory;
 
-import gobblin.config.store.api.ConfigStoreCreationException;
-import gobblin.config.store.api.ConfigStoreFactory;
-import gobblin.util.ConfigUtils;
+import org.apache.gobblin.config.store.api.ConfigStoreCreationException;
+import org.apache.gobblin.config.store.api.ConfigStoreFactory;
+import org.apache.gobblin.util.ConfigUtils;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/SimpleLocalHDFSConfigStoreFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/SimpleLocalHDFSConfigStoreFactory.java b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/SimpleLocalHDFSConfigStoreFactory.java
index ceb4eda..1c7e864 100644
--- a/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/SimpleLocalHDFSConfigStoreFactory.java
+++ b/gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/SimpleLocalHDFSConfigStoreFactory.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.config.store.hdfs;
+package org.apache.gobblin.config.store.hdfs;
 
 import java.io.IOException;
 import java.net.URI;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/TestEnvironment.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/TestEnvironment.java b/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/TestEnvironment.java
index 4e31d64..4d91faf 100644
--- a/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/TestEnvironment.java
+++ b/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/TestEnvironment.java
@@ -15,13 +15,13 @@
  * limitations under the License.
  */
 
-package gobblin.config;
+package org.apache.gobblin.config;
 
 import org.testng.annotations.BeforeSuite;
 import org.testng.annotations.Test;
 
-import gobblin.config.common.impl.TestConfigStoreValueInspector;
-import gobblin.config.store.hdfs.SimpleHdfsConfigStoreTest;
+import org.apache.gobblin.config.common.impl.TestConfigStoreValueInspector;
+import org.apache.gobblin.config.store.hdfs.SimpleHdfsConfigStoreTest;
 
 
 @Test

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/common/impl/ImportTraverserTest.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/common/impl/ImportTraverserTest.java b/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/common/impl/ImportTraverserTest.java
index 1e4b75b..d5b0781 100644
--- a/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/common/impl/ImportTraverserTest.java
+++ b/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/common/impl/ImportTraverserTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.config.common.impl;
+package org.apache.gobblin.config.common.impl;
 
 import java.util.List;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/common/impl/TestCircularDependency.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/common/impl/TestCircularDependency.java b/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/common/impl/TestCircularDependency.java
index 1da6891..7122b64 100644
--- a/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/common/impl/TestCircularDependency.java
+++ b/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/common/impl/TestCircularDependency.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.config.common.impl;
+package org.apache.gobblin.config.common.impl;
 
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.when;
@@ -29,8 +29,8 @@ import org.mockito.Mockito;
 import org.testng.Assert;
 import org.testng.annotations.Test;
 
-import gobblin.config.store.api.ConfigKeyPath;
-import gobblin.config.store.api.ConfigStore;
+import org.apache.gobblin.config.store.api.ConfigKeyPath;
+import org.apache.gobblin.config.store.api.ConfigStore;
 
 
 @Test(groups = { "gobblin.config.common.impl" })

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/common/impl/TestConfigStoreValueInspector.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/common/impl/TestConfigStoreValueInspector.java b/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/common/impl/TestConfigStoreValueInspector.java
index e49b2de..79b09f1 100644
--- a/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/common/impl/TestConfigStoreValueInspector.java
+++ b/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/common/impl/TestConfigStoreValueInspector.java
@@ -15,14 +15,14 @@
  * limitations under the License.
  */
 
-package gobblin.config.common.impl;
+package org.apache.gobblin.config.common.impl;
 
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.when;
 
-import gobblin.config.TestEnvironment;
-import gobblin.config.store.api.ConfigKeyPath;
-import gobblin.config.store.api.ConfigStore;
+import org.apache.gobblin.config.TestEnvironment;
+import org.apache.gobblin.config.store.api.ConfigKeyPath;
+import org.apache.gobblin.config.store.api.ConfigStore;
 
 import org.mockito.Mockito;
 import org.testng.Assert;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/common/impl/TestInMemoryTopology.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/common/impl/TestInMemoryTopology.java b/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/common/impl/TestInMemoryTopology.java
index a21121d..4ad53f7 100644
--- a/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/common/impl/TestInMemoryTopology.java
+++ b/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/common/impl/TestInMemoryTopology.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.config.common.impl;
+package org.apache.gobblin.config.common.impl;
 
 import java.util.ArrayList;
 import java.util.Collection;
@@ -40,8 +40,8 @@ import com.typesafe.config.Config;
 import com.typesafe.config.ConfigFactory;
 import com.typesafe.config.ConfigValue;
 
-import gobblin.config.store.api.ConfigKeyPath;
-import gobblin.config.store.api.ConfigStore;
+import org.apache.gobblin.config.store.api.ConfigKeyPath;
+import org.apache.gobblin.config.store.api.ConfigStore;
 
 @Test(groups = { "gobblin.config.common.impl" })
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/common/impl/TestSingleLinkedListConfigKeyPath.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/common/impl/TestSingleLinkedListConfigKeyPath.java b/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/common/impl/TestSingleLinkedListConfigKeyPath.java
index 6891f4c..d57fe69 100644
--- a/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/common/impl/TestSingleLinkedListConfigKeyPath.java
+++ b/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/common/impl/TestSingleLinkedListConfigKeyPath.java
@@ -15,12 +15,12 @@
  * limitations under the License.
  */
 
-package gobblin.config.common.impl;
+package org.apache.gobblin.config.common.impl;
 
 import java.util.HashSet;
 import java.util.Set;
 
-import gobblin.config.store.api.ConfigKeyPath;
+import org.apache.gobblin.config.store.api.ConfigKeyPath;
 
 import org.testng.Assert;
 import org.testng.annotations.Test;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/store/hdfs/SimpleHDFSStoreMetadataTest.java
----------------------------------------------------------------------
diff --git a/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/store/hdfs/SimpleHDFSStoreMetadataTest.java b/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/store/hdfs/SimpleHDFSStoreMetadataTest.java
index 3d55774..5199046 100644
--- a/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/store/hdfs/SimpleHDFSStoreMetadataTest.java
+++ b/gobblin-config-management/gobblin-config-core/src/test/java/org/apache/gobblin/config/store/hdfs/SimpleHDFSStoreMetadataTest.java
@@ -14,9 +14,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.config.store.hdfs;
+package org.apache.gobblin.config.store.hdfs;
 
-import gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.ConfigurationKeys;
 
 import java.net.URI;
 


Mime
View raw message