??????
????????flink1.10.1,??????????????????????????????????????????????????????=????????-??????????????????????????????????????????????????????????????????????????????????????
SELECT
| DATE_FORMAT(TIMESTAMPADD(HOUR, 8, HOP_START(proctime, INTERVAL '$slide'
SECOND, INTERVAL '$size' MINUTE)), 'yyyy-MM-dd HH:mm:ss') start_time,
| UNIX_TIMESTAMP(DATE_FORMAT(TIMESTAMPADD(HOUR, 8, HOP_START(proctime,
INTERVAL '$slide' SECOND, INTERVAL '$size' MINUTE)), 'yyyy-MM-dd HH:mm:ss')) *
1000 AS `time`,
| CAST(COUNT(distinct drive_id) AS INT) num
| FROM
| ${databaseName}.log_stream
| WHERE
| req_type = '1' and navigation_flag=' '
| GROUP BY
| HOP(proctime, INTERVAL '$slide' SECOND, INTERVAL '$size' MINUTE)
3> 2021-01-15 13:43:20,1610689400000,1
4> 2021-01-15 13:43:30,1610689410000,2
1> 2021-01-15 13:43:40,1610689420000,3
2> 2021-01-15 13:43:50,1610689430000,3
3> 2021-01-15 13:44:00,1610689440000,3
4> 2021-01-15 13:44:10,1610689450000,3
1> 2021-01-15 13:44:20,1610689460000,3
2> 2021-01-15 13:44:30,1610689470000,3
3> 2021-01-15 13:44:40,1610689480000,3
4> 2021-01-15 13:44:50,1610689490000,3
1> 2021-01-15 13:45:00,1610689500000,3
2> 2021-01-15 13:45:10,1610689510000,3
3> 2021-01-15 13:45:20,1610689520000,3
