flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Paul Joireman <paul.joire...@physiq.com>
Subject flink batch data processing
Date Fri, 22 Jul 2016 17:21:29 GMT
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

Mime
View raw message