gobblin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a...@apache.org
Subject [42/77] [abbrv] incubator-gobblin git commit: Change internal references to org.apache.gobblin packages
Date Mon, 31 Jul 2017 07:53:00 GMT
Change internal references to org.apache.gobblin packages


Project: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/commit/bbf2aee0
Tree: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/tree/bbf2aee0
Diff: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/diff/bbf2aee0

Branch: refs/heads/master
Commit: bbf2aee0c24d106eb6108efffcaf2458616db705
Parents: fbdcc8a
Author: Abhishek Tiwari <abhishektiwari.btech@gmail.com>
Authored: Sun Jul 30 18:41:41 2017 -0700
Committer: Abhishek Tiwari <abhishektiwari.btech@gmail.com>
Committed: Sun Jul 30 18:41:41 2017 -0700

----------------------------------------------------------------------
 .../gobblin/configuration/ConfigurationKeys.java    |  4 ++--
 .../resources/GobblinAWSClusterLauncherTest.conf    |  2 +-
 .../cluster/GobblinClusterConfigurationKeys.java    |  6 +++---
 .../gobblin/compaction/mapreduce/MRCompactor.java   |  2 +-
 .../mapreduce/avro/AvroKeyDedupReducer.java         |  2 +-
 .../mapreduce/avro/ConfBasedDeltaFieldProvider.java |  2 +-
 .../FieldAttributeBasedDeltaFieldsProvider.java     |  4 ++--
 .../qualitychecker/RowCountTaskLevelPolicyTest.java | 12 ++++++------
 .../qualitychecker/RowLevelQualityCheckerTest.java  |  4 ++--
 .../qualitychecker/TaskLevelQualityCheckerTest.java |  4 ++--
 .../copy/publisher/CopyDataPublisher.java           |  2 +-
 .../retention/ConfigurableCleanableDatasetTest.java | 16 ++++++++--------
 gobblin-docs/adaptors/Hive-Avro-To-ORC-Converter.md |  4 ++--
 gobblin-example/src/main/resources/csvToAvro.conf   |  6 +++---
 .../java/org/apache/gobblin/hive/HiveRegister.java  |  2 +-
 .../hive/metastore/HiveMetaStoreBasedRegister.java  |  2 +-
 .../src/test/resources/performance-testng.xml       |  2 +-
 .../gobblin/kafka/writer/Kafka08DataWriterTest.java |  2 +-
 .../source/extractor/extract/kafka/KafkaSource.java |  2 +-
 .../idl/gobblin.rest.jobExecutions.restspec.json    |  2 +-
 .../gobblin.rest.jobExecutions.snapshot.json        |  2 +-
 .../gobblin/rest/JobExecutionInfoResource.java      |  2 +-
 .../idl/gobblin.service.flowconfigs.restspec.json   |  2 +-
 .../idl/gobblin.service.flowstatuses.restspec.json  |  4 ++--
 .../org/apache/gobblin/service/FlowConfig.pdsc      |  2 +-
 .../org/apache/gobblin/service/Schedule.pdsc        |  2 +-
 .../gobblin.service.flowconfigs.snapshot.json       |  6 +++---
 .../gobblin.service.flowstatuses.snapshot.json      |  4 ++--
 .../apache/gobblin/service/FlowConfigsResource.java |  2 +-
 .../apache/gobblin/service/FlowStatusResource.java  |  2 +-
 .../gobblin.restli.throttling.permits.restspec.json |  2 +-
 .../gobblin.restli.throttling.permits.snapshot.json |  2 +-
 .../restli/throttling/LimiterServerResource.java    |  2 +-
 .../gobblin/restli/throttling/PoliciesResource.java |  2 +-
 .../throttling/ThrottlingGuiceServletConfig.java    |  2 +-
 .../1/ConfigBasedPolicyTest/resource2/main.conf     |  2 +-
 gobblin-runtime/build.gradle                        |  2 +-
 .../gobblin/runtime/local/LocalJobLauncherTest.java | 10 +++++-----
 .../runtime/mapreduce/MRJobLauncherTest.java        | 12 ++++++------
 .../brokerTest/SimpleHelloWorldJob.jobconf          |  2 +-
 .../service/modules/core/GobblinServiceHATest.java  |  2 +-
 .../modules/core/GobblinServiceManagerTest.java     |  2 +-
 .../gobblin/SkipWorkUnitsIntegrationTest.java       |  2 +-
 .../java/org/apache/gobblin/util/HadoopUtils.java   |  2 +-
 .../util/limiter/broker/SharedLimiterFactory.java   |  2 +-
 ligradle/findbugs/findbugsExclude.xml               |  6 +++---
 46 files changed, 82 insertions(+), 82 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-api/src/main/java/org/apache/gobblin/configuration/ConfigurationKeys.java
----------------------------------------------------------------------
diff --git a/gobblin-api/src/main/java/org/apache/gobblin/configuration/ConfigurationKeys.java b/gobblin-api/src/main/java/org/apache/gobblin/configuration/ConfigurationKeys.java
index 0d8dcf5..79e9b98 100644
--- a/gobblin-api/src/main/java/org/apache/gobblin/configuration/ConfigurationKeys.java
+++ b/gobblin-api/src/main/java/org/apache/gobblin/configuration/ConfigurationKeys.java
@@ -397,7 +397,7 @@ public class ConfigurationKeys {
   /**
    * Metadata configuration properties used internally
    */
-  public static final String DATA_PUBLISH_WRITER_METADATA_MERGER_NAME_DEFAULT = "gobblin.metadata.types.GlobalMetadataJsonMerger";
+  public static final String DATA_PUBLISH_WRITER_METADATA_MERGER_NAME_DEFAULT = "org.apache.gobblin.metadata.types.GlobalMetadataJsonMerger";
   public static final String DATA_PUBLISHER_METADATA_OUTPUT_DIR =  DATA_PUBLISHER_PREFIX + ".metadata.output.dir";
   //Metadata String in the configuration file
   public static final String DATA_PUBLISHER_METADATA_STR = DATA_PUBLISHER_PREFIX + ".metadata.string";
@@ -410,7 +410,7 @@ public class ConfigurationKeys {
   public static final String DATA_PUBLISHER_TYPE = DATA_PUBLISHER_PREFIX + ".type";
   public static final String JOB_DATA_PUBLISHER_TYPE = DATA_PUBLISHER_PREFIX + ".job.type";
   public static final String TASK_DATA_PUBLISHER_TYPE = DATA_PUBLISHER_PREFIX + ".task.type";
-  public static final String DEFAULT_DATA_PUBLISHER_TYPE = "gobblin.publisher.BaseDataPublisher";
+  public static final String DEFAULT_DATA_PUBLISHER_TYPE = "org.apache.gobblin.publisher.BaseDataPublisher";
   public static final String DATA_PUBLISHER_FILE_SYSTEM_URI = DATA_PUBLISHER_PREFIX + ".fs.uri";
   public static final String DATA_PUBLISHER_FINAL_DIR = DATA_PUBLISHER_PREFIX + ".final.dir";
   public static final String DATA_PUBLISHER_APPEND_EXTRACT_TO_FINAL_DIR = DATA_PUBLISHER_PREFIX + ".appendExtractToFinalDir";

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-aws/src/test/resources/GobblinAWSClusterLauncherTest.conf
----------------------------------------------------------------------
diff --git a/gobblin-aws/src/test/resources/GobblinAWSClusterLauncherTest.conf b/gobblin-aws/src/test/resources/GobblinAWSClusterLauncherTest.conf
index 12eabc6..4e2024d 100644
--- a/gobblin-aws/src/test/resources/GobblinAWSClusterLauncherTest.conf
+++ b/gobblin-aws/src/test/resources/GobblinAWSClusterLauncherTest.conf
@@ -67,7 +67,7 @@ gobblin.aws.nfs.parent.dir="/home/ec2-user"
 gobblin.aws.nfs.root.dir=${gobblin.aws.nfs.parent.dir}"/"${gobblin.aws.cluster.name}
 gobblin.cluster.helix.cluster.name=${gobblin.aws.cluster.name}
 gobblin.cluster.job.conf.path=${gobblin.aws.nfs.root.dir}"/job-conf"
-gobblin.cluster.job.configuration.manager="gobblin.aws.AWSJobConfigurationManager"
+gobblin.cluster.job.configuration.manager="org.apache.gobblin.aws.AWSJobConfigurationManager"
 gobblin.aws.email.notification.on.shutdown=false
 
 ## AWS Configuration

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterConfigurationKeys.java
----------------------------------------------------------------------
diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterConfigurationKeys.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterConfigurationKeys.java
index 9c3f6c8..e8dfb1d 100644
--- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterConfigurationKeys.java
+++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterConfigurationKeys.java
@@ -70,12 +70,12 @@ public class GobblinClusterConfigurationKeys {
   public static final String JOB_SPEC_REFRESH_INTERVAL = GOBBLIN_CLUSTER_PREFIX + "job.spec.refresh.interval";
   public static final String SPEC_EXECUTOR_INSTANCE_CONSUMER_CLASS_KEY = GOBBLIN_CLUSTER_PREFIX + "specConsumer.class";
   public static final String DEFAULT_SPEC_EXECUTOR_INSTANCE_CONSUMER_CLASS =
-      "gobblin.service.SimpleKafkaSpecExecutorInstanceConsumer";
+      "org.apache.gobblin.service.SimpleKafkaSpecExecutorInstanceConsumer";
   public static final String DEFAULT_STREAMING_SPEC_EXECUTOR_INSTANCE_CONSUMER_CLASS =
-      "gobblin.service.StreamingKafkaSpecExecutorInstanceConsumer";
+      "org.apache.gobblin.service.StreamingKafkaSpecExecutorInstanceConsumer";
   public static final String JOB_CATALOG_KEY = GOBBLIN_CLUSTER_PREFIX + "job.catalog";
   public static final String DEFAULT_JOB_CATALOG =
-      "gobblin.runtime.job_catalog.NonObservingFSJobCatalog";
+      "org.apache.gobblin.runtime.job_catalog.NonObservingFSJobCatalog";
 
   public static final String STOP_TIMEOUT_SECONDS = GOBBLIN_CLUSTER_PREFIX + "stopTimeoutSeconds";
   public static final long DEFAULT_STOP_TIMEOUT_SECONDS = 60;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/MRCompactor.java
----------------------------------------------------------------------
diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/MRCompactor.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/MRCompactor.java
index e52b5e5..2b57782 100644
--- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/MRCompactor.java
+++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/MRCompactor.java
@@ -131,7 +131,7 @@ public class MRCompactor implements Compactor {
 
   public static final String COMPACTION_JOB_RUNNER_CLASS = COMPACTION_PREFIX + "job.runner.class";
   public static final String DEFAULT_COMPACTION_JOB_RUNNER_CLASS =
-      "gobblin.compaction.mapreduce.avro.MRCompactorAvroKeyDedupJobRunner";
+      "org.apache.gobblin.compaction.mapreduce.avro.MRCompactorAvroKeyDedupJobRunner";
   public static final String COMPACTION_TIMEZONE = COMPACTION_PREFIX + "timezone";
   public static final String DEFAULT_COMPACTION_TIMEZONE = ConfigurationKeys.PST_TIMEZONE_NAME;
   public static final String COMPACTION_FILE_SYSTEM_URI = COMPACTION_PREFIX + "file.system.uri";

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/AvroKeyDedupReducer.java
----------------------------------------------------------------------
diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/AvroKeyDedupReducer.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/AvroKeyDedupReducer.java
index ecb0dc5..130e544 100644
--- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/AvroKeyDedupReducer.java
+++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/AvroKeyDedupReducer.java
@@ -49,7 +49,7 @@ public class AvroKeyDedupReducer extends Reducer<AvroKey<GenericRecord>, AvroVal
   }
 
   public static final String DELTA_SCHEMA_PROVIDER =
-      "gobblin.compaction." + AvroKeyDedupReducer.class.getSimpleName() + ".deltaFieldsProvider";
+      "org.apache.gobblin.compaction." + AvroKeyDedupReducer.class.getSimpleName() + ".deltaFieldsProvider";
   private AvroKey<GenericRecord> outKey;
   private Optional<AvroValueDeltaSchemaComparator> deltaComparatorOptional;
   private AvroDeltaFieldNameProvider deltaFieldNamesProvider;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/ConfBasedDeltaFieldProvider.java
----------------------------------------------------------------------
diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/ConfBasedDeltaFieldProvider.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/ConfBasedDeltaFieldProvider.java
index cef3d0e..d8a1f8b 100644
--- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/ConfBasedDeltaFieldProvider.java
+++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/ConfBasedDeltaFieldProvider.java
@@ -33,7 +33,7 @@ import com.google.common.base.Splitter;
 @Test(groups = {"gobblin.compaction"})
 public class ConfBasedDeltaFieldProvider implements AvroDeltaFieldNameProvider {
   public static final String DELTA_FIELDS_KEY =
-      "gobblin.compaction." + ConfBasedDeltaFieldProvider.class.getSimpleName() + ".deltaFields";
+      "org.apache.gobblin.compaction." + ConfBasedDeltaFieldProvider.class.getSimpleName() + ".deltaFields";
   private final List<String> deltaFields;
 
   public ConfBasedDeltaFieldProvider(Configuration conf) {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/FieldAttributeBasedDeltaFieldsProvider.java
----------------------------------------------------------------------
diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/FieldAttributeBasedDeltaFieldsProvider.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/FieldAttributeBasedDeltaFieldsProvider.java
index 2596ebf..8e508e5 100644
--- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/FieldAttributeBasedDeltaFieldsProvider.java
+++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/FieldAttributeBasedDeltaFieldsProvider.java
@@ -46,9 +46,9 @@ import lombok.extern.slf4j.Slf4j;
 @Slf4j
 public class FieldAttributeBasedDeltaFieldsProvider implements AvroDeltaFieldNameProvider {
   public static final String ATTRIBUTE_FIELD =
-      "gobblin.compaction." + FieldAttributeBasedDeltaFieldsProvider.class.getSimpleName() + ".deltaAttributeField";
+      "org.apache.gobblin.compaction." + FieldAttributeBasedDeltaFieldsProvider.class.getSimpleName() + ".deltaAttributeField";
   public static final String DELTA_PROP_NAME =
-      "gobblin.compaction." + FieldAttributeBasedDeltaFieldsProvider.class.getSimpleName() + ".deltaPropName";
+      "org.apache.gobblin.compaction." + FieldAttributeBasedDeltaFieldsProvider.class.getSimpleName() + ".deltaPropName";
   public static final String DEFAULT_DELTA_PROP_NAME = "delta";
   private final String attributeField;
   private final String deltaPropName;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowCountTaskLevelPolicyTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowCountTaskLevelPolicyTest.java b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowCountTaskLevelPolicyTest.java
index e8edba6..43736fa 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowCountTaskLevelPolicyTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowCountTaskLevelPolicyTest.java
@@ -40,7 +40,7 @@ public class RowCountTaskLevelPolicyTest {
   public void testRowCountPolicyPassed()
       throws Exception {
     State state = new State();
-    state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST, "gobblin.policies.count.RowCountPolicy");
+    state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST, "org.apache.gobblin.policies.count.RowCountPolicy");
     state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST_TYPE, "FAIL");
     state.setProp(ConfigurationKeys.EXTRACTOR_ROWS_EXPECTED, EXTRACTOR_ROWS_READ);
     state.setProp(ConfigurationKeys.WRITER_ROWS_WRITTEN, WRITER_ROWS_WRITTEN);
@@ -55,7 +55,7 @@ public class RowCountTaskLevelPolicyTest {
   public void testRowCountPolicyFailed()
       throws Exception {
     State state = new State();
-    state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST, "gobblin.policies.count.RowCountPolicy");
+    state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST, "org.apache.gobblin.policies.count.RowCountPolicy");
     state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST_TYPE, "FAIL");
     state.setProp(ConfigurationKeys.EXTRACTOR_ROWS_EXPECTED, EXTRACTOR_ROWS_READ);
     state.setProp(ConfigurationKeys.WRITER_ROWS_WRITTEN, -1);
@@ -70,7 +70,7 @@ public class RowCountTaskLevelPolicyTest {
   public void testRowCountRangePolicyPassedExact()
       throws Exception {
     State state = new State();
-    state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST, "gobblin.policies.count.RowCountRangePolicy");
+    state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST, "org.apache.gobblin.policies.count.RowCountRangePolicy");
     state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST_TYPE, "FAIL");
     state.setProp(ConfigurationKeys.EXTRACTOR_ROWS_EXPECTED, EXTRACTOR_ROWS_READ);
     state.setProp(ConfigurationKeys.WRITER_ROWS_WRITTEN, WRITER_ROWS_WRITTEN);
@@ -86,7 +86,7 @@ public class RowCountTaskLevelPolicyTest {
   public void testRowCountRangePolicyPassedRange()
       throws Exception {
     State state = new State();
-    state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST, "gobblin.policies.count.RowCountRangePolicy");
+    state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST, "org.apache.gobblin.policies.count.RowCountRangePolicy");
     state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST_TYPE, "FAIL");
     state.setProp(ConfigurationKeys.EXTRACTOR_ROWS_EXPECTED, EXTRACTOR_ROWS_READ);
     state.setProp(ConfigurationKeys.WRITER_ROWS_WRITTEN, (long) 0.03 * EXTRACTOR_ROWS_READ + EXTRACTOR_ROWS_READ);
@@ -102,7 +102,7 @@ public class RowCountTaskLevelPolicyTest {
   public void testRowCountRangePolicyFailed()
       throws Exception {
     State state = new State();
-    state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST, "gobblin.policies.count.RowCountRangePolicy");
+    state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST, "org.apache.gobblin.policies.count.RowCountRangePolicy");
     state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST_TYPE, "FAIL");
     state.setProp(ConfigurationKeys.EXTRACTOR_ROWS_EXPECTED, EXTRACTOR_ROWS_READ);
     state.setProp(ConfigurationKeys.WRITER_ROWS_WRITTEN, -1);
@@ -119,7 +119,7 @@ public class RowCountTaskLevelPolicyTest {
       throws Exception {
     State state = new State();
     state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST,
-        "gobblin.policies.count.RowCountPolicy,gobblin.policies.count.RowCountRangePolicy");
+        "org.apache.gobblin.policies.count.RowCountPolicy,org.apache.gobblin.policies.count.RowCountRangePolicy");
     state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST_TYPE, "FAIL,FAIL");
     state.setProp(ConfigurationKeys.EXTRACTOR_ROWS_EXPECTED, EXTRACTOR_ROWS_READ);
     state.setProp(ConfigurationKeys.WRITER_ROWS_WRITTEN, WRITER_ROWS_WRITTEN);

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowLevelQualityCheckerTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowLevelQualityCheckerTest.java b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowLevelQualityCheckerTest.java
index 1ce5868..808cfef 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowLevelQualityCheckerTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowLevelQualityCheckerTest.java
@@ -43,7 +43,7 @@ public class RowLevelQualityCheckerTest {
   public void testRowLevelPolicy()
       throws Exception {
     State state = new State();
-    state.setProp(ConfigurationKeys.ROW_LEVEL_POLICY_LIST, "gobblin.qualitychecker.TestRowLevelPolicy");
+    state.setProp(ConfigurationKeys.ROW_LEVEL_POLICY_LIST, "org.apache.gobblin.qualitychecker.TestRowLevelPolicy");
     state.setProp(ConfigurationKeys.ROW_LEVEL_POLICY_LIST_TYPE, "FAIL");
 
     RowLevelPolicyChecker checker =
@@ -61,7 +61,7 @@ public class RowLevelQualityCheckerTest {
   public void testWriteToErrFile()
       throws Exception {
     State state = new State();
-    state.setProp(ConfigurationKeys.ROW_LEVEL_POLICY_LIST, "gobblin.qualitychecker.TestRowLevelPolicyFail");
+    state.setProp(ConfigurationKeys.ROW_LEVEL_POLICY_LIST, "org.apache.gobblin.qualitychecker.TestRowLevelPolicyFail");
     state.setProp(ConfigurationKeys.ROW_LEVEL_POLICY_LIST_TYPE, "ERR_FILE");
     state.setProp(ConfigurationKeys.ROW_LEVEL_ERR_FILE, TestConstants.TEST_ERR_FILE);
     state.setProp(ConfigurationKeys.WRITER_FILE_SYSTEM_URI, TestConstants.TEST_FS_URI);

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TaskLevelQualityCheckerTest.java
----------------------------------------------------------------------
diff --git a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TaskLevelQualityCheckerTest.java b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TaskLevelQualityCheckerTest.java
index 8bd8edf..c366faa 100644
--- a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TaskLevelQualityCheckerTest.java
+++ b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TaskLevelQualityCheckerTest.java
@@ -37,7 +37,7 @@ public class TaskLevelQualityCheckerTest {
   public void testPolicyChecker()
       throws Exception {
     State state = new State();
-    state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST, "gobblin.qualitychecker.TestTaskLevelPolicy");
+    state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST, "org.apache.gobblin.qualitychecker.TestTaskLevelPolicy");
     state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST_TYPE, "FAIL");
 
     TaskLevelPolicyCheckResults results = getPolicyResults(state);
@@ -51,7 +51,7 @@ public class TaskLevelQualityCheckerTest {
       throws Exception {
     State state = new State();
     state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST,
-        "gobblin.qualitychecker.TestTaskLevelPolicy,gobblin.qualitychecker.TestTaskLevelPolicy");
+        "org.apache.gobblin.qualitychecker.TestTaskLevelPolicy,org.apache.gobblin.qualitychecker.TestTaskLevelPolicy");
     state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST_TYPE, "FAIL,FAIL");
 
     TaskLevelPolicyCheckResults results = getPolicyResults(state);

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/publisher/CopyDataPublisher.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/publisher/CopyDataPublisher.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/publisher/CopyDataPublisher.java
index 3b22a89..b961faa 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/publisher/CopyDataPublisher.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/publisher/CopyDataPublisher.java
@@ -103,7 +103,7 @@ public class CopyDataPublisher extends DataPublisher implements UnpublishedHandl
     MetricContext metricContext =
         Instrumented.getMetricContext(state, CopyDataPublisher.class, GobblinMetrics.getCustomTagsFromState(state));
 
-    this.eventSubmitter = new EventSubmitter.Builder(metricContext, "gobblin.copy.CopyDataPublisher").build();
+    this.eventSubmitter = new EventSubmitter.Builder(metricContext, "org.apache.gobblin.copy.CopyDataPublisher").build();
 
     this.recoveryHelper = new RecoveryHelper(this.fs, state);
     this.recoveryHelper.purgeOldPersistedFile();

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/ConfigurableCleanableDatasetTest.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/ConfigurableCleanableDatasetTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/ConfigurableCleanableDatasetTest.java
index 1a4311d..35ddd77 100644
--- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/ConfigurableCleanableDatasetTest.java
+++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/ConfigurableCleanableDatasetTest.java
@@ -48,9 +48,9 @@ public class ConfigurableCleanableDatasetTest {
 
     Config conf =
         ConfigFactory.parseMap(ImmutableMap.<String, String> of("gobblin.retention.version.finder.class",
-            "gobblin.data.management.version.finder.WatermarkDatasetVersionFinder",
+            "org.apache.gobblin.data.management.version.finder.WatermarkDatasetVersionFinder",
             "gobblin.retention.retention.policy.class",
-            "gobblin.data.management.retention.policy.NewestKRetentionPolicy",
+            "org.apache.gobblin.data.management.retention.policy.NewestKRetentionPolicy",
             "gobblin.retention.newestK.versions.retained", "2"));
 
     ConfigurableCleanableDataset<FileSystemDatasetVersion> dataset =
@@ -67,9 +67,9 @@ public class ConfigurableCleanableDatasetTest {
 
     Config conf =
         ConfigFactory.parseMap(ImmutableMap.<String, String> of("gobblin.retention.version.finder.class",
-            "gobblin.data.management.version.finder.WatermarkDatasetVersionFinder",
+            "org.apache.gobblin.data.management.version.finder.WatermarkDatasetVersionFinder",
             "gobblin.retention.selection.policy.class",
-            "gobblin.data.management.policy.NewestKSelectionPolicy",
+            "org.apache.gobblin.data.management.policy.NewestKSelectionPolicy",
             "gobblin.retention.selection.newestK.versionsSelected", "2"));
 
     ConfigurableCleanableDataset<FileSystemDatasetVersion> dataset =
@@ -86,8 +86,8 @@ public class ConfigurableCleanableDatasetTest {
 
     Map<String, String> partitionConf =
         ImmutableMap.<String, String> of("version.finder.class",
-            "gobblin.data.management.version.finder.WatermarkDatasetVersionFinder", "selection.policy.class",
-            "gobblin.data.management.policy.NewestKSelectionPolicy", "selection.newestK.versionsSelected", "2");
+            "org.apache.gobblin.data.management.version.finder.WatermarkDatasetVersionFinder", "selection.policy.class",
+            "org.apache.gobblin.data.management.policy.NewestKSelectionPolicy", "selection.newestK.versionsSelected", "2");
     Config conf = ConfigFactory.parseMap(ImmutableMap.<String, List<Map<String, String>>> of("gobblin.retention.dataset.partitions",
             ImmutableList.of(partitionConf, partitionConf)));
 
@@ -108,9 +108,9 @@ public class ConfigurableCleanableDatasetTest {
 
     Config conf =
         ConfigFactory.parseMap(ImmutableMap.<String, String> of("gobblin.retention.version.finder.class",
-            "gobblin.data.management.version.finder.WatermarkDatasetVersionFinder",
+            "org.apache.gobblin.data.management.version.finder.WatermarkDatasetVersionFinder",
             "gobblin.retention.selection.policy.class",
-            "gobblin.data.management.policy.NewestKSelectionPolicy",
+            "org.apache.gobblin.data.management.policy.NewestKSelectionPolicy",
             "gobblin.retention.selection.newestK.versionsSelected", "2",
             "gobblin.retention.dataset.is.blacklisted", "true"));
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-docs/adaptors/Hive-Avro-To-ORC-Converter.md
----------------------------------------------------------------------
diff --git a/gobblin-docs/adaptors/Hive-Avro-To-ORC-Converter.md b/gobblin-docs/adaptors/Hive-Avro-To-ORC-Converter.md
index c88f1f6..117d506 100644
--- a/gobblin-docs/adaptors/Hive-Avro-To-ORC-Converter.md
+++ b/gobblin-docs/adaptors/Hive-Avro-To-ORC-Converter.md
@@ -257,9 +257,9 @@ SLA event is published every time an Avro partition/table is converted to ORC. E
         "workunitCreateTime": "1470227446703"
 
         ## Gobblin metrics metadata
-        "class": "gobblin.data.management.conversion.hive.publisher.HiveConvertPublisher",
+        "class": "org.apache.gobblin.data.management.conversion.hive.publisher.HiveConvertPublisher",
         "metricContextID": "20bfb2a2-0592-4f53-9259-c8ee125f90a8",
-        "metricContextName": "gobblin.data.management.conversion.hive.publisher.HiveConvertPublisher.781426901",
+        "metricContextName": "org.apache.gobblin.data.management.conversion.hive.publisher.HiveConvertPublisher.781426901",
     }
 }
 ```

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-example/src/main/resources/csvToAvro.conf
----------------------------------------------------------------------
diff --git a/gobblin-example/src/main/resources/csvToAvro.conf b/gobblin-example/src/main/resources/csvToAvro.conf
index 8a60486..e318588 100644
--- a/gobblin-example/src/main/resources/csvToAvro.conf
+++ b/gobblin-example/src/main/resources/csvToAvro.conf
@@ -1,8 +1,8 @@
 source.filebased.data.directory=/tmp/csvSource
 
-source.class=gobblin.source.extractor.filebased.TextFileBasedSource
-converter.classes="gobblin.converter.StringSchemaInjector,gobblin.converter.csv.CsvToJsonConverter,gobblin.converter.avro.JsonIntermediateToAvroConverter"
-writer.builder.class=gobblin.writer.AvroDataWriterBuilder
+source.class=org.apache.gobblin.source.extractor.filebased.TextFileBasedSource
+converter.classes="org.apache.gobblin.converter.StringSchemaInjector,org.apache.gobblin.converter.csv.CsvToJsonConverter,org.apache.gobblin.converter.avro.JsonIntermediateToAvroConverter"
+writer.builder.class=org.apache.gobblin.writer.AvroDataWriterBuilder
 
 extract.table.name=CsvToAvro
 extract.namespace=gobblin.example

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegister.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegister.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegister.java
index 66cce96..82d205b 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegister.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegister.java
@@ -61,7 +61,7 @@ import lombok.extern.slf4j.Slf4j;
 public abstract class HiveRegister implements Closeable {
 
   public static final String HIVE_REGISTER_TYPE = "hive.register.type";
-  public static final String DEFAULT_HIVE_REGISTER_TYPE = "gobblin.hive.metastore.HiveMetaStoreBasedRegister";
+  public static final String DEFAULT_HIVE_REGISTER_TYPE = "org.apache.gobblin.hive.metastore.HiveMetaStoreBasedRegister";
   public static final String HIVE_TABLE_COMPARATOR_TYPE = "hive.table.comparator.type";
   public static final String DEFAULT_HIVE_TABLE_COMPARATOR_TYPE = HiveTableComparator.class.getName();
   public static final String HIVE_PARTITION_COMPARATOR_TYPE = "hive.partition.comparator.type";

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/metastore/HiveMetaStoreBasedRegister.java
----------------------------------------------------------------------
diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/metastore/HiveMetaStoreBasedRegister.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/metastore/HiveMetaStoreBasedRegister.java
index 49c08a7..2d074d9 100644
--- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/metastore/HiveMetaStoreBasedRegister.java
+++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/metastore/HiveMetaStoreBasedRegister.java
@@ -142,7 +142,7 @@ public class HiveMetaStoreBasedRegister extends HiveRegister {
     this.metricContext =
         GobblinMetricsRegistry.getInstance().getMetricContext(state, HiveMetaStoreBasedRegister.class, GobblinMetrics.getCustomTagsFromState(state));
 
-    this.eventSubmitter = new EventSubmitter.Builder(this.metricContext, "gobblin.hive.HiveMetaStoreBasedRegister").build();
+    this.eventSubmitter = new EventSubmitter.Builder(this.metricContext, "org.apache.gobblin.hive.HiveMetaStoreBasedRegister").build();
   }
 
   @Override

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-metrics-libs/gobblin-metrics-base/src/test/resources/performance-testng.xml
----------------------------------------------------------------------
diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/test/resources/performance-testng.xml b/gobblin-metrics-libs/gobblin-metrics-base/src/test/resources/performance-testng.xml
index 0a95a7c..442f5c0 100644
--- a/gobblin-metrics-libs/gobblin-metrics-base/src/test/resources/performance-testng.xml
+++ b/gobblin-metrics-libs/gobblin-metrics-base/src/test/resources/performance-testng.xml
@@ -23,7 +23,7 @@
         </run>
     </groups>
     <packages>
-        <package name="gobblin.metrics.*" />
+        <package name="org.apache.gobblin.metrics.*" />
     </packages>
 </test>
 </suite>

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/kafka/writer/Kafka08DataWriterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/kafka/writer/Kafka08DataWriterTest.java b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/kafka/writer/Kafka08DataWriterTest.java
index 900e0be..c7ac96f 100644
--- a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/kafka/writer/Kafka08DataWriterTest.java
+++ b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/kafka/writer/Kafka08DataWriterTest.java
@@ -137,7 +137,7 @@ public class Kafka08DataWriterTest {
     props.setProperty(KafkaWriterConfigurationKeys.KAFKA_TOPIC, topic);
     props.setProperty(KafkaWriterConfigurationKeys.KAFKA_PRODUCER_CONFIG_PREFIX + "bootstrap.servers", "localhost:" + _kafkaTestHelper.getKafkaServerPort());
     props.setProperty(KafkaWriterConfigurationKeys.KAFKA_PRODUCER_CONFIG_PREFIX + "value.serializer",
-        "gobblin.kafka.serialize.LiAvroSerializer");
+        "org.apache.gobblin.kafka.serialize.LiAvroSerializer");
 
     // set up mock schema registry
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSource.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSource.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSource.java
index 42c594d..ec4bed5 100644
--- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSource.java
+++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSource.java
@@ -108,7 +108,7 @@ public abstract class KafkaSource<S, D> extends EventBasedSource<S, D> {
   public static final String GOBBLIN_KAFKA_EXTRACT_ALLOW_TABLE_TYPE_NAMESPACE_CUSTOMIZATION =
       "gobblin.kafka.extract.allowTableTypeAndNamspaceCustomization";
   public static final String DEFAULT_GOBBLIN_KAFKA_CONSUMER_CLIENT_FACTORY_CLASS =
-      "gobblin.kafka.client.Kafka08ConsumerClient$Factory";
+      "org.apache.gobblin.kafka.client.Kafka08ConsumerClient$Factory";
   public static final String GOBBLIN_KAFKA_SHOULD_ENABLE_DATASET_STATESTORE =
       "gobblin.kafka.shouldEnableDatasetStateStore";
   public static final boolean DEFAULT_GOBBLIN_KAFKA_SHOULD_ENABLE_DATASET_STATESTORE = false;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-rest-service/gobblin-rest-api/src/main/idl/gobblin.rest.jobExecutions.restspec.json
----------------------------------------------------------------------
diff --git a/gobblin-rest-service/gobblin-rest-api/src/main/idl/gobblin.rest.jobExecutions.restspec.json b/gobblin-rest-service/gobblin-rest-api/src/main/idl/gobblin.rest.jobExecutions.restspec.json
index 4be751e..40e5004 100644
--- a/gobblin-rest-service/gobblin-rest-api/src/main/idl/gobblin.rest.jobExecutions.restspec.json
+++ b/gobblin-rest-service/gobblin-rest-api/src/main/idl/gobblin.rest.jobExecutions.restspec.json
@@ -7,7 +7,7 @@
   "collection" : {
     "identifier" : {
       "name" : "jobExecutionsId",
-      "type" : "gobblin.rest.JobExecutionQuery",
+      "type" : "org.apache.gobblin.rest.JobExecutionQuery",
       "params" : "com.linkedin.restli.common.EmptyRecord"
     },
     "supports" : [ "batch_get", "get" ],

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-rest-service/gobblin-rest-api/src/main/snapshot/gobblin.rest.jobExecutions.snapshot.json
----------------------------------------------------------------------
diff --git a/gobblin-rest-service/gobblin-rest-api/src/main/snapshot/gobblin.rest.jobExecutions.snapshot.json b/gobblin-rest-service/gobblin-rest-api/src/main/snapshot/gobblin.rest.jobExecutions.snapshot.json
index fe626e4..50b37b5 100644
--- a/gobblin-rest-service/gobblin-rest-api/src/main/snapshot/gobblin.rest.jobExecutions.snapshot.json
+++ b/gobblin-rest-service/gobblin-rest-api/src/main/snapshot/gobblin.rest.jobExecutions.snapshot.json
@@ -333,7 +333,7 @@
     "collection" : {
       "identifier" : {
         "name" : "jobExecutionsId",
-        "type" : "gobblin.rest.JobExecutionQuery",
+        "type" : "org.apache.gobblin.rest.JobExecutionQuery",
         "params" : "com.linkedin.restli.common.EmptyRecord"
       },
       "supports" : [ "batch_get", "get" ],

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-rest-service/gobblin-rest-server/src/main/java/org/apache/gobblin/rest/JobExecutionInfoResource.java
----------------------------------------------------------------------
diff --git a/gobblin-rest-service/gobblin-rest-server/src/main/java/org/apache/gobblin/rest/JobExecutionInfoResource.java b/gobblin-rest-service/gobblin-rest-server/src/main/java/org/apache/gobblin/rest/JobExecutionInfoResource.java
index bcaa164..99f4374 100644
--- a/gobblin-rest-service/gobblin-rest-server/src/main/java/org/apache/gobblin/rest/JobExecutionInfoResource.java
+++ b/gobblin-rest-service/gobblin-rest-server/src/main/java/org/apache/gobblin/rest/JobExecutionInfoResource.java
@@ -41,7 +41,7 @@ import org.apache.gobblin.metastore.JobHistoryStore;
  *
  * @author Yinan Li
  */
-@RestLiCollection(name = "jobExecutions", namespace = "gobblin.rest")
+@RestLiCollection(name = "jobExecutions", namespace = "org.apache.gobblin.rest")
 public class JobExecutionInfoResource extends ComplexKeyResourceTemplate<JobExecutionQuery, EmptyRecord, JobExecutionQueryResult> {
 
   private static final Logger LOGGER = LoggerFactory.getLogger(JobExecutionInfoResource.class);

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowconfigs.restspec.json
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowconfigs.restspec.json b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowconfigs.restspec.json
index 8191d60..3f06bbe 100644
--- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowconfigs.restspec.json
+++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowconfigs.restspec.json
@@ -7,7 +7,7 @@
   "collection" : {
     "identifier" : {
       "name" : "id",
-      "type" : "gobblin.service.FlowId",
+      "type" : "org.apache.gobblin.service.FlowId",
       "params" : "com.linkedin.restli.common.EmptyRecord"
     },
     "supports" : [ "create", "delete", "get", "update" ],

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowstatuses.restspec.json
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowstatuses.restspec.json b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowstatuses.restspec.json
index 97f7da1..a8e4d1c 100644
--- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowstatuses.restspec.json
+++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowstatuses.restspec.json
@@ -7,7 +7,7 @@
   "collection" : {
     "identifier" : {
       "name" : "id",
-      "type" : "gobblin.service.FlowStatusId",
+      "type" : "org.apache.gobblin.service.FlowStatusId",
       "params" : "com.linkedin.restli.common.EmptyRecord"
     },
     "supports" : [ "get" ],
@@ -19,7 +19,7 @@
       "name" : "latestFlowStatus",
       "parameters" : [ {
         "name" : "flowId",
-        "type" : "gobblin.service.FlowId"
+        "type" : "org.apache.gobblin.service.FlowId"
       } ]
     } ],
     "entity" : {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/FlowConfig.pdsc
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/FlowConfig.pdsc b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/FlowConfig.pdsc
index b77c204..0bba724 100644
--- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/FlowConfig.pdsc
+++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/FlowConfig.pdsc
@@ -20,7 +20,7 @@
       "type" : "string",
       "doc" : "Comma separated list of URIs for templates used in the flow. The template location is defined by the multiproduct that packages the template.",
       "validate": {
-        "gobblin.service.validator.TemplateUriValidator": {}
+        "org.apache.gobblin.service.validator.TemplateUriValidator": {}
       }
     },
     {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/Schedule.pdsc
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/Schedule.pdsc b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/Schedule.pdsc
index 030a10f..8ca592f 100644
--- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/Schedule.pdsc
+++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/Schedule.pdsc
@@ -9,7 +9,7 @@
       "type" : "string",
       "doc" : "Schedule for flow in cron format",
       "validate": {
-        "gobblin.service.validator.CronValidator": {}
+        "org.apache.gobblin.service.validator.CronValidator": {}
       }
     },
     {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowconfigs.snapshot.json
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowconfigs.snapshot.json b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowconfigs.snapshot.json
index 9bbdfe8..5871f21 100644
--- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowconfigs.snapshot.json
+++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowconfigs.snapshot.json
@@ -35,7 +35,7 @@
       "type" : "string",
       "doc" : "Schedule for flow in cron format",
       "validate" : {
-        "gobblin.service.validator.CronValidator" : { }
+        "org.apache.gobblin.service.validator.CronValidator" : { }
       }
     }, {
       "name" : "runImmediately",
@@ -62,7 +62,7 @@
       "type" : "string",
       "doc" : "Comma separated list of URIs for templates used in the flow. The template location is defined by the multiproduct that packages the template.",
       "validate" : {
-        "gobblin.service.validator.TemplateUriValidator" : { }
+        "org.apache.gobblin.service.validator.TemplateUriValidator" : { }
       }
     }, {
       "name" : "properties",
@@ -91,7 +91,7 @@
     "collection" : {
       "identifier" : {
         "name" : "id",
-        "type" : "gobblin.service.FlowId",
+        "type" : "org.apache.gobblin.service.FlowId",
         "params" : "com.linkedin.restli.common.EmptyRecord"
       },
       "supports" : [ "create", "delete", "get", "update" ],

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowstatuses.snapshot.json
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowstatuses.snapshot.json b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowstatuses.snapshot.json
index 4ed7fd6..cd2943d 100644
--- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowstatuses.snapshot.json
+++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowstatuses.snapshot.json
@@ -204,7 +204,7 @@
     "collection" : {
       "identifier" : {
         "name" : "id",
-        "type" : "gobblin.service.FlowStatusId",
+        "type" : "org.apache.gobblin.service.FlowStatusId",
         "params" : "com.linkedin.restli.common.EmptyRecord"
       },
       "supports" : [ "get" ],
@@ -216,7 +216,7 @@
         "name" : "latestFlowStatus",
         "parameters" : [ {
           "name" : "flowId",
-          "type" : "gobblin.service.FlowId"
+          "type" : "org.apache.gobblin.service.FlowId"
         } ]
       } ],
       "entity" : {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowConfigsResource.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowConfigsResource.java b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowConfigsResource.java
index bb47050..3159d49 100644
--- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowConfigsResource.java
+++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowConfigsResource.java
@@ -49,7 +49,7 @@ import org.apache.gobblin.runtime.spec_catalog.FlowCatalog;
 /**
  * Resource for handling flow configuration requests
  */
-@RestLiCollection(name = "flowconfigs", namespace = "gobblin.service", keyName = "id")
+@RestLiCollection(name = "flowconfigs", namespace = "org.apache.gobblin.service", keyName = "id")
 public class FlowConfigsResource extends ComplexKeyResourceTemplate<FlowId, EmptyRecord, FlowConfig> {
   private static final Logger LOG = LoggerFactory.getLogger(FlowConfigsResource.class);
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowStatusResource.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowStatusResource.java b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowStatusResource.java
index d8192d4..a8ba987 100644
--- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowStatusResource.java
+++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowStatusResource.java
@@ -42,7 +42,7 @@ import org.apache.gobblin.service.monitoring.FlowStatusGenerator;
 /**
  * Resource for handling flow status requests
  */
-@RestLiCollection(name = "flowstatuses", namespace = "gobblin.service", keyName = "id")
+@RestLiCollection(name = "flowstatuses", namespace = "org.apache.gobblin.service", keyName = "id")
 public class FlowStatusResource extends ComplexKeyResourceTemplate<FlowStatusId, EmptyRecord, FlowStatus> {
   private static final Logger LOG = LoggerFactory.getLogger(FlowStatusResource.class);
   public static final String FLOW_STATUS_GENERATOR_INJECT_NAME = "FlowStatusGenerator";

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/idl/gobblin.restli.throttling.permits.restspec.json
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/idl/gobblin.restli.throttling.permits.restspec.json b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/idl/gobblin.restli.throttling.permits.restspec.json
index 799ecb7..4cb7820 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/idl/gobblin.restli.throttling.permits.restspec.json
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/idl/gobblin.restli.throttling.permits.restspec.json
@@ -7,7 +7,7 @@
   "collection" : {
     "identifier" : {
       "name" : "permitsId",
-      "type" : "gobblin.restli.throttling.PermitRequest",
+      "type" : "org.apache.gobblin.restli.throttling.PermitRequest",
       "params" : "com.linkedin.restli.common.EmptyRecord"
     },
     "supports" : [ "get" ],

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/snapshot/gobblin.restli.throttling.permits.snapshot.json
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/snapshot/gobblin.restli.throttling.permits.snapshot.json b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/snapshot/gobblin.restli.throttling.permits.snapshot.json
index 65947c0..c534de20e8 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/snapshot/gobblin.restli.throttling.permits.snapshot.json
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/snapshot/gobblin.restli.throttling.permits.snapshot.json
@@ -60,7 +60,7 @@
     "collection" : {
       "identifier" : {
         "name" : "permitsId",
-        "type" : "gobblin.restli.throttling.PermitRequest",
+        "type" : "org.apache.gobblin.restli.throttling.PermitRequest",
         "params" : "com.linkedin.restli.common.EmptyRecord"
       },
       "supports" : [ "get" ],

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/LimiterServerResource.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/LimiterServerResource.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/LimiterServerResource.java
index 94b303f..0f06967 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/LimiterServerResource.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/LimiterServerResource.java
@@ -58,7 +58,7 @@ import lombok.extern.slf4j.Slf4j;
  */
 @Alpha
 @Slf4j
-@RestLiCollection(name = "permits", namespace = "gobblin.restli.throttling")
+@RestLiCollection(name = "permits", namespace = "org.apache.gobblin.restli.throttling")
 public class LimiterServerResource extends ComplexKeyResourceAsyncTemplate<PermitRequest, EmptyRecord, PermitAllocation> {
 
   public static final long TIMEOUT_MILLIS = 7000; // resli client times out after 10 seconds

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/PoliciesResource.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/PoliciesResource.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/PoliciesResource.java
index 9242717..8311d4d 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/PoliciesResource.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/PoliciesResource.java
@@ -43,7 +43,7 @@ import static org.apache.gobblin.restli.throttling.LimiterServerResource.*;
 /**
  * A Rest.li endpoint for getting the {@link ThrottlingPolicy} associated with a resource id.
  */
-@RestLiCollection(name = "policies", namespace = "gobblin.restli.throttling")
+@RestLiCollection(name = "policies", namespace = "org.apache.gobblin.restli.throttling")
 public class PoliciesResource extends CollectionResourceTemplate<String, Policy> {
 
   @Inject

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ThrottlingGuiceServletConfig.java
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ThrottlingGuiceServletConfig.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ThrottlingGuiceServletConfig.java
index b2f18ff..91d3b17 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ThrottlingGuiceServletConfig.java
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ThrottlingGuiceServletConfig.java
@@ -124,7 +124,7 @@ public class ThrottlingGuiceServletConfig extends GuiceServletContextListener im
         try {
 
           RestLiConfig restLiConfig = new RestLiConfig();
-          restLiConfig.setResourcePackageNames("gobblin.restli.throttling");
+          restLiConfig.setResourcePackageNames("org.apache.gobblin.restli.throttling");
           bind(RestLiConfig.class).toInstance(restLiConfig);
 
           bind(SharedResourcesBroker.class).annotatedWith(Names.named(LimiterServerResource.BROKER_INJECT_NAME)).toInstance(topLevelBroker);

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/test/resources/configStore/_CONFIG_STORE/1/ConfigBasedPolicyTest/resource2/main.conf
----------------------------------------------------------------------
diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/test/resources/configStore/_CONFIG_STORE/1/ConfigBasedPolicyTest/resource2/main.conf b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/test/resources/configStore/_CONFIG_STORE/1/ConfigBasedPolicyTest/resource2/main.conf
index 41e5a83..212b56b 100644
--- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/test/resources/configStore/_CONFIG_STORE/1/ConfigBasedPolicyTest/resource2/main.conf
+++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/test/resources/configStore/_CONFIG_STORE/1/ConfigBasedPolicyTest/resource2/main.conf
@@ -1,2 +1,2 @@
-globalThrottling.policy = "gobblin.restli.throttling.CountBasedPolicy$Factory"
+globalThrottling.policy = "org.apache.gobblin.restli.throttling.CountBasedPolicy$Factory"
 globalThrottling.count = 50

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-runtime/build.gradle
----------------------------------------------------------------------
diff --git a/gobblin-runtime/build.gradle b/gobblin-runtime/build.gradle
index ec99635..422d6f3 100644
--- a/gobblin-runtime/build.gradle
+++ b/gobblin-runtime/build.gradle
@@ -172,7 +172,7 @@ ext.classification="library"
 task pullFileConverter(type: JavaExec) {
   dependsOn jar
   doFirst {
-    main = "gobblin.runtime.template.PullFileToConfigConverter"
+    main = "org.apache.gobblin.runtime.template.PullFileToConfigConverter"
 
     def pullFilesRootPath = "pullFilesRootPath"
     def pullFilesToConvertGlob = "pullFilesToConvertGlob"

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/local/LocalJobLauncherTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/local/LocalJobLauncherTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/local/LocalJobLauncherTest.java
index f620561..8b0c481 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/local/LocalJobLauncherTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/local/LocalJobLauncherTest.java
@@ -120,18 +120,18 @@ public class LocalJobLauncherTest {
     Properties jobProps = loadJobProps();
     jobProps.setProperty(ConfigurationKeys.JOB_NAME_KEY,
         jobProps.getProperty(ConfigurationKeys.JOB_NAME_KEY) + "-testLaunchJobWithFork");
-    jobProps.setProperty(ConfigurationKeys.CONVERTER_CLASSES_KEY, "gobblin.test.TestConverter2");
+    jobProps.setProperty(ConfigurationKeys.CONVERTER_CLASSES_KEY, "org.apache.gobblin.test.TestConverter2");
     jobProps.setProperty(ConfigurationKeys.FORK_BRANCHES_KEY, "2");
     jobProps.setProperty(ConfigurationKeys.ROW_LEVEL_POLICY_LIST + ".0",
-        "gobblin.policies.schema.SchemaRowCheckPolicy");
+        "org.apache.gobblin.policies.schema.SchemaRowCheckPolicy");
     jobProps.setProperty(ConfigurationKeys.ROW_LEVEL_POLICY_LIST + ".1",
-        "gobblin.policies.schema.SchemaRowCheckPolicy");
+        "org.apache.gobblin.policies.schema.SchemaRowCheckPolicy");
     jobProps.setProperty(ConfigurationKeys.ROW_LEVEL_POLICY_LIST_TYPE + ".0", "OPTIONAL");
     jobProps.setProperty(ConfigurationKeys.ROW_LEVEL_POLICY_LIST_TYPE + ".1", "OPTIONAL");
     jobProps.setProperty(ConfigurationKeys.TASK_LEVEL_POLICY_LIST + ".0",
-        "gobblin.policies.count.RowCountPolicy,gobblin.policies.schema.SchemaCompatibilityPolicy");
+        "org.apache.gobblin.policies.count.RowCountPolicy,org.apache.gobblin.policies.schema.SchemaCompatibilityPolicy");
     jobProps.setProperty(ConfigurationKeys.TASK_LEVEL_POLICY_LIST + ".1",
-        "gobblin.policies.count.RowCountPolicy,gobblin.policies.schema.SchemaCompatibilityPolicy");
+        "org.apache.gobblin.policies.count.RowCountPolicy,org.apache.gobblin.policies.schema.SchemaCompatibilityPolicy");
     jobProps.setProperty(ConfigurationKeys.TASK_LEVEL_POLICY_LIST_TYPE + ".0", "OPTIONAL,OPTIONAL");
     jobProps.setProperty(ConfigurationKeys.TASK_LEVEL_POLICY_LIST_TYPE + ".1", "OPTIONAL,OPTIONAL");
     jobProps.setProperty(ConfigurationKeys.WRITER_OUTPUT_FORMAT_KEY + ".0", WriterOutputFormat.AVRO.name());

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncherTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncherTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncherTest.java
index e9f6c62..cd7af9d 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncherTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncherTest.java
@@ -161,18 +161,18 @@ public class MRJobLauncherTest extends BMNGRunner {
     Properties jobProps = loadJobProps();
     jobProps.setProperty(ConfigurationKeys.JOB_NAME_KEY,
         jobProps.getProperty(ConfigurationKeys.JOB_NAME_KEY) + "-testLaunchJobWithFork");
-    jobProps.setProperty(ConfigurationKeys.CONVERTER_CLASSES_KEY, "gobblin.test.TestConverter2");
+    jobProps.setProperty(ConfigurationKeys.CONVERTER_CLASSES_KEY, "org.apache.gobblin.test.TestConverter2");
     jobProps.setProperty(ConfigurationKeys.FORK_BRANCHES_KEY, "2");
     jobProps.setProperty(ConfigurationKeys.ROW_LEVEL_POLICY_LIST + ".0",
-        "gobblin.policies.schema.SchemaRowCheckPolicy");
+        "org.apache.gobblin.policies.schema.SchemaRowCheckPolicy");
     jobProps.setProperty(ConfigurationKeys.ROW_LEVEL_POLICY_LIST + ".1",
-        "gobblin.policies.schema.SchemaRowCheckPolicy");
+        "org.apache.gobblin.policies.schema.SchemaRowCheckPolicy");
     jobProps.setProperty(ConfigurationKeys.ROW_LEVEL_POLICY_LIST_TYPE + ".0", "OPTIONAL");
     jobProps.setProperty(ConfigurationKeys.ROW_LEVEL_POLICY_LIST_TYPE + ".1", "OPTIONAL");
     jobProps.setProperty(ConfigurationKeys.TASK_LEVEL_POLICY_LIST + ".0",
-        "gobblin.policies.count.RowCountPolicy,gobblin.policies.schema.SchemaCompatibilityPolicy");
+        "org.apache.gobblin.policies.count.RowCountPolicy,org.apache.gobblin.policies.schema.SchemaCompatibilityPolicy");
     jobProps.setProperty(ConfigurationKeys.TASK_LEVEL_POLICY_LIST + ".1",
-        "gobblin.policies.count.RowCountPolicy,gobblin.policies.schema.SchemaCompatibilityPolicy");
+        "org.apache.gobblin.policies.count.RowCountPolicy,org.apache.gobblin.policies.schema.SchemaCompatibilityPolicy");
     jobProps.setProperty(ConfigurationKeys.TASK_LEVEL_POLICY_LIST_TYPE + ".0", "OPTIONAL,OPTIONAL");
     jobProps.setProperty(ConfigurationKeys.TASK_LEVEL_POLICY_LIST_TYPE + ".1", "OPTIONAL,OPTIONAL");
     jobProps.setProperty(ConfigurationKeys.WRITER_OUTPUT_FORMAT_KEY + ".0", WriterOutputFormat.AVRO.name());
@@ -205,7 +205,7 @@ public class MRJobLauncherTest extends BMNGRunner {
    * {@link MRJobLauncher#countersToMetrics(GobblinMetrics)} method is called.
    */
   @Test
-  @BMRule(name = "testJobCleanupOnError", targetClass = "gobblin.runtime.mapreduce.MRJobLauncher",
+  @BMRule(name = "testJobCleanupOnError", targetClass = "org.apache.gobblin.runtime.mapreduce.MRJobLauncher",
       targetMethod = "countersToMetrics(GobblinMetrics)", targetLocation = "AT ENTRY", condition = "true",
       action = "throw new IOException(\"Exception for testJobCleanupOnError\")")
   public void testJobCleanupOnError() throws IOException {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-runtime/src/test/resources/brokerTest/SimpleHelloWorldJob.jobconf
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/resources/brokerTest/SimpleHelloWorldJob.jobconf b/gobblin-runtime/src/test/resources/brokerTest/SimpleHelloWorldJob.jobconf
index 4edc7d6..373d5ff 100644
--- a/gobblin-runtime/src/test/resources/brokerTest/SimpleHelloWorldJob.jobconf
+++ b/gobblin-runtime/src/test/resources/brokerTest/SimpleHelloWorldJob.jobconf
@@ -28,7 +28,7 @@ job.description=The "Hello World" Gobblin job
 
 # Source, Converters, Writer, Publisher
 source.class=gobblin.util.test.HelloWorldSource
-converter.classes="gobblin.runtime.JobBrokerInjectionTest$JobBrokerConverter"
+converter.classes="org.apache.gobblin.runtime.JobBrokerInjectionTest$JobBrokerConverter"
 writer.builder.class="org.apache.gobblin.writer.test.GobblinTestEventBusWriter$Builder"
 writer.GobblinTestEventBusWriter.eventBusId=${gobblin.workDir}
 data.publisher.type=gobblin.publisher.NoopPublisher

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceHATest.java
----------------------------------------------------------------------
diff --git a/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceHATest.java b/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceHATest.java
index a468477..01d0285 100644
--- a/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceHATest.java
+++ b/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceHATest.java
@@ -140,7 +140,7 @@ public class GobblinServiceHATest {
     commonServiceCoreProperties.put(ServiceConfigKeys.TOPOLOGY_FACTORY_PREFIX +  TEST_GOBBLIN_EXECUTOR_NAME + ".uri",
         "gobblinExecutor");
     commonServiceCoreProperties.put(ServiceConfigKeys.TOPOLOGY_FACTORY_PREFIX +  TEST_GOBBLIN_EXECUTOR_NAME + ".specExecutorInstanceProducer",
-        "gobblin.service.InMemorySpecExecutorInstanceProducer");
+        "org.apache.gobblin.service.InMemorySpecExecutorInstanceProducer");
     commonServiceCoreProperties.put(ServiceConfigKeys.TOPOLOGY_FACTORY_PREFIX +  TEST_GOBBLIN_EXECUTOR_NAME + ".specExecInstance.capabilities",
         TEST_SOURCE_NAME + ":" + TEST_SINK_NAME);
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceManagerTest.java
----------------------------------------------------------------------
diff --git a/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceManagerTest.java b/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceManagerTest.java
index 835588d..6378339 100644
--- a/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceManagerTest.java
+++ b/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceManagerTest.java
@@ -104,7 +104,7 @@ public class GobblinServiceManagerTest {
     serviceCoreProperties.put(ServiceConfigKeys.TOPOLOGY_FACTORY_PREFIX +  TEST_GOBBLIN_EXECUTOR_NAME + ".uri",
         "gobblinExecutor");
     serviceCoreProperties.put(ServiceConfigKeys.TOPOLOGY_FACTORY_PREFIX +  TEST_GOBBLIN_EXECUTOR_NAME + ".specExecutorInstanceProducer",
-        "gobblin.service.InMemorySpecExecutorInstanceProducer");
+        "org.apache.gobblin.service.InMemorySpecExecutorInstanceProducer");
     serviceCoreProperties.put(ServiceConfigKeys.TOPOLOGY_FACTORY_PREFIX +  TEST_GOBBLIN_EXECUTOR_NAME + ".specExecInstance.capabilities",
         TEST_SOURCE_NAME + ":" + TEST_SINK_NAME);
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-test-harness/src/test/java/org/apache/gobblin/SkipWorkUnitsIntegrationTest.java
----------------------------------------------------------------------
diff --git a/gobblin-test-harness/src/test/java/org/apache/gobblin/SkipWorkUnitsIntegrationTest.java b/gobblin-test-harness/src/test/java/org/apache/gobblin/SkipWorkUnitsIntegrationTest.java
index 84ebc81..ce4f61d 100644
--- a/gobblin-test-harness/src/test/java/org/apache/gobblin/SkipWorkUnitsIntegrationTest.java
+++ b/gobblin-test-harness/src/test/java/org/apache/gobblin/SkipWorkUnitsIntegrationTest.java
@@ -47,7 +47,7 @@ public class SkipWorkUnitsIntegrationTest {
       throws Exception {
     Properties jobProperties =
         GobblinLocalJobLauncherUtils.getJobProperties("runtime_test/skip_workunits_test.properties");
-    jobProperties.setProperty("data.publisher.type", "gobblin.TestSkipWorkUnitsPublisher");
+    jobProperties.setProperty("data.publisher.type", "org.apache.gobblin.TestSkipWorkUnitsPublisher");
     GobblinLocalJobLauncherUtils.invokeLocalJobLauncher(jobProperties);
   }
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-utility/src/main/java/org/apache/gobblin/util/HadoopUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/HadoopUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/HadoopUtils.java
index 1b9b45f..b1bd6cc 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/HadoopUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/HadoopUtils.java
@@ -111,7 +111,7 @@ public class HadoopUtils {
     }
 
     // Add a new custom filesystem mapping
-    conf.set("fs.sftp.impl", "gobblin.source.extractor.extract.sftp.SftpLightWeightFileSystem");
+    conf.set("fs.sftp.impl", "org.apache.gobblin.source.extractor.extract.sftp.SftpLightWeightFileSystem");
     conf.set("fs.sftp.impl.disable.cache", "true");
     return conf;
   }

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/broker/SharedLimiterFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/broker/SharedLimiterFactory.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/broker/SharedLimiterFactory.java
index 7d2a364..8a029c1 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/broker/SharedLimiterFactory.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/broker/SharedLimiterFactory.java
@@ -99,7 +99,7 @@ public class SharedLimiterFactory<S extends ScopeType<S>> implements SharedResou
 
     if (!configView.getScope().isLocal() && !globalLimiterPolicy.equals(SharedLimiterKey.GlobalLimiterPolicy.LOCAL_ONLY)) {
       try {
-        Class<?> klazz = Class.forName("gobblin.util.limiter.RestliLimiterFactory");
+        Class<?> klazz = Class.forName("org.apache.gobblin.util.limiter.RestliLimiterFactory");
         return new ResourceCoordinate<>((SharedResourceFactory<Limiter, SharedLimiterKey, S>) klazz.newInstance(),
             configView.getKey(), (S) configView.getScope());
       } catch (ReflectiveOperationException roe) {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/ligradle/findbugs/findbugsExclude.xml
----------------------------------------------------------------------
diff --git a/ligradle/findbugs/findbugsExclude.xml b/ligradle/findbugs/findbugsExclude.xml
index 8a75879..7032a51 100644
--- a/ligradle/findbugs/findbugsExclude.xml
+++ b/ligradle/findbugs/findbugsExclude.xml
@@ -37,16 +37,16 @@
 	</Match>
 	<!-- Ignore gobblin.audit.values.auditor as the package is still a WIP -->
   <Match>
-    <Package name="~gobblin\.audit\.values\.auditor.*" />
+    <Package name="~org\.apache\.gobblin\.audit\.values\.auditor.*" />
 	</Match>
   <!-- Ignored until https://github.com/linkedin/gobblin/issues/969 has been resolved -->
   <Match>
-     <Class name="~gobblin\.metastore\.database\.DatabaseJobHistoryStoreV.*" />
+     <Class name="~org\.apache\.gobblin\.metastore\.database\.DatabaseJobHistoryStoreV.*" />
      <Bug pattern="SQL_PREPARED_STATEMENT_GENERATED_FROM_NONCONSTANT_STRING" />
   </Match>
   <!-- Ignored until https://github.com/linkedin/gobblin/issues/976 has been resolved -->
   <Match>
-    <Class name="gobblin.source.jdbc.JdbcExtractor" />
+    <Class name="org.apache.gobblin.source.jdbc.JdbcExtractor" />
     <Bug pattern="OBL_UNSATISFIED_OBLIGATION,ODR_OPEN_DATABASE_RESOURCE" />
   </Match>
 </FindBugsFilter>


Mime
View raw message