[FLINK-12799] Improve expression based TableSchema extraction from DataStream/DataSet

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.9.0
• Component/s: Table SQL / API, Table SQL / Legacy Planner
• Labels: pull-request-available
• Assignee: Dawid Wysakowicz
• Reporter: Dawid Wysakowicz
• Created: 11/Jun/19 07:32
• Updated: 17/Jun/19 12:10
• Resolved: 13/Jun/19 11:33

Description

We should improve the extraction of TableSchema from DataStream/DataSet. Currently it is split into a few stages:

1. Extract types ignoring time attributes via FieldInfoUtils#getFieldInfo
2. Extract the rowtime and proctime positions via StreamTableEnvImpl#validateAndExtractTimeAttributes
3. Adjust the indices from #1 using information from #2

All that could happen in a single pass. This will also deal with the porting/removing of a few methods from StreamTableEnvImpl.

Issue Links

• links to: GitHub Pull Request #8685