feathub
feathub copied to clipboard
Support getting map features natively with Flink
# 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: