[FLINK-20613] Update TableResult.collect()/TableResult.print() to the new type system

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.13.0
• Component/s: Table SQL / API
• Labels: pull-request-available

Release Note

Table.execute().collect() might return slightly different results for column types and row kind. The most important differences include:
* Structured types are represented as POJOs of the original class and not Row anymore.
* Raw types are serialized according to the configuration in TableConfig.

• Assignee: Timo Walther
• Reporter: Timo Walther
• Created: 15/Dec/20 13:48
• Updated: 28/May/21 09:09
• Resolved: 16/Apr/21 15:07

Description

Currently, TableResult.collect()/TableResult.print() use old sink interfaces and old type system. Those methods are very important in the API and should be updated.

Issue Links

• links to: GitHub Pull Request #15588