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 as we speak. Hopefully it will work out. 😊
On Wed, 30 Mar, 2022, 8:02 am Xingbo Huang, <hxbks...@gmail.com> wrote: > Hi, > > Are you using datastream api or table api？If you are using the table api, > you can use the connector by executing sql[1]. If you are using the > datastream api, there is really no es connector api provided, you need to > write python wrapper code, but the wrapper code is very simple. The > underlying code takes use of py4j to call the java api of es connector. For > details, you can refer to the wrapper code in kafka or pulsar[2]. > > [1] > https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/connectors/table/overview/ > [2] > https://github.com/apache/flink/blob/master/flink-python/pyflink/datastream/connectors.py > > Best, > Xingbo > > Sandeep Sharat <sandeepsha...@gmail.com> 于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. But due to a >> recent policy change we are moving towards the python api for flink, >> however we were unable to find any python elastic search connectors 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 >> >
