public abstract class AtomicFsDataOutputStream
extends org.apache.flink.core.fs.FSDataOutputStream
Constructor and Description |
---|
AtomicFsDataOutputStream() |
Modifier and Type | Method and Description |
---|---|
abstract void |
close()
Closes this stream.
|
abstract boolean |
closeAndCommit()
Closes the stream, ensuring persistence of all data (similar to
FSDataOutputStream.sync() ). |
write, write, write
public abstract boolean closeAndCommit() throws IOException
FSDataOutputStream.sync()
). And commits
the file, publish (make visible) the file that the stream was writing to.IOException
public abstract void close() throws IOException
In order to persist all previously written data, one needs to call the closeAndCommit()
method.
close
in interface Closeable
close
in interface AutoCloseable
close
in class org.apache.flink.core.fs.FSDataOutputStream
IOException
- Thrown if an error occurred during closing.Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.