|
@@ -496,10 +496,10 @@ public class RankService {
|
|
|
|
|
|
// 3 进行密度控制
|
|
|
Set<Long> videosSet = result.stream().map(r-> r.getVideoId()).collect(Collectors.toSet());
|
|
|
- rovRecallRank = rovRecallRank.stream().filter(r -> !videosSet.contains(r.getVideoId())).collect(Collectors.toList());
|
|
|
- flowPoolRank = flowPoolRank.stream().filter(r -> !videosSet.contains(r.getVideoId())).collect(Collectors.toList());
|
|
|
+ List<Video> rovRecallRankNew = rovRecallRank.stream().filter(r -> !videosSet.contains(r.getVideoId())).collect(Collectors.toList());
|
|
|
+ List<Video> flowPoolRankNew = flowPoolRank.stream().filter(r -> !videosSet.contains(r.getVideoId())).collect(Collectors.toList());
|
|
|
List<Video> resultWithDnsity = RankProcessorDensity.mergeDensityControl(result,
|
|
|
- rovRecallRank, flowPoolRank, densityRules);
|
|
|
+ rovRecallRankNew, flowPoolRankNew, densityRules);
|
|
|
return new RankResult(resultWithDnsity);
|
|
|
}
|
|
|
|