Not able to compare two loops in a chain query

[richcollier]

I've already recommended in a different thread that you should look at this post for ideas:

Comparing values from 2 ML Jobs in watcher

Ok - after a little research, this could be done in probably two ways Method 1 - a script on the condition to see if there's an intersection of results from both queries "condition": { "script": "def second_results = ctx.payload.second.hits.hits.stream().map(hit->hit._source.partition_field_value).collect(Collectors.toList()); return ctx.payload.first.hits.hits.stream().map(hit -> hit._source.partition_field_value).filter(p->second_results.contains(p)).collect(Collectors.toList()).si…

Why do you keep on asking? I'm confused...