flink4s
flink4s copied to clipboard
Implement aggregate on windows.
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.
sbt scalafmt is needed
Converting to Draft as I need to think a little bout how to model that best.