Re: Join Dataset in stream

Hi Eric, This sounds like a use case for BroadcastProcessFunction You’d use the Cassandra dataset as the source for the broadcast stream, which is distrib

Join Dataset in stream

Hi. I need to compute an euclidian distance between an input Vector and a full dataset stored in Cassandra and keep the n lowest value. The Cassandra dataset is evolving (mutable). I could do this on a batch job, but i will have to triger it each time and the input are more like a slow stream, but