return entries.stream().filter(task -> action.equals(task.action) && nodeId.equals(task.executorNode)).count(); | return tasks.values().stream().filter(task -> action.equals(task.action) && nodeId.equals(task.executorNode)).count(); | entries | entries.values() | elasticsearch | d340c190b20f0a32275a71aca881040d753995f0 | org.elasticsearch.persistent.PersistentTasksInProgress | | | | | | Uses | True |
return entries.stream().filter(task -> action.equals(task.action) && nodeId.equals(task.executorNode)).count(); | return tasks.values().stream().filter(task -> action.equals(task.action) && nodeId.equals(task.executorNode)).count(); | entries | entries.values() | elasticsearch | a0b37a25105c5e924842b90cf3be842af3895ac7 | org.elasticsearch.xpack.persistent.PersistentTasksInProgress | | | | | | Uses | True |