public class RecoverableAtomicFileWriter extends Object implements AtomicFileWriter
AtomicFileWriter
to wrap RecoverableWriter
.Constructor and Description |
---|
RecoverableAtomicFileWriter(org.apache.flink.core.fs.RecoverableWriter recoverableWriter) |
Modifier and Type | Method and Description |
---|---|
AtomicFsDataOutputStream |
open(org.apache.flink.core.fs.Path path)
Opens a new atomic stream to write to the given path.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
create, writeFileUtf8, writeFileUtf8
public RecoverableAtomicFileWriter(org.apache.flink.core.fs.RecoverableWriter recoverableWriter)
public AtomicFsDataOutputStream open(org.apache.flink.core.fs.Path path) throws IOException
AtomicFileWriter
open
in interface AtomicFileWriter
IOException
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.