| 820 | } |
| 821 | |
| 822 | Status PartitionedHashJoinNode::PrepareNullAwareNullProbe() { |
| 823 | DCHECK_EQ(null_probe_output_idx_, -1); |
| 824 | bool got_read_buffer; |
| 825 | RETURN_IF_ERROR(null_probe_rows_->PrepareForRead(true, &got_read_buffer)); |
| 826 | if (!got_read_buffer) { |
| 827 | return mem_tracker()->MemLimitExceeded( |
| 828 | runtime_state_, Substitute(PREPARE_FOR_READ_FAILED_ERROR_MSG, id_)); |
| 829 | } |
| 830 | DCHECK_EQ(probe_batch_->num_rows(), 0); |
| 831 | probe_batch_pos_ = 0; |
| 832 | null_probe_output_idx_ = 0; |
| 833 | return Status::OK(); |
| 834 | } |
| 835 | |
| 836 | Status PartitionedHashJoinNode::OutputNullAwareNullProbe( |
| 837 | RuntimeState* state, RowBatch* out_batch, bool* done) { |
nothing calls this directly
no test coverage detected