You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "vinoyang (JIRA)" <ji...@apache.org> on 2018/07/16 15:57:00 UTC

[jira] [Assigned] (FLINK-9863) Add a built-in ingestion time TS extractor

     [ https://issues.apache.org/jira/browse/FLINK-9863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

vinoyang reassigned FLINK-9863:
-------------------------------

    Assignee: vinoyang

> Add a built-in ingestion time TS extractor
> ------------------------------------------
>
>                 Key: FLINK-9863
>                 URL: https://issues.apache.org/jira/browse/FLINK-9863
>             Project: Flink
>          Issue Type: New Feature
>          Components: Table API &amp; SQL
>    Affects Versions: 1.6.0
>            Reporter: Timo Walther
>            Assignee: vinoyang
>            Priority: Major
>
> There are cases where ingestion time is also useful in the Table & SQL API. As an example see FLINK-9857 and the linked mailing list discussion there. We should provide an ingestion time timestamps extractor in {{org.apache.flink.table.sources.tsextractors}}.
> The following classes should be updated as welll:
> - org.apache.flink.table.descriptors.Rowtime
> - org.apache.flink.table.descriptors.RowtimeValidator
> - org.apache.flink.table.descriptors.SchemaValidator#deriveRowtimeAttributes



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)