Update static string references to point 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/fbdcc8ae Tree: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/tree/fbdcc8ae Diff: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/diff/fbdcc8ae Branch: refs/heads/master Commit: fbdcc8ae1ff228fd81bc6a0ecb0e267a24af2bb4 Parents: 26a040c Author: Abhishek Tiwari <[email protected]> Authored: Sun Jul 30 17:15:24 2017 -0700 Committer: Abhishek Tiwari <[email protected]> Committed: Sun Jul 30 17:15:24 2017 -0700 ---------------------------------------------------------------------- .../org/apache/gobblin/configuration/ConfigurationKeys.java | 8 ++++---- .../gobblin/compaction/ReflectionCompactorFactory.java | 2 +- .../gobblin/data/management/copy/hive/HiveDatasetFinder.java | 2 +- .../retention/policy/PredicateRetentionPolicy.java | 2 +- .../gobblin/compliance/ComplianceConfigurationKeys.java | 6 +++--- .../apache/gobblin/converter/EnvelopeSchemaConverter.java | 2 +- .../gobblin/source/extractor/extract/kafka/KafkaSource.java | 2 +- .../main/java/org/apache/gobblin/runtime/task/TaskUtils.java | 2 +- 8 files changed, 13 insertions(+), 13 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/fbdcc8ae/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 c77f871..0d8dcf5 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 @@ -144,7 +144,7 @@ public class ConfigurationKeys { public static final String SOURCE_CLASS_KEY = "source.class"; public static final String CONVERTER_CLASSES_KEY = "converter.classes"; public static final String FORK_OPERATOR_CLASS_KEY = "fork.operator.class"; - public static final String DEFAULT_FORK_OPERATOR_CLASS = "gobblin.fork.IdentityForkOperator"; + public static final String DEFAULT_FORK_OPERATOR_CLASS = "org.apache.gobblin.fork.IdentityForkOperator"; public static final String JOB_COMMIT_POLICY_KEY = "job.commit.policy"; public static final String DEFAULT_JOB_COMMIT_POLICY = "full"; // If true, commit of different datasets will be performed in parallel @@ -306,7 +306,7 @@ public class ConfigurationKeys { public static final String WRITER_TRUNCATE_STAGING_TABLE = WRITER_PREFIX + ".truncate.staging.table"; public static final String WRITER_OUTPUT_DIR = WRITER_PREFIX + ".output.dir"; public static final String WRITER_BUILDER_CLASS = WRITER_PREFIX + ".builder.class"; - public static final String DEFAULT_WRITER_BUILDER_CLASS = "gobblin.writer.AvroDataWriterBuilder"; + public static final String DEFAULT_WRITER_BUILDER_CLASS = "org.apache.gobblin.writer.AvroDataWriterBuilder"; public static final String WRITER_FILE_NAME = WRITER_PREFIX + ".file.name"; public static final String WRITER_FILE_PATH = WRITER_PREFIX + ".file.path"; public static final String WRITER_FILE_PATH_TYPE = WRITER_PREFIX + ".file.path.type"; @@ -608,7 +608,7 @@ public class ConfigurationKeys { public static final String METRICS_REPORTING_KAFKA_ENABLED_KEY = METRICS_CONFIGURATIONS_PREFIX + "reporting.kafka.enabled"; public static final String DEFAULT_METRICS_REPORTING_KAFKA_ENABLED = Boolean.toString(false); - public static final String DEFAULT_METRICS_REPORTING_KAFKA_REPORTER_CLASS = "gobblin.metrics.kafka.KafkaReporterFactory"; + public static final String DEFAULT_METRICS_REPORTING_KAFKA_REPORTER_CLASS = "org.apache.gobblin.metrics.kafka.KafkaReporterFactory"; public static final String METRICS_REPORTING_KAFKA_FORMAT = METRICS_CONFIGURATIONS_PREFIX + "reporting.kafka.format"; public static final String DEFAULT_METRICS_REPORTING_KAFKA_FORMAT = "json"; public static final String METRICS_REPORTING_KAFKA_USE_SCHEMA_REGISTRY = @@ -699,7 +699,7 @@ public class ConfigurationKeys { public static final String ADMIN_SERVER_REFRESH_INTERVAL_KEY = "admin.server.refresh_interval"; public static final long DEFAULT_ADMIN_SERVER_REFRESH_INTERVAL = 30000; - public static final String DEFAULT_ADMIN_SERVER_FACTORY_CLASS = "gobblin.admin.DefaultAdminWebServerFactory"; + public static final String DEFAULT_ADMIN_SERVER_FACTORY_CLASS = "org.apache.gobblin.admin.DefaultAdminWebServerFactory"; /** * Kafka job configurations. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/fbdcc8ae/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/ReflectionCompactorFactory.java ---------------------------------------------------------------------- diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/ReflectionCompactorFactory.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/ReflectionCompactorFactory.java index eaeebd3..fc68e47 100644 --- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/ReflectionCompactorFactory.java +++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/ReflectionCompactorFactory.java @@ -36,7 +36,7 @@ public class ReflectionCompactorFactory implements CompactorFactory { @VisibleForTesting static final String COMPACTION_COMPACTOR_CLASS = "compaction.compactor.class"; - private static final String DEFAULT_COMPACTION_COMPACTOR_CLASS = "gobblin.compaction.mapreduce.MRCompactor"; + private static final String DEFAULT_COMPACTION_COMPACTOR_CLASS = "org.apache.gobblin.compaction.mapreduce.MRCompactor"; @Override public Compactor createCompactor(Properties properties, List<Tag<String>> tags, http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/fbdcc8ae/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/hive/HiveDatasetFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/hive/HiveDatasetFinder.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/hive/HiveDatasetFinder.java index 7e34040..98134b8 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/hive/HiveDatasetFinder.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/hive/HiveDatasetFinder.java @@ -97,7 +97,7 @@ public class HiveDatasetFinder implements IterableDatasetFinder<HiveDataset> { * This is an optional key. * The fully qualified name of a {@link Function} class which returns the relative uri of a dataset in the config store */ - public static final String CONFIG_STORE_DATASET_URI_BUILDER_CLASS = "gobblin.config.management.datasetUriBuilderClass"; + public static final String CONFIG_STORE_DATASET_URI_BUILDER_CLASS = "org.apache.gobblin.config.management.datasetUriBuilderClass"; // Event names private static final String DATASET_FOUND = "DatasetFound"; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/fbdcc8ae/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/PredicateRetentionPolicy.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/PredicateRetentionPolicy.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/PredicateRetentionPolicy.java index 1858606..35aba33 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/PredicateRetentionPolicy.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/PredicateRetentionPolicy.java @@ -39,7 +39,7 @@ public class PredicateRetentionPolicy implements RetentionPolicy<DatasetVersion> private final Predicate<DatasetVersion> predicate; - private static final String RETENTION_POLICY_PREDICATE_CLASS = "gobblin.retention.retention.policy.predicate.class"; + private static final String RETENTION_POLICY_PREDICATE_CLASS = "org.apache.gobblin.retention.retention.policy.predicate.class"; @SuppressWarnings("unchecked") public PredicateRetentionPolicy(Properties props) throws InstantiationException, IllegalAccessException, http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/fbdcc8ae/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/ComplianceConfigurationKeys.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/ComplianceConfigurationKeys.java b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/ComplianceConfigurationKeys.java index 4ef4474..dbb79b2 100644 --- a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/ComplianceConfigurationKeys.java +++ b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/ComplianceConfigurationKeys.java @@ -93,10 +93,10 @@ public class ComplianceConfigurationKeys { COMPLIANCE_PREFIX + ".retention.selection.policy.class"; public static final String DATASET_SELECTION_POLICY_CLASS = COMPLIANCE_PREFIX + ".dataset.selection.policy.class"; - public static final String DEFAULT_DATASET_SELECTION_POLICY_CLASS = "gobblin.compliance.HivePartitionDatasetPolicy"; + public static final String DEFAULT_DATASET_SELECTION_POLICY_CLASS = "org.apache.gobblin.compliance.HivePartitionDatasetPolicy"; public static final String PURGER_COMMIT_POLICY_CLASS = COMPLIANCE_PREFIX + ".purger.commit.policy.class"; - public static final String DEFAULT_PURGER_COMMIT_POLICY_CLASS = "gobblin.compliance.purger.HivePurgerCommitPolicy"; + public static final String DEFAULT_PURGER_COMMIT_POLICY_CLASS = "org.apache.gobblin.compliance.purger.HivePurgerCommitPolicy"; public static final String RETENTION_VERSION_CLEANER_CLASS_KEY = COMPLIANCE_PREFIX + ".retention.version.cleaner.class"; @@ -116,7 +116,7 @@ public class ComplianceConfigurationKeys { // Path to the compliance id in the dataset descriptor json object. public static final String DATASET_DESCRIPTOR_FIELDPATH = COMPLIANCE_PREFIX + ".dataset.descriptor.fieldPath"; public static final String DATASET_DESCRIPTOR_CLASS = COMPLIANCE_PREFIX + ".dataset.descriptor.class"; - public static final String DEFAULT_DATASET_DESCRIPTOR_CLASS = "gobblin.compliance.DatasetDescriptorImpl"; + public static final String DEFAULT_DATASET_DESCRIPTOR_CLASS = "org.apache.gobblin.compliance.DatasetDescriptorImpl"; // Name of the table containing the compliance ids based on which purging will take place. public static final String COMPLIANCE_ID_TABLE_KEY = COMPLIANCE_PREFIX + ".purger.complianceIdTable"; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/fbdcc8ae/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/converter/EnvelopeSchemaConverter.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/converter/EnvelopeSchemaConverter.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/converter/EnvelopeSchemaConverter.java index 8c1bf7f..8696f13 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/converter/EnvelopeSchemaConverter.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/converter/EnvelopeSchemaConverter.java @@ -54,7 +54,7 @@ public class EnvelopeSchemaConverter extends Converter<Schema, String, GenericRe public static final String PAYLOAD_FIELD = "EnvelopeSchemaConverter.payloadField"; public static final String DEFAULT_PAYLOAD_SCHEMA_ID_FIELD ="payloadSchemaId"; public static final String DEFAULT_PAYLOAD_FIELD = "payload"; - public static final String DEFAULT_KAFKA_SCHEMA_REGISTRY_FACTORY_CLASS = "gobblin.metrics.kafka.KafkaAvroSchemaRegistryFactory"; + public static final String DEFAULT_KAFKA_SCHEMA_REGISTRY_FACTORY_CLASS = "org.apache.gobblin.metrics.kafka.KafkaAvroSchemaRegistryFactory"; private Optional<AvroSchemaFieldRemover> fieldRemover; private KafkaSchemaRegistry registry; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/fbdcc8ae/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 4fa9fb4..42c594d 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 @@ -104,7 +104,7 @@ public abstract class KafkaSource<S, D> extends EventBasedSource<S, D> { public static final String ALL_TOPICS = "all"; public static final String AVG_RECORD_SIZE = "avg.record.size"; public static final String AVG_RECORD_MILLIS = "avg.record.millis"; - public static final String GOBBLIN_KAFKA_CONSUMER_CLIENT_FACTORY_CLASS = "gobblin.kafka.consumerClient.class"; + public static final String GOBBLIN_KAFKA_CONSUMER_CLIENT_FACTORY_CLASS = "org.apache.gobblin.kafka.consumerClient.class"; 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 = http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/fbdcc8ae/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskUtils.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskUtils.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskUtils.java index 8df7a0b..f5ebd0d 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskUtils.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/task/TaskUtils.java @@ -26,7 +26,7 @@ import org.apache.gobblin.configuration.State; */ public class TaskUtils { - private static final String TASK_FACTORY_CLASS = "gobblin.runtime.taskFactoryClass"; + private static final String TASK_FACTORY_CLASS = "org.apache.gobblin.runtime.taskFactoryClass"; /** * Parse the {@link TaskFactory} in the state if one is defined.
