ksql连接和时间

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

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

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

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

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

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

yr9zkbsy

yr9zkbsy1#

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

相关问题