Skip to content

Commit

Permalink
value => valueFunc
Browse files Browse the repository at this point in the history
  • Loading branch information
fqaiser94 committed Aug 12, 2020
1 parent ad111ba commit 977ff31
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions sql/core/src/main/scala/org/apache/spark/sql/Column.scala
Original file line number Diff line number Diff line change
Expand Up @@ -972,17 +972,17 @@ class Column(val expr: Expression) extends Logging {
}

private def updateFieldsHelper(
struct: Expression,
namePartsRemaining: Seq[String],
value: String => StructFieldsOperation): UpdateFields = {
struct: Expression,
namePartsRemaining: Seq[String],
valueFunc: String => StructFieldsOperation): UpdateFields = {
val fieldName = namePartsRemaining.head
if (namePartsRemaining.length == 1) {
UpdateFields(struct, value(fieldName) :: Nil)
UpdateFields(struct, valueFunc(fieldName) :: Nil)
} else {
val newValue = updateFieldsHelper(
struct = UnresolvedExtractValue(struct, Literal(fieldName)),
namePartsRemaining = namePartsRemaining.tail,
value = value)
valueFunc = valueFunc)
UpdateFields(struct, WithField(fieldName, newValue) :: Nil)
}
}
Expand Down

0 comments on commit 977ff31

Please sign in to comment.