ScatterGatherBackingStore

Store intermediate payload in a scatter-gather scenario. Multiple threads write their payload to a backing store, which can subsequently be reversed to an InputStream to be used as input in the gather phase.

It is the responsibility of the allocator of an instance of this class to close this. Closing it should clear off any allocated structures and preferably delete files.

Since

1.10

Functions

Link copied to clipboard
abstract fun close()
Link copied to clipboard
abstract fun closeForWriting()
Closes this backing store for further writing.
Link copied to clipboard
abstract fun getInputStream(): InputStream
An input stream that contains the scattered payload
Link copied to clipboard
abstract fun writeOut(data: Array<Byte>, offset: Int, length: Int)
Writes a piece of payload.