The Liebre SPE has been updated. Aside some code optimizations and minor bugs fixing, there are now 2 new operators: FlatMap and Router. Furthermore, back-pressure is now implemented for all sources, operators and sinks. You can find the updated documentation here and the updated code here.
Update – The Liebre Stream Processing Engine
Posted in Uncategorized