debug.slurp() function

debug.slurp() will read the incoming tables and concatenate buffers with the same group key into a single in memory table buffer. This is useful for testing the performance impact of multiple buffers versus a single buffer.

Function type signature
(<-tables: stream[A]) => stream[A] where A: Record

For more information, see Function type signatures.



Stream to consume into single buffers per table.

Was this page helpful?

Thank you for your feedback!

The future of Flux

Flux is going into maintenance mode. You can continue using it as you currently are without any changes to your code.

Read more