Filter logic for river

[mryhmln]

Hi. I am just starting to investigate using the river concept for my mongodb/elasticsearch setup. The thing that I was wondering is if it would be possible to implement a filter on the river such that it will only detect changes that meet a certain criteria, e.g. in my case I don't want elasticsearch to grab a record from my mongodb until a certain field has been set. Is there a way to accomplish this with the current way that the river is implemented? Please advise. And thanks in advance.

[richardwilly98]

This feature is available in version 1.5.0. I did not have time yet to document it but there is an example of river setting here: https://github.com/richardwilly98/elasticsearch-river-mongodb/blob/master/resources/create-mongodb-river-with-filter.json
It uses "dot notation" query available in MongoDB.

[richardwilly98]

Hi,

I am not sure if the last comment done by @egueidan is relevant to the issue.
Can you please clarify?

Thanks,
Richard.