public static final class FsStateBackend.FsCheckpointStateOutputStream extends AbstractStateBackend.CheckpointStateOutputStream
Constructor and Description |
---|
FsCheckpointStateOutputStream(Path basePath,
FileSystem fs,
HashSet<FsStateBackend.FsCheckpointStateOutputStream> openStreams,
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.
|
Path |
closeAndGetPath()
Closes the stream and returns the path to the file that contains the stream's data.
|
boolean |
equals(Object obj) |
void |
flush() |
int |
hashCode() |
boolean |
isClosed() |
void |
write(byte[] b,
int off,
int len) |
void |
write(int b) |
write
public FsCheckpointStateOutputStream(Path basePath, FileSystem fs, HashSet<FsStateBackend.FsCheckpointStateOutputStream> openStreams, 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 void flush() throws IOException
flush
in interface Flushable
flush
in class OutputStream
IOException
public void close()
Throwable
.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 Path closeAndGetPath() throws IOException
IOException
- Thrown if the stream cannot be successfully closed.public boolean isClosed()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.