gobblin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a...@apache.org
Subject [41/77] [abbrv] incubator-gobblin git commit: Update static string references to point to org.apache.gobblin packages
Date Mon, 31 Jul 2017 07:52:59 GMT
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 <abhishektiwari.btech@gmail.com>
Authored: Sun Jul 30 17:15:24 2017 -0700
Committer: Abhishek Tiwari <abhishektiwari.btech@gmail.com>
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.


Mime
View raw message