You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/05/15 15:00:06 UTC
[jira] [Created] (FLINK-6591) Extend functionality of final
ConversionMapper
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)