| 476 | ASSERT_OK((**out).ValidateFull()); |
| 477 | } |
| 478 | static void AssertReadEnd(const std::shared_ptr<StreamingReader>& reader) { |
| 479 | std::shared_ptr<RecordBatch> out; |
| 480 | ASSERT_OK(reader->ReadNext(&out)); |
| 481 | ASSERT_TRUE(IsIterationEnd(out)); |
| 482 | } |
| 483 | |
| 484 | static void AssertBatchSequenceEquals(const RecordBatchVector& expected_batches, |
| 485 | const RecordBatchVector& sequence) { |
nothing calls this directly
no test coverage detected