Explorar o código

feat:修改20240729_copy_zheng分桶脚本

zhaohaipeng hai 9 meses
pai
achega
cb229e0fe6

+ 5 - 0
src/main/scala/com/aliyun/odps/spark/examples/makedata_ad/makedata_ad_33_bucketData_20240729_copy_zheng.scala

@@ -109,6 +109,11 @@ object makedata_ad_33_bucketData_20240729_copy_zheng {
               val label = JSON.parseObject(labelKey).getOrDefault(whatLabel, "0").toString
               if (!label.equals("0")) {
                 Seq(
+                  (logKey, labelKey, features),
+                  (logKey, labelKey, features),
+                  (logKey, labelKey, features),
+                  (logKey, labelKey, features),
+                  (logKey, labelKey, features),
                   (logKey, labelKey, features),
                   (logKey, labelKey, features),
                   (logKey, labelKey, features),