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;
