| 1198 | } |
| 1199 | |
| 1200 | Status BufferedTupleStream::ReadIterator::InitReadPtrs() { |
| 1201 | DCHECK(read_page_->is_pinned()); |
| 1202 | DCHECK_EQ(read_page_rows_returned_, 0); |
| 1203 | const BufferHandle* read_buffer; |
| 1204 | RETURN_IF_ERROR(read_page_->GetBuffer(&read_buffer)); |
| 1205 | read_ptr_ = read_buffer->data(); |
| 1206 | read_end_ptr_ = read_ptr_ + read_buffer->len(); |
| 1207 | return Status::OK(); |
| 1208 | } |
| 1209 | |
| 1210 | void BufferedTupleStream::ReadIterator::IncrRowsReturned(int64_t rows) { |
| 1211 | rows_returned_ += rows; |