|
@@ -88,7 +88,8 @@ public class RankStrategy4RegionMergeModelV552 extends RankStrategy4RegionMergeM
|
|
|
Map<String, Map<String, String>> featureOriginUser = feature.getUserFeature();
|
|
|
Map<String, Map<String, Map<String, String>>> featureOriginVideo = feature.getVideoFeature();
|
|
|
|
|
|
- log.info("batch get feature cost={}", stopwatch.elapsed(TimeUnit.MILLISECONDS));
|
|
|
+ log.info("batch get feature videosize={} cost={}", rovRecallRank.size(),
|
|
|
+ stopwatch.elapsed(TimeUnit.MILLISECONDS));
|
|
|
stopwatch.reset().start();
|
|
|
|
|
|
// 2 特征处理
|
|
@@ -165,6 +166,8 @@ public class RankStrategy4RegionMergeModelV552 extends RankStrategy4RegionMergeM
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+ log.info("handle feature 1 cost={}", rovRecallRank.size(),
|
|
|
+ stopwatch.elapsed(TimeUnit.MILLISECONDS));
|
|
|
|
|
|
List<RankItem> rankItems = CommonCollectionUtils.toList(rovRecallRank, RankItem::new);
|
|
|
for (RankItem item : rankItems) {
|
|
@@ -264,6 +267,9 @@ public class RankStrategy4RegionMergeModelV552 extends RankStrategy4RegionMergeM
|
|
|
item.featureMapDouble = featureMap;
|
|
|
}
|
|
|
|
|
|
+ log.info("handle feature 2 cost={}", stopwatch.elapsed(TimeUnit.MILLISECONDS));
|
|
|
+ stopwatch.reset().start();
|
|
|
+
|
|
|
// 3 连续值特征分桶
|
|
|
readBucketFile();
|
|
|
Map<String, String> userFeatureMap = new HashMap<>(userFeatureMapDouble.size());
|
|
@@ -297,7 +303,7 @@ public class RankStrategy4RegionMergeModelV552 extends RankStrategy4RegionMergeM
|
|
|
item.featureMap = featureMap;
|
|
|
}
|
|
|
|
|
|
- log.info("handle feature cost={}", stopwatch.elapsed(TimeUnit.MILLISECONDS));
|
|
|
+ log.info("bucket feature cost={}", stopwatch.elapsed(TimeUnit.MILLISECONDS));
|
|
|
stopwatch.reset().start();
|
|
|
|
|
|
// 3 排序
|