Skip to content
  • Ottomata's avatar
    Finish conversions for pyflink and python native types · 45e10298
    Ottomata authored and Gmodena's avatar Gmodena committed
    * Finish conversions for pyflink and python native types
    
    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
    45e10298
Loading