소스 검색

增加空值处理

xueyiming 2 달 전
부모
커밋
6f7e8c0f78
1개의 변경된 파일1개의 추가작업 그리고 1개의 파일을 삭제
  1. 1 1
      src/main/scala/com/aliyun/odps/spark/examples/makedata_ad/v20240718/diff_data_20240718.scala

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

@@ -43,7 +43,7 @@ object diff_data_20240718 {
     for (i <- 0 until columns.size()) {
       val column = columns.get(i)
       val name = column.getName
-      val value = record.get(name).toString
+      val value = Option(record.get(name)).map(_.toString).getOrElse("")
       map += (name -> value)
     }
     map