| 498 | ASSERT_OK((**out).ValidateFull()); |
| 499 | } |
| 500 | static void AssertReadEnd(const std::shared_ptr<StreamingReader>& reader) { |
| 501 | std::shared_ptr<RecordBatch> out; |
| 502 | ASSERT_OK(reader->ReadNext(&out)); |
| 503 | ASSERT_TRUE(IsIterationEnd(out)); |
| 504 | } |
| 505 | |
| 506 | static void AssertBatchSequenceEquals(const RecordBatchVector& expected_batches, |
| 507 | const RecordBatchVector& sequence) { |
nothing calls this directly
no test coverage detected