Hi Jiabao & Jiadong,
Could you please share examples on how to "*update*" data using
ElasticsearchSink?
Thanks
On Mon, Jan 29, 2024 at 9:07 PM Jiabao Sun <jiabao....@xtransfer.cn> wrote:
> Hi Fidea,
>
> I found some examples in the Java documentation, and I hope they can be
> helpful.
>
> private static class TestElasticSearchSinkFunction implements
> ElasticsearchSinkFunction<Tuple2<Integer, String>> {
> public IndexRequest createIndexRequest(Tuple2<Integer, String>
> element) {
> Map<String, Object> json = new HashMap<>();
> json.put("data", element.f1);
> return Requests
> .indexRequest()
> .index("my-index")
> .type("my-type")
> .id(element.f0.toString())
> .source(json);
> }
>
> public void process(
> Tuple2<Integer, String> element,
> RuntimeContext ctx,
> RequestIndexer indexer) {
> indexer.add(createIndexRequest(element));
> }
> }
>
> But as jiadong mentioned, ElasticsearchSinkFunction is no longer
> recommended for use.
>
> Best,
> Jiabao
>
>
> On 2024/01/29 11:15:43 Fidea Lidea wrote:
> > Hi Team,
> >
> > Could you please share with me a few example codes on how to perform
> > "updaterequest on elasticsearch using apache flink"
> > I.want to use ElasticsearchSinkFunction to perform updaterequest.
> >
> > Thanks
> > Nida Shaikh
> > lideafidea...@gmail.com
> >
