search

ariskk / flink4s

Scala 3.x wrapper for Apache Flink
MIT License
49 stars 10 forks source link

Add biflatmap #24

Closed Wosin closed 1 year ago

Wosin commented 1 year ago

Simple idea to add FlatMap the same way we have Map to connected streams to allow us to perform both filtering and mapping at the same time.

ariskk commented 1 year ago

sbt scalafmt is needed

ariskk commented 1 year ago

Please squash commits to a single "Implement biFlatMap"