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

Jark Wu commented on FLINK-14099:
---------------------------------

[~alfredlu] Btw, for your problem, maybe you can try this:

{code:java}
new Schema()
   .field("timestamp", Types.LONG)
  .field("rowtime", Types.SQL_TIMESTAMP)
  .rowtime(new 
Rowtime().timestampsFromField("timestamp").watermarksPeriodicAscending())
  .field("requestId", Types.STRING)
{code}


> 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