RabbitMQ River->Bulk API:Delete or DeleteByQuery?

Hi folks,

I'm using the RabbitMQ River to bulk index some feed data, but I can't seem to work out how to do a deletebyquery first, or an upsert like in mongodb. The main issue is I don't have an id for each record, but three very strong fields that make a good update key for our model. Is there a preferred way of approaching bulk upserts in ES?



Had a quick look at the code today, and found the answer:

package org.elasticsearch.client.action.bulk only implements support for DeleteRequest, not DeleteByQuery.

Oh well. :frowning: