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
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' -H
'Content-Type: application/json' -d'
{
"name": "Jane Doe"
}
'
In my case I have json like this:
{
"filters" : {
Hi,
I'm using Flink and Elasticsearch and I want to recieve in elasticsearch a
json object ({"id":1, "name":"X"} ect...), I already have a string with
this information, but I don't want to save it as string.
I recieve this:
{
"_index": "logs",
"_type": "object",
"_id":
