Преглед на файлове

feat:修改20240729_copy_zheng分桶脚本

zhaohaipeng преди 10 месеца
родител
ревизия
959a3d9e4b
променени са 1 файла, в които са добавени 2 реда и са изтрити 2 реда
  1. 2 2
      src/main/scala/com/aliyun/odps/spark/examples/makedata_ad/makedata_ad_33_bucketData_20240729_copy_zheng.scala

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

@@ -106,8 +106,8 @@ object makedata_ad_33_bucketData_20240729_copy_zheng {
               }
             }
             if (key.equals("cid_3319")) {
-              val whatLabel = JSON.parseObject(labelKey).getOrDefault(whatLabel, "0").toString
-              if (!whatLabel.equals("0")) {
+              val label = JSON.parseObject(labelKey).getOrDefault(whatLabel, "0").toString
+              if (!label.equals("0")) {
                 Seq(
                   (logKey, labelKey, features),
                   (logKey, labelKey, features),