|
@@ -1,4 +1,5 @@
|
|
|
package com.tzld.piaoquan.recommend.server.service.recall;
|
|
|
+
|
|
|
import com.ctrip.framework.apollo.spring.annotation.ApolloJsonValue;
|
|
|
import com.tzld.piaoquan.recommend.server.common.ThreadPoolFactory;
|
|
|
import com.tzld.piaoquan.recommend.server.common.enums.AppTypeEnum;
|
|
@@ -20,7 +21,6 @@ import java.util.concurrent.CountDownLatch;
|
|
|
import java.util.concurrent.ExecutorService;
|
|
|
import java.util.concurrent.Future;
|
|
|
import java.util.concurrent.TimeUnit;
|
|
|
-import java.util.stream.Collectors;
|
|
|
|
|
|
/**
|
|
|
* @author dyp
|
|
@@ -75,9 +75,9 @@ public class RecallService implements ApplicationContextAware {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- log.info("recall result size: {}",
|
|
|
- results.stream().collect(Collectors.toMap(RecallResult.RecallData::getPushFrom,
|
|
|
- d -> d.getVideos().size())));
|
|
|
+// log.info("recall result size: {}",
|
|
|
+// results.stream().collect(Collectors.toMap(RecallResult.RecallData::getPushFrom,
|
|
|
+// d -> d.getVideos().size())));
|
|
|
|
|
|
return new RecallResult(results);
|
|
|
}
|