kafka ksql翻滚窗口

svgewumm  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(244)

我试图理解并通过一些关于ksql的例子来工作。我的本地计算机上安装了confluent community edition(6.0.0)。
我有下表中的ksql

sql> DESCRIBE TUMB;

Name                 : TUMB
 Field    | Type                           
-------------------------------------------
 EMAIL    | VARCHAR(STRING)  (primary key) 
 AMOUNT   | DOUBLE                         
 CURRENCY | VARCHAR(STRING)

我正在使用python producer来生成这个主题/表中的数据

CREATE TABLE pageviews_per_region_per_minute AS
>  SELECT CURRENCY,
>         COUNT(*)
>  FROM TUMB
>  WINDOW TUMBLING (SIZE 1 MINUTE)
>  GROUP BY CURRENCY
>  EMIT CHANGES;

我得到了一个错误-“表聚合不支持窗口化。”
我在youtube上查了这个视频https://www.youtube.com/watch?v=2fuoi9wjphk 做了同样的事情,但没有错误。我在上查看了ksql文档https://docs.ksqldb.io/en/latest/developer-guide/aggregate-streaming-data/ 语法似乎没问题,我不知道我做错了什么。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题