| 53 | : rows_to_send_(rows_to_send), rows_to_skip_(rows_to_skip) {} |
| 54 | |
| 55 | Page NextPage(const ExecBatch& batch) { |
| 56 | int64_t rows_in_batch_to_skip = 0; |
| 57 | if (rows_to_skip_ > 0) { |
| 58 | rows_in_batch_to_skip = std::min(rows_to_skip_, batch.length); |
| 59 | rows_to_skip_ -= rows_in_batch_to_skip; |
| 60 | } |
| 61 | |
| 62 | int64_t rows_in_batch_to_send = 0; |
| 63 | if (rows_to_send_ > 0) { |
| 64 | rows_in_batch_to_send = |
| 65 | std::min(rows_to_send_, batch.length - rows_in_batch_to_skip); |
| 66 | rows_to_send_ -= rows_in_batch_to_send; |
| 67 | } |
| 68 | return {rows_in_batch_to_skip, rows_in_batch_to_send, rows_to_send_ == 0}; |
| 69 | } |
| 70 | |
| 71 | private: |
| 72 | int64_t rows_to_send_; |