diff --git a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieClusteringConfig.java b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieClusteringConfig.java index b576c5b6c..41b1812c0 100644 --- a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieClusteringConfig.java +++ b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieClusteringConfig.java @@ -114,7 +114,8 @@ public class HoodieClusteringConfig extends HoodieConfig { .key("hoodie.clustering.inline") .defaultValue("false") .sinceVersion("0.7.0") - .withDocumentation("Turn on inline clustering - clustering will be run after each write operation is complete"); + .withDocumentation("Turn on inline clustering - clustering will be run after each write operation is complete") + .withAlternatives("hoodie.datasource.clustering.inline.enable"); public static final ConfigProperty INLINE_CLUSTERING_MAX_COMMITS = ConfigProperty .key("hoodie.clustering.inline.max.commits") @@ -192,7 +193,8 @@ public class HoodieClusteringConfig extends HoodieConfig { .key("hoodie.clustering.async.enabled") .defaultValue("false") .sinceVersion("0.7.0") - .withDocumentation("Enable running of clustering service, asynchronously as inserts happen on the table."); + .withDocumentation("Enable running of clustering service, asynchronously as inserts happen on the table.") + .withAlternatives("hoodie.datasource.clustering.async.enable"); public static final ConfigProperty PRESERVE_COMMIT_METADATA = ConfigProperty .key("hoodie.clustering.preserve.commit.metadata") diff --git a/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/DataSourceOptions.scala b/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/DataSourceOptions.scala index 34641f7f6..7c48adf32 100644 --- a/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/DataSourceOptions.scala +++ b/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/DataSourceOptions.scala @@ -23,7 +23,7 @@ import org.apache.hudi.common.fs.ConsistencyGuardConfig import org.apache.hudi.common.model.{HoodieTableType, WriteOperationType} import org.apache.hudi.common.table.HoodieTableConfig import org.apache.hudi.common.util.Option -import org.apache.hudi.config.HoodieWriteConfig +import org.apache.hudi.config.{HoodieClusteringConfig, HoodieWriteConfig} import org.apache.hudi.hive.util.ConfigUtils import org.apache.hudi.hive.{HiveStylePartitionValueExtractor, HiveSyncTool, MultiPartKeysValueExtractor, NonPartitionedExtractor, SlashEncodedDayPartitionValueExtractor} import org.apache.hudi.keygen.constant.KeyGeneratorOptions @@ -587,17 +587,9 @@ object DataSourceWriteOptions { .defaultValue("true") .withDocumentation("Controls whether async compaction should be turned on for MOR table writing.") - val INLINE_CLUSTERING_ENABLE: ConfigProperty[String] = ConfigProperty - .key("hoodie.datasource.clustering.inline.enable") - .defaultValue("false") - .sinceVersion("0.9.0") - .withDocumentation("Enable inline clustering. Disabled by default.") + val INLINE_CLUSTERING_ENABLE = HoodieClusteringConfig.INLINE_CLUSTERING - val ASYNC_CLUSTERING_ENABLE: ConfigProperty[String] = ConfigProperty - .key("hoodie.datasource.clustering.async.enable") - .defaultValue("false") - .sinceVersion("0.9.0") - .withDocumentation("Enable asynchronous clustering. Disabled by default.") + val ASYNC_CLUSTERING_ENABLE = HoodieClusteringConfig.ASYNC_CLUSTERING_ENABLE val KAFKA_AVRO_VALUE_DESERIALIZER_CLASS: ConfigProperty[String] = ConfigProperty .key("hoodie.deltastreamer.source.kafka.value.deserializer.class") @@ -669,10 +661,10 @@ object DataSourceWriteOptions { @Deprecated val HIVE_PARTITION_EXTRACTOR_CLASS_OPT_KEY = HIVE_PARTITION_EXTRACTOR_CLASS.key() - /** @deprecated Use {@link KEYGENERATOR_CLASS} and its methods instead */ + /** @deprecated Use {@link KEYGENERATOR_CLASS_NAME} and its methods instead */ @Deprecated val DEFAULT_KEYGENERATOR_CLASS_OPT_VAL = KEYGENERATOR_CLASS_NAME.defaultValue() - /** @deprecated Use {@link KEYGENERATOR_CLASS} and its methods instead */ + /** @deprecated Use {@link KEYGENERATOR_CLASS_NAME} and its methods instead */ @Deprecated val KEYGENERATOR_CLASS_OPT_KEY = HoodieWriteConfig.KEYGENERATOR_CLASS_NAME.key() /** @deprecated Use {@link ENABLE_ROW_WRITER} and its methods instead */