[ https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932011#comment-16932011 ]
Zijie Lu edited comment on FLINK-14099 at 9/18/19 7:52 AM: ----------------------------------------------------------- So your idea is that the rowtime is still be extracted from field and it is converted to stand SQL by using built in function in the sql statment. Do I unserstand it? *[~felixzheng] [~twalthr]* was (Author: alfredlu): 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())* Do you think this idea work? *[~felixzheng] [~twalthr]* > 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)