Dominik Wosiński

Add benchmark to compare WeakConcurrentBag with Mutable Set.

1

This is part of https://github.com/zio/zio/issues/6852. We should be able to use benchmark to optimize WeakConcurrentBag.

Zio 2 support

1

# Description PR to update ZIO version to 2.0.0 and and do all the necessary code changes to reflect that. # Checklist ## Pull Request * [ X] PR description...

This fixes #7260. The problem described in the issue is related to the fact that in Scala 3, logicall `&&` and `||` are both mapped to `AndThen` case class. This...

This is pretty much just bringing back what was already defined for CE 2. I didn't wanted to split that into multiple classes to make it the same as it's...

StreamSerializer fails on compositeTypes and rowTypes

2

In ```StreamSchema``` there are methods ```isRowType()``` and is ```isCompositeType()```. But they are not used in ```StreamSerializer```, which makes it impossible to create SiddhiStream for those types.

Implement aggregate on windows.

2

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.

Currently, we have sort plan that should be able to handle ascending sorting by single column. The idea is to extend the implementation so that it allows sorting by multiple...

Just as with `WHERE` we gonna need `HAVING` to be able to support some of the TPC-H queries.