flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Xingcan Cui (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-8094) Support other types for ExistingField rowtime extractor
Date Fri, 17 Nov 2017 01:37:00 GMT

    [ https://issues.apache.org/jira/browse/FLINK-8094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16256294#comment-16256294

Xingcan Cui commented on FLINK-8094:

Thanks for your suggestions, [~fhueske]. I'll finish it step by step.

> 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

View raw message