...
- Defines a length window that keeps 1 event of the input stream PurchaseStream.
- Joins it with the CardUserTable with the condition p.cardNo == c.cardNum and c.blacklisted == false. In this condition, the events with blacklisted == true in the table gets filtered out and then the remaining events will be joined based on the card number.
- Emits those events as output events through the TransformedRoomTempStreamthe WhiteListPurchaseStream.
| Code Block |
|---|
from DeleteAllUsers delete CardUserTable on deleteAll == true; |
...