Hi everyone, I'd like to start a discussion about supporting conversion between PyFlink Table and Pandas DataFrame.
Pandas dataframe is the de-facto standard to work with tabular data in Python community. PyFlink table is Flink’s representation of the tabular data in Python language. It would be nice to provide the functionality to convert between the PyFlink table and Pandas dataframe in PyFlink Table API. It provides users the ability to switch between PyFlink and Pandas seamlessly when processing data in Python language without an extra intermediate connectors. Jincheng Sun and I have discussed offline and have drafted the FLIP-120[1]. Looking forward to your feedback! Regards, Dian [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-120%3A+Support+conversion+between+PyFlink+Table+and+Pandas+DataFrame
