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)

Reply via email to