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-7446) Support to define an existing field as the rowtime field for TableSource
Date Fri, 18 Aug 2017 14:49:00 GMT

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

Xingcan Cui commented on FLINK-7446:
------------------------------------

Thanks for the response, [~fhueske]. From my perspective, I prefer the later option (create
new interfaces/operators...). Maybe we can provide one or more default watermark generators.
Users can directly set them by providing some parameters (e.g., the watermark interval and
the expected delay to the latest rowtime). Moreover, if the provided watermark generators
can not meet the requirements, users can implement their own ones. What do you think, [~jark]?

> Support to define an existing field as the rowtime field for TableSource
> ------------------------------------------------------------------------
>
>                 Key: FLINK-7446
>                 URL: https://issues.apache.org/jira/browse/FLINK-7446
>             Project: Flink
>          Issue Type: Improvement
>          Components: Table API & SQL
>            Reporter: Jark Wu
>            Assignee: Jark Wu
>
> Currently {{DefinedRowtimeAttribute}} can define an appended rowtime field for a {{TableSource}}.
But it would be helpful if we can support to define an existing field as the rowtime field.
Just like registering a DataStream, the rowtime field can be appended but also can replace
an existing field.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Mime
View raw message