Ok third question, hopefully I can get an answer here. I'm attempting to apply an outlier detection algorithm for a time window written in pandas. It's not clear to me how I should correctly introduce this into a flink stream. At first I thought I should apply this over a table window, but that use case seems targeted at aggregation. This is for removal of outliers, so is this better done as a stream with map operation over a window ?