str和ros扩展新特征

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

@@ -183,11 +183,11 @@ object makedata_recsys_41_str2ros_originData_20241209 {
           )
           for ((featType, featPeriod, featData) <- vidStatFeat) {
             for (period <- featPeriod) {
-              val view = if (featData.isEmpty) 0D else featData.getIntValue("view_" + period).toDouble
-              val share = if (featData.isEmpty) 0D else featData.getIntValue("share_" + period).toDouble
-              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 view = if (featData.isEmpty) 0D else featData.getDoubleValue("view_" + period)
+              val share = if (featData.isEmpty) 0D else featData.getDoubleValue("share_" + period)
+              val return_ = if (featData.isEmpty) 0D else featData.getDoubleValue("return_" + period)
+              val view_hasreturn = if (featData.isEmpty) 0D else featData.getDoubleValue("view_hasreturn_" + period)
+              val share_hasreturn = if (featData.isEmpty) 0D else featData.getDoubleValue("share_hasreturn_" + period)
               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)