Mailing-List: contact user-help@flink.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@flink.apache.org
MIME-Version: 1.0
References: 
 <CAFNkWkZQLdA-HapezofD+DoPOK_T2-AHRdntsi6zKRAPHxgkhQ@mail.gmail.com>
In-Reply-To: 
 <CAFNkWkZQLdA-HapezofD+DoPOK_T2-AHRdntsi6zKRAPHxgkhQ@mail.gmail.com>
From: Zach Cox <zcox522@gmail.com>
Date: Mon, 28 Mar 2016 21:32:34 +0000
Message-ID: 
 <CANjo42yfZ0x=bFEgA3eo95pWE0qiNn7K2Mt4TJ9BbJ3p+0Vqaw@mail.gmail.com>
Subject: Re: Upserts with Flink-elasticsearch
To: user@flink.apache.org
Content-Type: multipart/alternative; boundary=001a113ecfc03e0c36052f22a73a

--001a113ecfc03e0c36052f22a73a
Content-Type: text/plain; charset=UTF-8

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?
>

--001a113ecfc03e0c36052f22a73a
Content-Type: text/html; charset=UTF-8
Content-Transfer-Encoding: quoted-printable

<div dir=3D"ltr">Hi Madhukar - with the current Elasticsearch sink in Flink=
 1.0.0 [1], I don&#39;t think an upsert is possible, since IndexRequestBuil=
der can only return an IndexRequest.<div><br></div><div>In Flink 1.1, the E=
lasticsearch 2.x sink [2] provides a RequestIndexer [3] that you can pass a=
n UpdateRequest to do an upsert.</div><div><br></div><div>Thanks,</div><div=
>Zach</div><div><div><br></div><div>[1]=C2=A0<a href=3D"https://ci.apache.o=
rg/projects/flink/flink-docs-release-1.0/apis/streaming/connectors/elastics=
earch.html">https://ci.apache.org/projects/flink/flink-docs-release-1.0/api=
s/streaming/connectors/elasticsearch.html</a></div><div>[2]=C2=A0<a href=3D=
"https://ci.apache.org/projects/flink/flink-docs-master/apis/streaming/conn=
ectors/elasticsearch2.html">https://ci.apache.org/projects/flink/flink-docs=
-master/apis/streaming/connectors/elasticsearch2.html</a></div><div>[3]=C2=
=A0<a href=3D"https://ci.apache.org/projects/flink/flink-docs-master/api/ja=
va/org/apache/flink/streaming/connectors/elasticsearch2/RequestIndexer.html=
">https://ci.apache.org/projects/flink/flink-docs-master/api/java/org/apach=
e/flink/streaming/connectors/elasticsearch2/RequestIndexer.html</a></div></=
div><div><br></div></div><br><div class=3D"gmail_quote"><div dir=3D"ltr">On=
 Mon, Mar 28, 2016 at 2:18 PM Madhukar Thota &lt;<a href=3D"mailto:madhukar=
.thota@gmail.com">madhukar.thota@gmail.com</a>&gt; wrote:<br></div><blockqu=
ote class=3D"gmail_quote" style=3D"margin:0 0 0 .8ex;border-left:1px #ccc s=
olid;padding-left:1ex"><div dir=3D"ltr">Is it possible to do Upsert with ex=
isting flink-elasticsearch connector today?</div>
</blockquote></div>

--001a113ecfc03e0c36052f22a73a--