召回改造

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/service/recall/strategy/RegionRealtimeRecallStrategyV1.java

@@ -53,7 +53,7 @@ public class RegionRealtimeRecallStrategyV1 implements RecallStrategy {
 
 
         long t1 = new Long(System.currentTimeMillis());
-        int chunkSize = 20;
+        int chunkSize = 25;
         List<List<Long>> groupedKeys = groupKeys(videoMap, chunkSize);
         List<Long> videoids = new ArrayList<>();
         for (List<Long> tmp : groupedKeys){

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/service/recall/strategy/RegionRealtimeRecallStrategyV3.java

@@ -1,5 +1,6 @@
 package com.tzld.piaoquan.recommend.server.service.recall.strategy;
 
+import com.alibaba.fastjson.JSONObject;
 import com.google.common.collect.Lists;
 import com.tzld.piaoquan.recommend.server.model.Video;
 import com.tzld.piaoquan.recommend.server.service.filter.FilterParam;
@@ -48,10 +49,15 @@ public class RegionRealtimeRecallStrategyV3 implements RecallStrategy {
         for (Pair<Long, Double> v: result){
             videoMap.put(v.getLeft(), v.getRight());
         }
-
+        long t1 = new Long(System.currentTimeMillis());
         FilterParam filterParam = FilterParamFactory.create(param, Lists.newArrayList(videoMap.keySet()));
         filterParam.setForceTruncation(10000);
         FilterResult filterResult = filterService.filter(filterParam);
+        long t2 = new Long(System.currentTimeMillis());
+        JSONObject obj = new JSONObject();
+        obj.put("name", "RegionRealtimeRecallStrategyV3");
+        obj.put("filter_time", t2-t1);
+        log.info(obj.toString());
         List<Video> videosResult = new ArrayList<>();
         if (filterResult != null && CollectionUtils.isNotEmpty(filterResult.getVideoIds())) {
             filterResult.getVideoIds().stream().forEach(vid -> {

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/service/score4recall/strategy/RegionRecallScorerV1.java

@@ -30,7 +30,7 @@ public class RegionRecallScorerV1 extends AbstractScorer4Recall {
             lists = model.kv.getOrDefault("中国", new ArrayList<>());
         }
 
-        return lists.subList(0, Math.min(100, lists.size()));
+        return lists.subList(0, Math.min(75, lists.size()));
     }
 
 

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/service/score4recall/strategy/RegionRecallScorerV3.java

@@ -30,7 +30,7 @@ public class RegionRecallScorerV3 extends AbstractScorer4Recall {
             lists = model.kv.getOrDefault("中国", new ArrayList<>());
         }
 
-        return lists.subList(0, Math.min(100, lists.size()));
+        return lists.subList(0, Math.min(75, lists.size()));
     }