|
@@ -138,7 +138,6 @@ public class BaseRecaller<Video> {
|
|
|
QueueName name = candidate.getCandidateQueueName();
|
|
|
Queue<Video> entries = queues.get(name);
|
|
|
if (queues.containsKey(name) && entries != null) {
|
|
|
- entries.limit(candidate.getCandidateNum());
|
|
|
candidateQueueMap.put(candidate, entries);
|
|
|
}
|
|
|
}
|
|
@@ -240,7 +239,7 @@ public class BaseRecaller<Video> {
|
|
|
if (CollectionUtils.isNotEmpty(entriesAfterFilter)) {
|
|
|
List<Entry<Video>> entries = entriesAfterFilter.stream()
|
|
|
.limit(candidate.getCandidateNum())
|
|
|
- .map(e -> entryMap.get(e))
|
|
|
+ .map(entryMap::get)
|
|
|
.collect(Collectors.toList());
|
|
|
// 2. toHits
|
|
|
candidateHits.addAll(toHits(entries, candidate));
|