public interface ScatterGatherBackingStore extends Closeable
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 |
|---|---|
void |
closeForWriting()
Closes this backing store for further writing.
|
InputStream |
getInputStream()
An input stream that contains the scattered payload
|
void |
writeOut(byte[] data,
int offset,
int length)
Writes a piece of payload.
|
InputStream getInputStream() throws IOException
IOException - when something failsvoid writeOut(byte[] data, int offset, int length) throws IOException
data - the data to writeoffset - offset inside data to start writing fromlength - the amount of data to writeIOException - when something failsvoid closeForWriting() throws IOException
IOException - when something failsCopyright © 2016 The Apache Software Foundation. All rights reserved.