flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Xingcan Cui (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-8094) Support other types for ExistingField rowtime extractor
Date Thu, 16 Nov 2017 15:25:00 GMT
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)

Mime
View raw message