@@ -67,6 +67,7 @@ object pred_recsys_61_xgb_nor_hdfsfile_20241209 {
sc.textFile(testPath),
features
)
+ println("recsys nor:test data size:" + testData.count())
val testDataSet = spark.createDataFrame(testData, schema)
val testDataSetTrans = vectorAssembler.transform(testDataSet).select("features", "label", "logKey", "scoresMap")