|
|
@@ -38,7 +38,7 @@ object makedata_ad_31_originData_20260807 {
|
|
|
val endStr = param.getOrElse("endStr", "2024062023")
|
|
|
val savePath = param.getOrElse("savePath", "/dw/recommend/model/31_ad_sample_data/")
|
|
|
val project = param.getOrElse("project", "loghubods")
|
|
|
- val table = param.getOrElse("table", "alg_recsys_ad_sample_all")
|
|
|
+ val table = param.getOrElse("table", "alg_recsys_ad_sample_all_v3")
|
|
|
val repartition = param.getOrElse("repartition", "100").toInt
|
|
|
val filterHours = param.getOrElse("filterHours", "00,01,02,03,04,05").split(",").toSet
|
|
|
val idDefaultValue = param.getOrElse("idDefaultValue", "1.0").toDouble
|
|
|
@@ -415,11 +415,12 @@ object makedata_ad_31_originData_20260807 {
|
|
|
*/
|
|
|
|
|
|
|
|
|
- //4 处理label信息。
|
|
|
+ //4 处理label信息（v3 表 label 在 label_json 内）。
|
|
|
val labels = new JSONObject
|
|
|
+ val labelJson = getJsonObject(record, "label_json")
|
|
|
for (labelKey <- List("ad_is_click", "ad_is_conversion")) {
|
|
|
- if (!record.isNull(labelKey)) {
|
|
|
- labels.put(labelKey, record.getString(labelKey))
|
|
|
+ if (labelJson.containsKey(labelKey)) {
|
|
|
+ labels.put(labelKey, labelJson.getString(labelKey))
|
|
|
}
|
|
|
}
|
|
|
//5 处理log key表头。
|
xueyiming