Browse Source

add time feature

jch 3 months ago
parent
commit
3f914eef30

+ 3 - 3
src/main/scala/com/aliyun/odps/spark/examples/makedata_recsys_r_rate/makedata_recsys_61_originData_20241209.scala

@@ -94,12 +94,12 @@ object makedata_recsys_61_originData_20241209 {
                 val share = if (b_2.isEmpty) 0D else b_2.getIntValue("share_pv_" + prefix2).toDouble
                 val returns = if (b_3.isEmpty) 0D else b_3.getIntValue("return_uv_" + prefix2).toDouble
                 val f0 = RankExtractorFeature_20240530.calLog(exp)
-                val f1 = RankExtractorFeature_20240530.smoothDiv(share, exp, smoothPlus)
+                val f1 = RankExtractorFeature_20240530.calDiv(share, exp)
                 val f2 = RankExtractorFeature_20240530.calLog(share)
-                val f3 = RankExtractorFeature_20240530.smoothDiv(returns, exp, smoothPlus)
+                val f3 = RankExtractorFeature_20240530.calDiv(returns, exp)
                 val f4 = RankExtractorFeature_20240530.calLog(returns)
                 val f5 = f3 * f4
-                val f6 = RankExtractorFeature_20240530.smoothDiv(returns, share, smoothPlus)
+                val f6 = RankExtractorFeature_20240530.calDiv(returns, share)
                 featureMap.put(prefix1 + "_" + prefix2 + "_" + "EXP", f0)
                 featureMap.put(prefix1 + "_" + prefix2 + "_" + "STR", f1)
                 featureMap.put(prefix1 + "_" + prefix2 + "_" + "log(share)", f2)