Hi,
Yes, your reasoning is correct. If you use two binary joins, the data of
the first two streams will be buffered twice.
Unioning all three streams and joining them in a custom ProcessFunction
would reduce the amount of required state.
Best, Fabian
Am Sa., 24. Nov. 2018 um 14:08 Uhr schrieb Ga
Hi,
I want to do window join on multiple Kafka streams (say a, b, c) on common
field in all 3 streams and apply some custom function on joined stream. As
I understand we can join only 2 streams at a time via DataStream api. So
may be I need to join a and b first and then join first joined stream wi
