unsubscribe
--
Thanks & Regards
Sandeep Sharat Kumar
gt; haven't any custom wrapper code. You can use PyFlink Table API to connect
> ES and convert Table to DataStream. When you use Table API.
>
> https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/dev/table/data_stream_api/
>
> Beat,
> LuNing Wang
>
>
> San
use cases regarding the elasticsearch use the table api to achieve it??
On Wed, 30 Mar, 2022, 9:58 am Sandeep Sharat,
wrote:
> Hi,
>
> Thank you for the quick responses. We are using the datastream api for
> pyflink. We are trying to implement a wrapper in python for the same a
flink/datastream/connectors.py
>
> Best,
> Xingbo
>
> Sandeep Sharat 于2022年3月29日周二 20:51写道：
>
>> Hello Everyone,
>>
>> I have been working on a streaming application using elasticsearch as the
>> sink. I had achieved it using the java api quite easily. Bu
for
flink. We were able to find support for the kafka connectors in python.
Does it mean that we have to write our own connectors in python to
make use of the flink-elasticsearch connector jar?
Thanks in advance
--
Thanks & Regards
Sandeep Sharat Kumar
