소스 검색

ADD: filter log

sunxy 1 년 전
부모
커밋
0452ec5cdd
1개의 변경된 파일6개의 추가작업 그리고 6개의 파일을 삭제
  1. 6 6
      recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/framework/recaller/BaseRecaller.java

+ 6 - 6
recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/framework/recaller/BaseRecaller.java

@@ -187,8 +187,8 @@ public class BaseRecaller<Video> {
             }
         }
 
-//        LOGGER.info("traceId: [{}], recall candidateQueueMap: [{}]", requestData.getRequestId(),
-//                JSONObject.toJSONString(candidateQueueMap));
+        LOGGER.info("traceId: [{}], recall candidateQueueMap: [{}]", requestData.getRequestId(),
+                JSONObject.toJSONString(candidateQueueMap));
 
         List<RankItem> result = convertToRankItem(candidateQueueMap, requestData, user);
         LOGGER.info("traceId: [{}], recall result: [{}]", requestData.getRequestId(),
@@ -215,7 +215,8 @@ public class BaseRecaller<Video> {
                 List<RankItem> candidateHits = new ArrayList<>();
                 final Candidate candidate = entry.getKey();
                 List<Entry<Video>> entriesValue = CommonCollectionUtils.iterableToList(entry.getValue());
-
+                LOGGER.info("traceId: [{}], entry.getValue: [{}], entriesValue: [{}]", requestData.getRequestId(),
+                        JSONObject.toJSONString(entry.getValue()), JSONObject.toJSONString(entriesValue));
                 try {
                     final Map<Video, Entry<Video>> entryMap = new HashMap<>();
                     List<Video> entriesList = entriesValue.stream().map(e -> {
@@ -223,9 +224,8 @@ public class BaseRecaller<Video> {
                         return e.item;
                     }).collect(Collectors.toList());
                     List<Video> entriesAfterFilter = recallFilter.doFilter(candidate, entriesList);
-                    LOGGER.info("traceId: [{}], entriesList: [{}], entriesAfterFilter: [{}]",
-                            requestData.getRequestId(), JSONObject.toJSONString(entriesList),
-                            JSONObject.toJSONString(entriesAfterFilter));
+                    LOGGER.info("traceId: [{}] entriesAfterFilter: [{}]",
+                            requestData.getRequestId(), JSONObject.toJSONString(entriesAfterFilter));
                     // 1. filter  TODO 待后续增加自定义filter
                     if (CollectionUtils.isNotEmpty(entriesAfterFilter)) {
                         List<Entry<Video>> entries = entriesAfterFilter.stream()