Dawid Wysakowicz created FLINK-12799:
----------------------------------------
Summary: Improve expression based TableSchema extraction from DataStream/DataSet
Key: FLINK-12799
URL:
https://issues.apache.org/jira/browse/FLINK-12799 Project: Flink
Issue Type: Sub-task
Reporter: Dawid Wysakowicz
Assignee: Dawid Wysakowicz
Fix For: 1.9.0
We should improve the extraction of {{TableSchema}} from {{DataStream/DataSet}}. Currently it is split into two stages:
# We extract types ignoring time attributes via {{FieldInfoUtils#getFieldInfo}}
# We extract rowtime and proctime positions via {{StreamTableEnvImpl#validateAndExtractTimeAttributes}}
# We adjust indices from #1 using information from #2
All that could happen in a single pass. This will also deal with porting/removing few methods from {{StreamTableEnvImpl}}.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)