|
@@ -20,6 +20,7 @@ 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
|
|
@@ -74,6 +75,10 @@ public class RecallService implements ApplicationContextAware {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+ log.info("recall result size: {}",
|
|
|
+ results.stream().collect(Collectors.toMap(RecallResult.RecallData::getPushFrom,
|
|
|
+ d -> d.getVideos().size())));
|
|
|
+
|
|
|
return new RecallResult(results);
|
|
|
}
|
|
|
|