| 302 | opt_selected_read_indices); |
| 303 | } |
| 304 | void AssertArrayWriteReadEqual(const std::shared_ptr<Array>& input_array, |
| 305 | const std::shared_ptr<Array>& expected_output_array, |
| 306 | const int64_t max_size = kDefaultSmallMemStreamSize) { |
| 307 | std::shared_ptr<Schema> input_schema = schema({field("col0", input_array->type())}), |
| 308 | output_schema = |
| 309 | schema({field("col0", expected_output_array->type())}); |
| 310 | auto input_chunked_array = std::make_shared<ChunkedArray>(input_array), |
| 311 | expected_output_chunked_array = |
| 312 | std::make_shared<ChunkedArray>(expected_output_array); |
| 313 | std::shared_ptr<Table> input_table = Table::Make(input_schema, {input_chunked_array}), |
| 314 | expected_output_table = |
| 315 | Table::Make(output_schema, {expected_output_chunked_array}); |
| 316 | AssertTableWriteReadEqual(input_table, expected_output_table, max_size); |
| 317 | } |
| 318 | |
| 319 | void SchemaORCWriteReadTest(const std::shared_ptr<Schema>& schema, int64_t size, |
| 320 | int64_t min_num_chunks, int64_t max_num_chunks, |