Skip to content

Commit caffed9

Browse files
committed
fix 2.12 mapvalues usage
1 parent db1f1f2 commit caffed9

1 file changed

Lines changed: 4 additions & 2 deletions

File tree

spark/src/test/scala/org/apache/comet/CometCodegenDispatchSmokeSuite.scala

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1185,7 +1185,8 @@ class CometCodegenDispatchSmokeSuite extends CometTestBase with AdaptiveSparkPla
11851185
spark.udf.register(
11861186
"sortValues",
11871187
(m: Map[String, Seq[Int]]) =>
1188-
if (m == null) null else m.view.mapValues(v => if (v == null) null else v.sorted).toMap)
1188+
if (m == null) null
1189+
else m.map { case (k, v) => k -> (if (v == null) null else v.sorted) })
11891190
withTable("t") {
11901191
sql("CREATE TABLE t (m MAP<STRING, ARRAY<INT>>) USING parquet")
11911192
sql(
@@ -1206,7 +1207,8 @@ class CometCodegenDispatchSmokeSuite extends CometTestBase with AdaptiveSparkPla
12061207
"tagValues",
12071208
(m: Map[String, XyPair]) =>
12081209
if (m == null) null
1209-
else m.view.mapValues(v => if (v == null) null else XyPair(v.x + 1, s"<${v.y}>")).toMap)
1210+
else
1211+
m.map { case (k, v) => k -> (if (v == null) null else XyPair(v.x + 1, s"<${v.y}>")) })
12101212
withTable("t") {
12111213
sql("CREATE TABLE t (m MAP<STRING, STRUCT<x: INT, y: STRING>>) USING parquet")
12121214
sql(

0 commit comments

Comments
 (0)