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.
| Modifier and Type | Method and Description |
|---|---|
| public void | |
| public InputStream | Returns: An InputStream, should be closed by the caller of this method.An input stream that contains the scattered payload |
| public void | writeOut(byte[]
the data to write data, int offset inside data to start writing from offset, int the amount of data to write length)Writes a piece of payload. |
| closeForWriting | back to summary |
|---|---|
| public void closeForWriting() throws IOException Closes this backing store for further writing.
| |
| getInputStream | back to summary |
|---|---|
| public InputStream getInputStream() throws IOException An input stream that contains the scattered payload
| |
| writeOut | back to summary |
|---|---|
| public void writeOut(byte[] data, int offset, int length) throws IOException Writes a piece of payload.
| |