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

feat:修改20240729_reduce_feature分桶脚本

zhaohaipeng преди 9 месеца
родител
ревизия
f89d119c2b
променени са 1 файла, в които са добавени 3 реда и са изтрити 0 реда
  1. 3 0
      src/main/scala/com/aliyun/odps/spark/examples/makedata_ad/makedata_ad_31_originData_20240718.scala

+ 3 - 0
src/main/scala/com/aliyun/odps/spark/examples/makedata_ad/makedata_ad_31_originData_20240718.scala

@@ -102,6 +102,9 @@ object makedata_ad_31_originData_20240718 {
             if (b1.containsKey("cpa")) {
               featureMap.put("cpa", b1.getString("cpa").toDouble)
             }
+            if (b1.containsKey("weight") && b1.getString("weight").nonEmpty){
+              featureMap.put("weight", b1.getString("weight").toDouble)
+            }
 
             for ((bn, prefix1) <- List(
               (b2, "b2"), (b3, "b3"), (b4, "b4"), (b5, "b5"), (b8, "b8"), (b9, "b9")