str和ros扩展新特征

src/main/scala/com/aliyun/odps/spark/examples/makedata_recsys/makedata_recsys_41_str2ros_originData_20241209.scala

@@ -188,12 +188,12 @@ object makedata_recsys_41_str2ros_originData_20241209 {
               val return_ = if (featData.isEmpty) 0D else featData.getIntValue("return_" + period).toDouble
               val view_hasreturn = if (featData.isEmpty) 0D else featData.getIntValue("view_hasreturn_" + period).toDouble
               val share_hasreturn = if (featData.isEmpty) 0D else featData.getIntValue("share_hasreturn_" + period).toDouble
-              val ros = if (featData.isEmpty) 0D else featData.getIntValue("ros_" + period).toDouble
-              val rov = if (featData.isEmpty) 0D else featData.getIntValue("rov_" + period).toDouble
-              val r_cnt = if (featData.isEmpty) 0D else featData.getIntValue("r_cnt_" + period).toDouble
-              val r_rate = if (featData.isEmpty) 0D else featData.getIntValue("r_rate_" + period).toDouble
-              val r_cnt4s = if (featData.isEmpty) 0D else featData.getIntValue("r_cnt4s_" + period).toDouble
-              val str = if (featData.isEmpty) 0D else featData.getIntValue("str_" + period).toDouble
+              val ros = if (featData.isEmpty) 0D else featData.getDoubleValue("ros_" + period)
+              val rov = if (featData.isEmpty) 0D else featData.getDoubleValue("rov_" + period)
+              val r_cnt = if (featData.isEmpty) 0D else featData.getDoubleValue("r_cnt_" + period)
+              val r_rate = if (featData.isEmpty) 0D else featData.getDoubleValue("r_rate_" + period)
+              val r_cnt4s = if (featData.isEmpty) 0D else featData.getDoubleValue("r_cnt4s_" + period)
+              val str = if (featData.isEmpty) 0D else featData.getDoubleValue("str_" + period)
               // scale
               val view_s = RankExtractorFeature_20240530.calLog(view)
               val share_s = RankExtractorFeature_20240530.calLog(share)