|
@@ -6,6 +6,8 @@ import com.tzld.piaoquan.recommend.server.common.enums.AppTypeEnum;
|
|
|
import com.tzld.piaoquan.recommend.server.model.Video;
|
|
|
import com.tzld.piaoquan.recommend.server.service.flowpool.FlowPoolConstants;
|
|
|
import com.tzld.piaoquan.recommend.server.service.recall.strategy.*;
|
|
|
+import com.tzld.piaoquan.recommend.server.util.CommonCollectionUtils;
|
|
|
+import com.tzld.piaoquan.recommend.server.util.JSONUtils;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.apache.commons.collections4.CollectionUtils;
|
|
|
import org.apache.commons.lang3.StringUtils;
|
|
@@ -45,7 +47,8 @@ public class RecallService implements ApplicationContextAware {
|
|
|
|
|
|
public RecallResult recall(RecallParam param) {
|
|
|
List<RecallStrategy> strategies = getRecallStrategy(param);
|
|
|
- //log.info("strategies {}", JSONUtils.toJson(CommonCollectionUtils.toList(strategies,o -> o.getClass().getSimpleName())));
|
|
|
+ log.info("recall strategies {}", JSONUtils.toJson(CommonCollectionUtils.toList(strategies,
|
|
|
+ o -> o.getClass().getSimpleName())));
|
|
|
CountDownLatch cdl = new CountDownLatch(strategies.size());
|
|
|
List<Future<RecallResult.RecallData>> recallResultFutures = new ArrayList<>();
|
|
|
for (final RecallStrategy strategy : strategies) {
|