flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Zach Cox <zcox...@gmail.com>
Subject Re: Upserts with Flink-elasticsearch
Date Mon, 28 Mar 2016 21:32:34 GMT
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.

Thanks,
Zach

[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.0/apis/streaming/connectors/elasticsearch.html
[2]
https://ci.apache.org/projects/flink/flink-docs-master/apis/streaming/connectors/elasticsearch2.html
[3]
https://ci.apache.org/projects/flink/flink-docs-master/api/java/org/apache/flink/streaming/connectors/elasticsearch2/RequestIndexer.html


On Mon, Mar 28, 2016 at 2:18 PM Madhukar Thota <madhukar.thota@gmail.com>
wrote:

> Is it possible to do Upsert with existing flink-elasticsearch connector
> today?
>

Mime
View raw message