Explorar o código

修改数据类型

xueyiming hai 2 meses
pai
achega
b3c2cfd8f5

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

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