| 529 | } |
| 530 | |
| 531 | void CheckSimpleRoundtrip(const std::shared_ptr<Table>& table, int64_t row_group_size, |
| 532 | const std::shared_ptr<ArrowWriterProperties>& |
| 533 | arrow_writer_properties = default_arrow_writer_properties(), |
| 534 | const ArrowReaderProperties& arrow_reader_properties = |
| 535 | default_arrow_reader_properties()) { |
| 536 | std::shared_ptr<Table> result; |
| 537 | ASSERT_NO_FATAL_FAILURE( |
| 538 | DoSimpleRoundtrip(table, false /* use_threads */, row_group_size, {}, &result, |
| 539 | arrow_writer_properties, arrow_reader_properties)); |
| 540 | ::arrow::AssertSchemaEqual(*table->schema(), *result->schema(), |
| 541 | /*check_metadata=*/false); |
| 542 | ASSERT_OK(result->ValidateFull()); |
| 543 | |
| 544 | ::arrow::AssertTablesEqual(*table, *result, false); |
| 545 | |
| 546 | ASSERT_NO_FATAL_FAILURE( |
| 547 | DoRoundTripWithBatches(table, false /* use_threads */, row_group_size, {}, &result, |
| 548 | arrow_writer_properties, arrow_reader_properties)); |
| 549 | ::arrow::AssertSchemaEqual(*table->schema(), *result->schema(), |
| 550 | /*check_metadata=*/false); |
| 551 | ASSERT_OK(result->ValidateFull()); |
| 552 | |
| 553 | ::arrow::AssertTablesEqual(*table, *result, false); |
| 554 | } |
| 555 | |
| 556 | static std::shared_ptr<GroupNode> MakeSimpleSchema(const DataType& type, |
| 557 | Repetition::type repetition) { |
no test coverage detected