| 118 | const auto kNullConsumer = std::make_shared<acero::NullSinkNodeConsumer>(); |
| 119 | |
| 120 | void WriteIpcData(const std::string& path, |
| 121 | const std::shared_ptr<fs::FileSystem> file_system, |
| 122 | const std::shared_ptr<Table> input) { |
| 123 | EXPECT_OK_AND_ASSIGN(auto out_stream, file_system->OpenOutputStream(path)); |
| 124 | ASSERT_OK_AND_ASSIGN( |
| 125 | auto file_writer, |
| 126 | MakeFileWriter(out_stream, input->schema(), ipc::IpcWriteOptions::Defaults())); |
| 127 | ASSERT_OK(file_writer->WriteTable(*input)); |
| 128 | ASSERT_OK(file_writer->Close()); |
| 129 | } |
| 130 | |
| 131 | void CheckRoundTripResult(const std::shared_ptr<Table> expected_table, |
| 132 | std::shared_ptr<Buffer>& buf, |
no test coverage detected