[jira] [Created] (FLINK-18180) unify the logic of time attribute derivation for both batch and streaming

[Shang Yuanchun (Jira)]

godfrey he created FLINK-18180:
----------------------------------

             Summary: unify the logic of time attribute derivation for both batch and streaming
                 Key: FLINK-18180
                 URL: https://issues.apache.org/jira/browse/FLINK-18180
             Project: Flink
          Issue Type: Improvement
          Components: Table SQL / Planner
            Reporter: godfrey he


Currently, the logic of time attribute derivation is different for batch and streaming. For batch table source, the rowtime type will not be generated or will be erased as regular time type if the source table has rowtime type. To handle this difference, we have to distinguish batch or streaming via {{isStreamingMode}} flag in many places, such as: {{DatabaseCalciteSchema}}, {{CatalogSchemaTable}}, {{CatalogTableSchemaResolver}}, etc. In fact, batch queries may also need rowtime type, such as supporting rowtime temporal join. So we can unify the logic of time attribute derivation from the source side, and erase the rowtime type if need in optimization phase. And then it's easier to push the unified {{TableEnvironment}} and planner forward.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)