Parcourir la source

feat:修改20240728分桶脚本

zhaohaipeng il y a 9 mois
Parent
commit
ee7f14d172

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

@@ -57,7 +57,7 @@ object makedata_ad_33_bucketData_20240729 {
 
     val dateRange = MyDateUtils.getDateRange(beginStr, endStr)
 
-    val cidCountMap = scala.collection.mutable.Map[String, Double]()
+    val cidCountMap = scala.collection.mutable.Map[String, Int]()
     for (date <- dateRange) {
       println("开始执行:" + date)
       val data = sc.textFile(readPath + "/" + date + "*").map(r=>{