public static final class FsCheckpointStreamFactory.FsCheckpointStateOutputStream extends CheckpointStreamFactory.CheckpointStateOutputStream
CheckpointStreamFactory.CheckpointStateOutputStream
that writes into a file and
returns a StreamStateHandle
upon closing.Constructor and Description |
---|
FsCheckpointStateOutputStream(Path basePath,
FileSystem fs,
int bufferSize,
int localStateThreshold) |
Modifier and Type | Method and Description |
---|---|
void |
close()
If the stream is only closed, we remove the produced file (cleanup through the auto close
feature, for example).
|
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()
Checks whether the stream is closed.
|
void |
sync() |
void |
write(byte[] b,
int off,
int len) |
void |
write(int b) |
write
public FsCheckpointStateOutputStream(Path basePath, FileSystem fs, int bufferSize, int localStateThreshold)
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 long getPos() throws IOException
getPos
in class FSDataOutputStream
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 boolean isClosed()
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.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.