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

Zijie Lu commented on FLINK-14099:
----------------------------------

Maybe we can add a parameter in the function timestampFromField with its 
timestamp format and convert it to the stand SQL timestamp.

The code looks like this:

*new Schema()*
*.field("rowtime", Types.SQL_TIMESTAMP)*
*.rowtime(new Rowtime().timestampsFromField("timestamp", 
"timestampFormat").watermarksPeriodicAscending())*

> SQL supports timestamp in Long
> ------------------------------
>
>                 Key: FLINK-14099
>                 URL: https://issues.apache.org/jira/browse/FLINK-14099
>             Project: Flink
>          Issue Type: New Feature
>            Reporter: Zijie Lu
>            Priority: Major
>
> The rowtime only supports sql timestamp but not long. Can the rowtime field 
> supports long?



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to