flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-8094) Support other types for ExistingField rowtime extractor
Date Wed, 04 Jul 2018 21:11:00 GMT

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

ASF GitHub Bot commented on FLINK-8094:

Github user HeartSaVioR commented on the issue:

    If we would like to answer 1 as "Yes, apply the change to ExistingField.", we can rebase
this PR with below branch. 
    Thanks to @xccui I can copy the test code from his POC commit in above branch.

> 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 &amp; SQL
>    Affects Versions: 1.4.0, 1.5.0
>            Reporter: Xingcan Cui
>            Priority: Major
>              Labels: pull-request-available
> 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