You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gobblin.apache.org by ab...@apache.org on 2017/07/31 07:52:51 UTC
[33/77] [abbrv] incubator-gobblin git commit: Updated package names,
imports and shell scripts
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;