JD557 commented on issue #1141: URL: https://github.com/apache/incubator-pekko/issues/1141#issuecomment-1960037460
For reference, here are some benchmarks (based on the original ZIO Streams benchmarks): https://gist.github.com/JD557/251467aac30860dca88dc3e697dfb381 You can quickly run them with Scala CLI with `scala-cli --power --jmh https://gist.github.com/JD557/251467aac30860dca88dc3e697dfb381` Here I compare an implementation using `scan`+`mapConcat` (`pekkoScan`), `statefulMapConcat` (`pekkoStatefulMapConcat`) and `statefulMap`+`mapConcat` (pekkoStatefulMapMapConcat) The tests were run on an Apple M3 Max, using OpenJDK 21.0.2+13-LTS Results: ``` Benchmark (chunkSize) (cols) (rows) Mode Cnt Score Error Units CSVStreamBenchmarks.pekkoScan 5000 100 100 thrpt 5 27.785 ± 0.080 ops/s CSVStreamBenchmarks.pekkoStatefulMapConcat 5000 100 100 thrpt 5 72.419 ± 0.308 ops/s CSVStreamBenchmarks.pekkoStatefulMapMapConcat 5000 100 100 thrpt 5 42.094 ± 0.744 ops/s ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: notifications-unsubscr...@pekko.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: notifications-unsubscr...@pekko.apache.org For additional commands, e-mail: notifications-h...@pekko.apache.org
