I'm evaluating for some processing batches of data. As a simple example say I have 2000 points which I would like to pass through an FIR filter using functionality provided by the Python scipy libraryjk. The scipy filter is a simple function which accepts a set of coefficients and the data to filter and returns the data. Is is possible to create a transformation to handle this in flink? It seems flink transformations are applied on a point by point basis but I may be missing something.
Paul
