You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gobblin.apache.org by ab...@apache.org on 2017/07/31 07:53:00 UTC
[42/77] [abbrv] incubator-gobblin git commit: Change internal
references to org.apache.gobblin packages
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 <ab...@gmail.com>
Authored: Sun Jul 30 18:41:41 2017 -0700
Committer: Abhishek Tiwari <ab...@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>