我需要识别那些在“失败登录”后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不允许我加入带有“窗口”表的流
这种情况有解决办法吗?
1条答案
按热度按时间yr9zkbsy1#
你说的是做一个流连接,它目前在ksql中不可用(但即将推出)。
现在,您需要使用Kafka流来实现这一点。