| 506 | } |
| 507 | |
| 508 | void Reset(BatchParam const& param) override { |
| 509 | if (proxy_) { |
| 510 | TryLockGuard guard{single_threaded_}; |
| 511 | iter_.Reset(); |
| 512 | } |
| 513 | SparsePageSourceImpl::Reset(param); |
| 514 | |
| 515 | TryLockGuard guard{single_threaded_}; |
| 516 | this->base_row_id_ = 0; |
| 517 | } |
| 518 | }; |
| 519 | |
| 520 | /** |
no test coverage detected