Glad to announce release of trembita 0.8.0-SNAPSHOT!
New version contains a new big features - Input/Output DSL .
This feature is inspired by Akka 's Source/Sink DSL and Spark structured streaming .
You can now manage your data pipeline more easily moving data from input into several outputs using into , alsoInto and keep[Right, Left, Both] | ignore (for all pipelines and special keepMat for akka pipelines to keep Source 's materialized value).
You can find updated examples here
From now trembita is released under new group id - ua.pp.itkpi and managed by functional operations team (or just #funcops).
Feel free to try it out.
Contributors are still welcome =)
1 Like