Skip to content

Commit c81d729

Browse files
authored
Fix mapValues (#14)
CI is failing with ``` [ERROR] [Error] /var/lib/applied-bk-agent/checkout/spark-private/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/unresolved.scala:593: value mapValues is not a member of scala.collection.IterableView[(org.apache.spark.sql.catalyst.expressions.Attribute, Seq[(org.apache.spark.sql.catalyst.expressions.NamedExpression, Seq[String])]),scala.collection.immutable.Map[org.apache.spark.sql.catalyst.expressions.Attribute,Seq[(org.apache.spark.sql.catalyst.expressions.NamedExpression, Seq[String])]]] ``` This replaces the `mapValues` construct with an equivalent one that should work.
1 parent 27e43ae commit c81d729

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

  • sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/unresolved.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -590,7 +590,7 @@ case class UnresolvedStarExcept(target: Option[Seq[String]], excepts: Seq[Seq[St
590590
: Seq[NamedExpression] = {
591591
// group the except pairs by the column they refer to. NOTE: no groupMap until scala 2.13
592592
val groupedExcepts: AttributeMap[Seq[Seq[String]]] =
593-
AttributeMap(excepts.groupBy(_._1.toAttribute).view.mapValues(v => v.map(_._2)))
593+
AttributeMap(excepts.groupBy(_._1.toAttribute).map { case (k, v) => k -> v.map(_._2) })
594594

595595
// map input columns while searching for the except entry corresponding to the current column
596596
columns.map(col => col -> groupedExcepts.get(col.toAttribute)).collect {

0 commit comments

Comments
 (0)