eyal farago
eyal farago
Hi, currently the BloomFilter and its buffer are not serializable, can this be added? same goes for kryo support, can be added with an optional dependency (I've actually already implemented...
I'm using the library with Apache-Spark, specifically I'm optimizing a sparse join by creating a bloom filter per partition, this required wrapping the bloom filter instances with a class that...
Guava already has this as part of its interface
I've encountered this failure on my local env (saw it once, wasn't able to reproduce): ```scala - ZStreamSpec / Combinators / tapSink / does not read ahead - 5 ms...
initial benchmark results: ``` Benchmark (chunkCount) (chunkSize) (parChunkSize) Mode Cnt Score Error Units StreamParBenchmark.zioMapPar 10000 5000 50 thrpt 15 0.194 ± 0.031 ops/s StreamParBenchmark.zioMapParUnordered 10000 5000 50 thrpt 15 0.202...
I've introduced a benchmark for `flatMapPar`, initial results: ``` Benchmark (chunkCount) (chunkSize) (parChunkSize) Mode Cnt Score Error Units StreamParBenchmark.akkaFlatMapPar 10000 5000 50 thrpt 15 1.208 ± 0.011 ops/s StreamParBenchmark.fs2FlatMapPar 10000...
I was able to introduce such an implicit in my code, I believe it belongs in zio.test: ```scala implicit def zioSuiteConstructor[R, R1, E
revisited recent optimizations done in #8819 in face of the technique used to optimize `ZStream.flatMapPar` in #8863. basic idea is to significantly reduce the number of forked fibers: 1. employ...
modify Server layers such that they expose the Driver, this is required in order to be able to share resources between http server and client in the same application. see...