File tree Expand file tree Collapse file tree 1 file changed +3
-8
lines changed Expand file tree Collapse file tree 1 file changed +3
-8
lines changed Original file line number Diff line number Diff line change 2626#include < arrow/table.h>
2727#include < arrow/type.h>
2828#include < arrow/util/key_value_metadata.h>
29- #include < iceberg/arrow_c_data_guard_internal.h>
3029#include < iceberg/file_reader.h>
3130#include < iceberg/file_writer.h>
3231#include < iceberg/result.h>
@@ -51,15 +50,11 @@ namespace {
5150
5251Status WriteTable (std::shared_ptr<::arrow::Array> data,
5352 const WriterOptions& writer_options) {
54- ArrowArray arr;
55- ICEBERG_ARROW_RETURN_NOT_OK (::arrow::ExportArray (*data, &arr));
56-
5753 ICEBERG_ASSIGN_OR_RAISE (
5854 auto writer, WriterFactoryRegistry::Open (FileFormatType::kParquet , writer_options));
59- {
60- internal::ArrowArrayGuard guard (&arr);
61- ICEBERG_RETURN_UNEXPECTED (writer->Write (arr));
62- }
55+ ArrowArray arr;
56+ ICEBERG_ARROW_RETURN_NOT_OK (::arrow::ExportArray (*data, &arr));
57+ ICEBERG_RETURN_UNEXPECTED (writer->Write (arr));
6358 return writer->Close ();
6459}
6560
You can’t perform that action at this time.
0 commit comments