flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Suneel Marthi <smar...@apache.org>
Subject Re: Upserts with Flink-elasticsearch
Date Mon, 28 Mar 2016 22:53:56 GMT
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 <zcox522@gmail.com> 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
> 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