소스 검색

修改类型

xueyiming 7 달 전
부모
커밋
dbce3e3876
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

@@ -62,7 +62,7 @@ object diff_data_20240718 {
     val parts = input.trim.split("\t")
     var resultMap = Map[String, String]()
     // 处理第一个元素,假设为特殊标识
-    resultMap += ("has_conversion" -> parts(0).toLong)
+    resultMap += ("has_conversion" -> parts(0))
     // 处理后续的键值对
     parts.drop(1).foreach { part =>
       part.split(":", 2) match {