Hi Yaroslav,
I think your approach is correct. Union is perfect to implement multiway
joins if you normalize the type of all streams before. It can simply be
a composite type with the key and a member variable for each stream
where only one of those variables is not null. A keyed process funct
Hello everyone,
I have a question about implementing a join of N datastreams (where N > 2)
without any time guarantees. According to my requirements, late data is not
tolerable, so if I have a join between stream A and stream B and a message
with key X arrives in stream B one year after arriving i
