| 123 | }; |
| 124 | |
| 125 | Result<std::shared_ptr<FileWriter>> OpenWriter( |
| 126 | const FileSystemDatasetWriteOptions& write_options, std::shared_ptr<Schema> schema, |
| 127 | const std::string& filename) { |
| 128 | ARROW_ASSIGN_OR_RAISE(std::shared_ptr<io::OutputStream> out_stream, |
| 129 | write_options.filesystem->OpenOutputStream(filename)); |
| 130 | return write_options.format()->MakeWriter(std::move(out_stream), std::move(schema), |
| 131 | write_options.file_write_options, |
| 132 | {write_options.filesystem, filename}); |
| 133 | } |
| 134 | |
| 135 | class DatasetWriterFileQueue |
| 136 | : public std::enable_shared_from_this<DatasetWriterFileQueue> { |
no test coverage detected