lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-2216] Correct the words fiels in the comments to fields (#3339)

Browse Source
This commit is contained in:
董可伦
2021-07-25 12:15:57 +08:00
committed by GitHub
parent a14b19fdd5
commit a91296f14a
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/MergeIntoHoodieTableCommand.scala
View File

@@ -260,7 +260,7 @@ case class MergeIntoHoodieTableCommand(mergeInto: MergeIntoTable) extends Runnab
writeParams += (PAYLOAD_INSERT_CONDITION_AND_ASSIGNMENTS -> writeParams += (PAYLOAD_INSERT_CONDITION_AND_ASSIGNMENTS ->
serializedInsertConditionAndExpressions(insertActions)) serializedInsertConditionAndExpressions(insertActions))
// Remove the meta fiels from the sourceDF as we do not need these when writing. // Remove the meta fields from the sourceDF as we do not need these when writing.
val sourceDFWithoutMetaFields = removeMetaFields(sourceDF) val sourceDFWithoutMetaFields = removeMetaFields(sourceDF)
HoodieSparkSqlWriter.write(sparkSession.sqlContext, SaveMode.Append, writeParams, sourceDFWithoutMetaFields) HoodieSparkSqlWriter.write(sparkSession.sqlContext, SaveMode.Append, writeParams, sourceDFWithoutMetaFields)
} }
@@ -281,7 +281,7 @@ case class MergeIntoHoodieTableCommand(mergeInto: MergeIntoTable) extends Runnab
writeParams += (PAYLOAD_INSERT_CONDITION_AND_ASSIGNMENTS -> writeParams += (PAYLOAD_INSERT_CONDITION_AND_ASSIGNMENTS ->
serializedInsertConditionAndExpressions(insertActions)) serializedInsertConditionAndExpressions(insertActions))
// Remove the meta fiels from the sourceDF as we do not need these when writing. // Remove the meta fields from the sourceDF as we do not need these when writing.
val sourceDFWithoutMetaFields = removeMetaFields(sourceDF) val sourceDFWithoutMetaFields = removeMetaFields(sourceDF)
HoodieSparkSqlWriter.write(sparkSession.sqlContext, SaveMode.Append, writeParams, sourceDFWithoutMetaFields) HoodieSparkSqlWriter.write(sparkSession.sqlContext, SaveMode.Append, writeParams, sourceDFWithoutMetaFields)
} }