feathub icon indicating copy to clipboard operation
feathub copied to clipboard

Published 20 hours ago • verified publisher icon alibaba

Support getting map features natively with Flink

Open yunfengzhou-hub opened this issue 11 months ago • 0 comments 

# PyFlink Table#to_pandas currently doesn't support Map type. We have to collect the
# result and construct the pandas DataFrame.
# TODO: Use PyFlink Table#to_pandas after
#  https://issues.apache.org/jira/projects/FLINK/issues/FLINK-30607 is resolved.
def flink_table_to_pandas(table: NativeFlinkTable) -> pd.DataFrame:

yunfengzhou-hub avatar Sep 18 '23 01:09 yunfengzhou-hub