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)
