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

Attach files

Attach Screenshot

Voters

Watch issue

Watchers

Link

Clone

Update Comment Author

Replace String in Comment

Update Comment Visibility

Delete Comments

XML

Word

Printable

JSON

Details

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

Release Note:

Hide
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.

Show
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.

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.