我试图理解并通过一些关于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/ 语法似乎没问题,我不知道我做错了什么。
暂无答案!
目前还没有任何答案,快来回答吧!