| 469 | } |
| 470 | |
| 471 | void CheckReadResult(const RecordBatch& result, const RecordBatch& expected) { |
| 472 | ASSERT_OK(result.ValidateFull()); |
| 473 | EXPECT_EQ(expected.num_rows(), result.num_rows()); |
| 474 | |
| 475 | ASSERT_TRUE(expected.schema()->Equals(*result.schema())); |
| 476 | ASSERT_EQ(expected.num_columns(), result.num_columns()) |
| 477 | << expected.schema()->ToString() << " result: " << result.schema()->ToString(); |
| 478 | |
| 479 | CompareBatchColumnsDetailed(result, expected); |
| 480 | } |
| 481 | |
| 482 | void CheckRoundtrip(const RecordBatch& batch, |
| 483 | IpcWriteOptions options = IpcWriteOptions::Defaults(), |
nothing calls this directly
no test coverage detected