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