We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent e5b15dc commit f20d89bCopy full SHA for f20d89b
1 file changed
src/iceberg/arrow/arrow_io.cc
@@ -530,8 +530,12 @@ Result<std::shared_ptr<::arrow::io::OutputStream>> OpenArrowOutputStream(
530
}
531
532
ICEBERG_ASSIGN_OR_RAISE(auto output_file, io->NewOutputFile(path));
533
- ICEBERG_ASSIGN_OR_RAISE(
534
- auto output, overwrite ? output_file->CreateOrOverwrite() : output_file->Create());
+ std::unique_ptr<PositionOutputStream> output;
+ if (overwrite) {
535
+ ICEBERG_ASSIGN_OR_RAISE(output, output_file->CreateOrOverwrite());
536
+ } else {
537
+ ICEBERG_ASSIGN_OR_RAISE(output, output_file->Create());
538
+ }
539
return std::make_shared<OutputStreamAdapter>(std::move(output));
540
541
0 commit comments