0

「ログイン失敗」から 10 分以内に「ログイン成功」した顧客を特定する必要がある 「ログイン失敗」の Windowed KSQL TABLE を作成した

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 では、「ウィンドウ化された」テーブルを使用してストリームに参加できません

この状況の回避策はありますか?

4

1 に答える 1