我在confluent-5.0.0中出错。 ksql>CREATE TABLE order_per_hour AS SELECT after->order_id,count(*) FROM transaction WINDOW SESSION(60 seconds) GROUP BY after->order_id; 名称为空
错误名称为空
后面是schema中的struct字段。不带分组依据的简单select查询工作正常。
我在confluent-5.0.0中出错。 ksql>CREATE TABLE order_per_hour AS SELECT after->order_id,count(*) FROM transaction WINDOW SESSION(60 seconds) GROUP BY after->order_id; 名称为空
错误名称为空
后面是schema中的struct字段。不带分组依据的简单select查询工作正常。
2条答案
按热度按时间jqjz2hbq1#
我已经在这里提交了一个pr来添加对ksql的支持https://github.com/confluentinc/ksql/pull/2076
希望这有帮助，
安迪
ovfsdjhp2#
当前只能在中使用列名
GROUP BY条款。作为解决方法，您可以按以下方式编写查询：CREATE STREAM foo AS SELECT after->order_id as o_id FROM transaction;
CREATE TABLE order_per_hour AS SELECT o_id,count(*) FROM foo WINDOW SESSION(60 seconds) GROUP BY o_id;