public static final class MemoryStateBackend.MemoryCheckpointOutputStream extends AbstractStateBackend.CheckpointStateOutputStream
Constructor and Description |
---|
MemoryCheckpointOutputStream(int maxSize) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
byte[] |
closeAndGetBytes()
Closes the stream and returns the byte array containing the stream's data.
|
StreamStateHandle |
closeAndGetHandle()
Closes the stream and gets a state handle that can create an input stream
producing the data written to this stream.
|
void |
write(byte[] b,
int off,
int len) |
void |
write(int b) |
flush, write
public void write(int b)
write
in class OutputStream
public void write(byte[] b, int off, int len)
write
in class OutputStream
public void close()
close
in interface Closeable
close
in interface AutoCloseable
close
in class OutputStream
public StreamStateHandle closeAndGetHandle() throws IOException
AbstractStateBackend.CheckpointStateOutputStream
closeAndGetHandle
in class AbstractStateBackend.CheckpointStateOutputStream
IOException
- Thrown, if the stream cannot be closed.public byte[] closeAndGetBytes() throws IOException
IOException
- Thrown if the size of the data exceeds the maximalCopyright © 2014–2017 The Apache Software Foundation. All rights reserved.