Package | Description |
---|---|
org.apache.flink.table.store.file.utils |
Modifier and Type | Class and Description |
---|---|
class |
RenamingAtomicFsDataOutputStream
A stream initially writes to hidden files or temp files and only creates the target file once it
is closed and "committed".
|
Modifier and Type | Method and Description |
---|---|
AtomicFsDataOutputStream |
RecoverableAtomicFileWriter.open(org.apache.flink.core.fs.Path path) |
AtomicFsDataOutputStream |
AtomicFileWriter.open(org.apache.flink.core.fs.Path path)
Opens a new atomic stream to write to the given path.
|
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.