flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Timo Walther (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-6591) Extend functionality of final ConversionMapper
Date Mon, 15 May 2017 15:00:06 GMT
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

View raw message