Of(id))
.source(json));
Cheers,
Hung
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Upserts-with-Flink-elasticsearch-tp5767p5829.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
gt; .type(type)
>> .id(element)
>> .source(json);
>> }
>>
>> Best,
>>
>> Sendoh
>>
>>
>>
>> --
>> View this message in context:
>> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Upserts-with-Flink-elasticsearch-tp5767p5787.html
>> Sent from the Apache Flink User Mailing List archive. mailing list
>> archive at Nabble.com.
>>
>
.index(index)
> .type(type)
> .id(element)
> .source(json);
> }
>
> Best,
>
> Sendoh
>
>
>
> --
> View this message in context:
> http://apache-flink-user-mailing-list-archive.2336050.n4.nabbl
ssage in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Upserts-with-Flink-elasticsearch-tp5767p5787.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
Would it be useful to modify the existing Elasticsearch 1x sink to be able
to handle Upserts ?
On Mon, Mar 28, 2016 at 5:32 PM, Zach Cox wrote:
> Hi Madhukar - with the current Elasticsearch sink in Flink 1.0.0 [1], I
> don't think an upsert is possible, since IndexRequestBuilder can only
> ret
Hi Madhukar - with the current Elasticsearch sink in Flink 1.0.0 [1], I
don't think an upsert is possible, since IndexRequestBuilder can only
return an IndexRequest.
In Flink 1.1, the Elasticsearch 2.x sink [2] provides a RequestIndexer [3]
that you can pass an UpdateRequest to do an upsert.
Than
Is it possible to do Upsert with existing flink-elasticsearch connector
today?
