??????flink sql ??????????????

Tue, 02 Jun 2020 19:14:46 -0700 

Hi
    ????????????????????????????????group by????????


select floor_day_hour_5minutes(timestamp), count(1)
from source table
group by floor_day_hour_5minutes(timestamp)


????sql????retract????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????


https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/streaming/query_configuration.html


Best,
Yichao Yang


------------------ ???????? ------------------
??????:&nbsp;"steven chen"<[email protected]&gt;;
????????:&nbsp;2020??6??3??(??????) ????0:02
??????:&nbsp;"[email protected]"<[email protected]&gt;;

????:&nbsp;flink sql ??????????????



 hi ??
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
????????????????????????????????????????????5????30??????????flink sql 
??????????????????????????????
????????????5????????????????????????????????????????????????????????????????????????????????????????18:02
 ??????+1+1 
????????????18:00-18:05????????????????+1??????????????????????????????????sink 
??mysql .30??????5??????????flink sql ??????????

????????
{ts: 2019-12-10 16:24:00 id: 1}
{ts: 2019-12-10 16:22:00 id: 1}
{ts: 2019-12-10 16:23:00 id: 2}
{ts: 2019-12-10 16:21:00 id: 1}
{ts: 2019-12-10 16:29:00 id: 2}
{ts: 2019-12-10 16:27:00 id: 3}
{ts: 2019-12-10 16:26:00 id: 2}







&nbsp;

回复