ksql连接和时间

rbpvctlc  于 2021-06-08  发布在  Kafka
关注(0)|答案(1)|浏览(273)

我需要识别那些在“失败登录”后10分钟内“成功登录”的客户我创建了一个包含“失败登录”的窗口ksql表

CREATE TABLE table_Rule200_FailedLogins WITH (TIMESTAMP='LOGDATE') AS \
SELECT CUSTID,LOGDATE,LOGIP \
FROM STREAM_DEMO_EXTRACTED \
WINDOW TUMBLING (SIZE 10 MINUTES) \
WHERE Successful_Login = 'FALSE' AND LogType = '39' \
GROUP BY CUSTID,LOGDATE,LOGIP;

我创建了一个“成功登录”流

CREATE STREAM stream_Rule200_SuccessLogins as \
select * \
FROM STREAM_DEMO_EXTRACTED WHERE LogType = '39' AND Successful_Login = 'TRUE';

ksql不允许我加入带有“窗口”表的流
这种情况有解决办法吗?

yr9zkbsy

yr9zkbsy1#

你说的是做一个流连接,它目前在ksql中不可用(但即将推出)。
现在,您需要使用Kafka流来实现这一点。

相关问题