Hi Subash,
Unfortunately you can not reference a DataStream (loop) within a Flink
operator. To handle both casual and feedback data I suggest using
CoOperators. Have a look at this mockup I did some time ago for a
conceptually similar problem. [1]
[1]
https://github.com/streamline-eu/ML-Pipelines
Hello all,
I have been trying to read the stock data as a stream and perform outlier
detection upon it.
My problem is mainly due to the absence of 'withBroadcastSet()' in
DataStream API I used global variable and DataStreamUtils to read the
variable *loop*.
But I get cast exceptions and others. Co
