Implement aggregate on windows.

ariskk / flink4s

Scala 3.x wrapper for Apache Flink

MIT License

49 stars 10 forks source link

Open Wosin opened 1 year ago

Wosin commented 1 year ago

Attempt to implement aggregate on windows using Monoid for some simplicity.

I'm not too convinced about using the Monoid there so I'm happy to discuss that.

ariskk commented 1 year ago

sbt scalafmt is needed

Wosin commented 1 year ago

Converting to Draft as I need to think a little bout how to model that best.