jch 1 месяц назад
Родитель
Сommit
db358e754c
1 измененных файлов с 1 добавлено и 0 удалено
  1. 1 0
      src/main/scala/com/aliyun/odps/spark/examples/myUtils/ConvertV1.java

+ 1 - 0
src/main/scala/com/aliyun/odps/spark/examples/myUtils/ConvertV1.java

@@ -23,6 +23,7 @@ public class ConvertV1 {
 
 
             // context
             // context
             FeatureTransformV1.getContextFeature(currentMs, behaviorMs, total, featMap);
             FeatureTransformV1.getContextFeature(currentMs, behaviorMs, total, featMap);
+            featMap.put("weight", weight);
 
 
             // cate1
             // cate1
             Map<String, String> cate1_stat = ConvertUtils.getRecordCol(record, "cate1_stat");
             Map<String, String> cate1_stat = ConvertUtils.getRecordCol(record, "cate1_stat");