Re: Data Type of timestamp in Streaming SQL Result? Long instead of timestamp?

Posted by chrisr123 on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Data-Type-of-timestamp-in-Streaming-SQL-Result-Long-instead-of-timestamp-tp21065p21075.html

Thank you Hequn,
I got it working. Here is the tumbling window query, in both SQL and Table
API.
I'm getting same results with these:



SQL API
tableEnvironment.registerDataStream("pageViews", eventStream,
"pageViewTime.rowtime, username, url");
String continuousQuery =
    "SELECT TUMBLE_END(pageViewTime, INTERVAL '1' MINUTE) as wend, " +
    "username, COUNT(url) as viewcount FROM pageViews " +
    "GROUP BY TUMBLE(pageViewTime, INTERVAL '1' MINUTE), username";
Table  windowedTable = tableEnvironment.sqlQuery(continuousQuery);



TABLE API
Table dynamicTable = tableEnvironment.fromDataStream(eventStream,
"pageViewTime.rowtime, username, url");
Table windowedTable = dynamicTable
    .window(Tumble.over("1.minutes").on("pageViewTime").as("tumblewindow"))
    .groupBy("tumblewindow, username")
    .select("tumblewindow.end as wend,username,url.count as viewcount");




--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/