Browse Source

feat:添加特征延迟验证脚本

zhaohaipeng 8 months ago
parent
commit
581af5befd

+ 5 - 1
src/main/scala/com/aliyun/odps/spark/examples/makedata_ad/xgb/makedata_31_bucketDataPrint_20240821.scala

@@ -476,7 +476,11 @@ object makedata_31_bucketDataPrint_20240821 {
         val allFeatureMap = JSON.parseObject(rList(6)).toMap.map(r => (r._1, r._2.toString))
         val offlineFeature = rList(7).split(",").map(r => (r.split(":")(0), r.split(":")(1))).toMap
         val offlineFeatureList = contentList.map(name => {
-          name + ":" + offlineFeature(name)
+          if (offlineFeature.containsKey(name)) {
+            name + ":" + offlineFeature(name)
+          } else {
+            ""
+          }
         }).filter(_.nonEmpty)
 
         val allFeatureV1 = allFeatureMap.map {