Hi, Nida.
About using connector with Java by Flink DataStream api, you can mainly
reference these doc[1][2].
However, Elaticsearch connector only supports sink currently. What you need it
to build a custom ES
connector with that patch[3] yourself. The following steps may help you.
1. Downlo
Hi Xuyang
I am new to Flink & I don't know how to implement this dependency into the
code.
Can you please share some examples so that I can refer those.
Thanks
Nida
On Fri, Mar 22, 2024 at 7:02 AM Xuyang wrote:
> Hi, Nida.
> Can you explain more details about "unable to use it." ? Did you get
Hi, Nida.
Can you explain more details about "unable to use it." ? Did you get an
exception after using it?
--
Best！
Xuyang
在 2024-03-21 21:14:53，"Fidea Lidea" 写道：
Thank you Xuyang.
I added the above flink-connector-elasticsearch dependency in my project.
But I am unable to use
Thank you Xuyang.
I added the above flink-connector-elasticsearch dependency in my project.
But I am unable to use it.
Can you please share a few sample codes which are using this dependency?
Thanks
Nida
On Tue, Mar 12, 2024 at 5:37 PM Xuyang wrote:
> Hi, Fidea.
> Currently, elasticsearch is no
Hi ,
I am trying to read data from elasticsearch & store in a stream.
Could you please share a few examples to *read*/get all data from
Elasticsearch using java.
Thanks,
