| 878 | } |
| 879 | |
| 880 | void WriteIpcData(const std::string& path, |
| 881 | const std::shared_ptr<fs::FileSystem> file_system, |
| 882 | const std::shared_ptr<Table> input) { |
| 883 | EXPECT_OK_AND_ASSIGN(auto out_stream, file_system->OpenOutputStream(path)); |
| 884 | ASSERT_OK_AND_ASSIGN( |
| 885 | auto file_writer, |
| 886 | MakeFileWriter(out_stream, input->schema(), ipc::IpcWriteOptions::Defaults())); |
| 887 | ASSERT_OK(file_writer->WriteTable(*input)); |
| 888 | ASSERT_OK(file_writer->Close()); |
| 889 | } |
| 890 | |
| 891 | struct TestScannerParams { |
| 892 | bool use_threads; |
no test coverage detected