我对ksql很陌生，只是想知道如何提取今天的数据进行聚合？假设我有以下模式的计数数据流：
Field | Type
-----------------------------
ROWTIME | BIGINT
ROWKEY | VARCHAR(STRING)
TS | BIGINT
COUNT | BIGINT如何创建一个表来输出今天的 COUNT 哪里 TS unix时间戳是否使用ksql？
我对ksql很陌生，只是想知道如何提取今天的数据进行聚合？假设我有以下模式的计数数据流：
Field | Type
-----------------------------
ROWTIME | BIGINT
ROWKEY | VARCHAR(STRING)
TS | BIGINT
COUNT | BIGINT如何创建一个表来输出今天的 COUNT 哪里 TS unix时间戳是否使用ksql？
1条答案
按热度按时间a14dhokn1#
你可以用
TIMESTAMPTOSTRING自定义项以更改TS值转换为所需的日期格式，然后执行求和。有一种方法：CREATE STREAM mystream1 AS SELECT TIMESTAMPTOSTRING(TS, 'yyyy-MM-dd') AS TS, COUNT_VAL FROM mystream;```SELECT TS, sum(COUNT_VAL) FROM mystream1 GROUP BY TS;