[jira] [Created] (FLINK-6591) Extend functionality of final ConversionMapper

[Shang Yuanchun (Jira)]

Timo Walther created FLINK-6591:
-----------------------------------

             Summary: Extend functionality of final ConversionMapper
                 Key: FLINK-6591
                 URL: https://issues.apache.org/jira/browse/FLINK-6591
             Project: Flink
          Issue Type: Improvement
          Components: Table API & SQL
            Reporter: Timo Walther


The functionality of the ConversionMapper generated in {{TableEnvironment#generateRowConverterFunction}} is very limited right now:


- It does not support conversion of nested Row types, e.g. a nested Avro-record can be read with the KafkaAvroTableSource into a nested row structure, but this structure can not be converted back into a Pojo or Avro structure. The code generator needs to be extended for this.

- The Table API supports BasicTypeInfo (e.g. {{Integer[]}}) as an input field, but since it works with ObjectTypeInfo internally, it cannot output the array. I disabled the test {{TableEnvironmentITCase#testAsFromTupleToPojo}} for now.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)