Browse Source

修改查询的数据

xueyiming 2 months ago
parent
commit
ff6c28a869

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

@@ -62,7 +62,7 @@ object makedata_ad_33_bucketData_hive_20240718 {
     val dateRange = MyDateUtils.getDateRange(beginStr, endStr)
     for (date <- dateRange) {
       println("开始执行:" + date)
-      val data = sc.textFile(readPath + "/" + date + "08").map(r => {
+      val data = sc.textFile(readPath + "/" + date + "*").map(r => {
         val rList = r.split("\t")
         val logKey = rList(0)
         val labelKey = rList(1)