| 810 | } |
| 811 | |
| 812 | void PartitionedHashJoinNode::OutputBuildRow( |
| 813 | RowBatch* out_batch, TupleRow* build_row, RowBatch::Iterator* out_batch_iterator) { |
| 814 | DCHECK(build_row != nullptr); |
| 815 | if (join_op_ == TJoinOp::RIGHT_ANTI_JOIN) { |
| 816 | out_batch->CopyRow(build_row, out_batch_iterator->Get()); |
| 817 | } else { |
| 818 | CreateOutputRow(out_batch_iterator->Get(), nullptr, build_row); |
| 819 | } |
| 820 | } |
| 821 | |
| 822 | Status PartitionedHashJoinNode::PrepareNullAwareNullProbe() { |
| 823 | DCHECK_EQ(null_probe_output_idx_, -1); |