We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 92ed43d commit 4b897c7Copy full SHA for 4b897c7
1 file changed
include/tpch/io_uring_output_stream.hpp
@@ -62,10 +62,10 @@ class IoUringOutputStream : public arrow::io::OutputStream {
62
/** Convenience overload accepting a Buffer. */
63
arrow::Status Write(const std::shared_ptr<arrow::Buffer>& data) override;
64
65
- /** No-op: Write() already blocks until data is on disk. */
+ /** No-op: Write() blocks until CQEs are drained (data in page cache). */
66
arrow::Status Flush() override;
67
68
- /** Stop worker thread (if running), fsync, close file fd. */
+ /** Stop worker thread (if running), close file fd. */
69
arrow::Status Close() override;
70
71
arrow::Result<int64_t> Tell() const override;
0 commit comments