Skip to content

Finish conversions for pyflink and python native types

Ottomata requested to merge pyflink_python_conversion into main

We previously only implemented conversion between PyFlink Rows and python dicts. We'd prefer not to expose any of the PyFlink types if we can help it. This change implements:

  • Conversion of PyFlink Instants to python datetimes
  • Conversion of any container type (Row, Array, Tuple) that might contain a Row or datetime

Bug: T349640

Merge request reports