Browse Source

修改map

xueyiming 2 months ago
parent
commit
bce7a91714

+ 2 - 2
src/main/scala/com/aliyun/odps/spark/examples/makedata_ad/v20240718/diff_data_20240718.scala

@@ -38,13 +38,13 @@ object diff_data_20240718 {
   }
 
   def func(record: Record, schema: TableSchema): Map[String, String] = {
-    val map: Map[String, String] = Map.empty
+    var map: Map[String, String] = Map.empty
     val columns = schema.getColumns
     for (i <- 0 until columns.size()) {
       val column = columns.get(i)
       val name = column.getName
       val value = record.get(name).toString
-      map += (name, value)
+      map += (name -> value)
     }
     map
   }