public static class MemCheckpointStreamFactory.MemoryCheckpointOutputStream extends CheckpointStreamFactory.CheckpointStateOutputStream
CheckpointStateOutputStream
that writes into a byte array.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 |
flush() |
long |
getPos() |
boolean |
isClosed() |
void |
sync() |
void |
write(byte[] b,
int off,
int len) |
void |
write(int b) |
write
public void write(int b) throws IOException
write
in class OutputStream
IOException
public void write(byte[] b, int off, int len) throws IOException
write
in class OutputStream
IOException
public void flush() throws IOException
flush
in interface Flushable
flush
in class FSDataOutputStream
IOException
public void sync() throws IOException
sync
in class FSDataOutputStream
IOException
public void close()
close
in interface Closeable
close
in interface AutoCloseable
close
in class OutputStream
public StreamStateHandle closeAndGetHandle() throws IOException
CheckpointStreamFactory.CheckpointStateOutputStream
closeAndGetHandle
in class CheckpointStreamFactory.CheckpointStateOutputStream
IOException
- Thrown, if the stream cannot be closed.public long getPos() throws IOException
getPos
in class FSDataOutputStream
IOException
public boolean isClosed()
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.