[jira] [Created] (FLINK-8094) Support other types for ExistingField rowtime extractor

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-8094) Support other types for ExistingField rowtime extractor

Shang Yuanchun (Jira)
Xingcan Cui created FLINK-8094:
----------------------------------

             Summary: Support other types for ExistingField rowtime extractor
                 Key: FLINK-8094
                 URL: https://issues.apache.org/jira/browse/FLINK-8094
             Project: Flink
          Issue Type: Improvement
          Components: Table API & SQL
    Affects Versions: 1.4.0, 1.5.0
            Reporter: Xingcan Cui


Currently, the {{ExistingField}} rowtime extractor only supports {{Long}} and {{Timestamp}} fields. To enable other data types (e.g., {{String}}), we can provide some system extraction functions and allow users to pass some parameters via the constructor of {{ExistingField}}. There's [a simple demo|https://github.com/xccui/flink/commit/afcc5f1a0ad92db08294199e61be5df72c1514f8] which enables the {{String}} type rowtime by adding a UDF {{str2EventTime}}.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)