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)