| 121 | ASSERT_GT(num_batches, num_pass); // must have more batches after pausing |
| 122 | auto t_schema = schema({field("time", int32()), field("value", int32())}); |
| 123 | ASSERT_OK_AND_ASSIGN(auto t_batches, |
| 124 | MakeIntegerBatches({[](int row) -> int64_t { return row; }, |
| 125 | [](int row) -> int64_t { return row + 1; }}, |
| 126 | t_schema, num_batches, batch_size)); |
| 127 |
no outgoing calls
no test coverage detected