Hi,
The Flink Elasticsearch Sink uses the Elasticsearch Java client to send the
indexing requests, so whatever the client supports, it will be achievable
through the `ElasticsearchSinkFunction` also.
From a quick check at the Elasticsearch Javadocs, I think you can also just set
the document j
Hi,
thanks for the reply.
There isn't other way to do that?
Using REST you can send json like this :
curl -XPOST 'localhost:9200/customer/external?pretty&pretty' -H
'Content-Type: application/json' -d'
{
"name": "Jane Doe"
}
'
In my case I have json like this:
{
"filters" : {
Hi,
I’ll use your code to explain.
public IndexRequest createIndexRequest(String element){
HashMap esJson = new HashMap<>();
esJson.put("data", element);
What you should do here is parse the field values from `element`, and simply
tre
