| 220 | } |
| 221 | |
| 222 | void NestedLoopJoinNode::ResetForProbe() { |
| 223 | DCHECK(build_batches_ != NULL); |
| 224 | build_row_iterator_ = build_batches_->Iterator(); |
| 225 | current_build_row_idx_ = 0; |
| 226 | matched_probe_ = false; |
| 227 | } |
| 228 | |
| 229 | Status NestedLoopJoinNode::GetNext( |
| 230 | RuntimeState* state, RowBatch* output_batch, bool* eos) { |