From ea2642cb0f32c1e2706aff6a2eea2626f60064f4 Mon Sep 17 00:00:00 2001 From: lamber-ken Date: Tue, 10 Dec 2019 09:23:47 +0800 Subject: [PATCH] [MINOR] replace scala map add operator --- hudi-spark/src/main/scala/org/apache/hudi/DefaultSource.scala | 2 +- .../src/main/scala/org/apache/hudi/HoodieSparkSqlWriter.scala | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/hudi-spark/src/main/scala/org/apache/hudi/DefaultSource.scala b/hudi-spark/src/main/scala/org/apache/hudi/DefaultSource.scala index f50d90f3185d8..0c857d0dd27d1 100644 --- a/hudi-spark/src/main/scala/org/apache/hudi/DefaultSource.scala +++ b/hudi-spark/src/main/scala/org/apache/hudi/DefaultSource.scala @@ -50,7 +50,7 @@ class DefaultSource extends RelationProvider optParams: Map[String, String], schema: StructType): BaseRelation = { // Add default options for unspecified read options keys. - val parameters = Map(VIEW_TYPE_OPT_KEY -> DEFAULT_VIEW_TYPE_OPT_VAL) ++: optParams + val parameters = Map(VIEW_TYPE_OPT_KEY -> DEFAULT_VIEW_TYPE_OPT_VAL) ++ optParams val path = parameters.get("path") if (path.isEmpty) { diff --git a/hudi-spark/src/main/scala/org/apache/hudi/HoodieSparkSqlWriter.scala b/hudi-spark/src/main/scala/org/apache/hudi/HoodieSparkSqlWriter.scala index a4335438227e4..dcd96a68f3859 100644 --- a/hudi-spark/src/main/scala/org/apache/hudi/HoodieSparkSqlWriter.scala +++ b/hudi-spark/src/main/scala/org/apache/hudi/HoodieSparkSqlWriter.scala @@ -305,7 +305,7 @@ private[hudi] object HoodieSparkSqlWriter { HIVE_PARTITION_EXTRACTOR_CLASS_OPT_KEY -> DEFAULT_HIVE_PARTITION_EXTRACTOR_CLASS_OPT_VAL, HIVE_ASSUME_DATE_PARTITION_OPT_KEY -> DEFAULT_HIVE_ASSUME_DATE_PARTITION_OPT_VAL, HIVE_STYLE_PARTITIONING_OPT_KEY -> DEFAULT_HIVE_STYLE_PARTITIONING_OPT_VAL - ) ++: parameters + ) ++ parameters } def toProperties(params: Map[String, String]): TypedProperties = {