| 1082 | } |
| 1083 | |
| 1084 | bool PartitionedHashJoinNode::AppendProbeRowSlow( |
| 1085 | BufferedTupleStream* stream, TupleRow* row, Status* status) { |
| 1086 | if (!status->ok()) return false; // Check if AddRow() set status. |
| 1087 | *status = runtime_state_->StartSpilling(mem_tracker()); |
| 1088 | if (!status->ok()) return false; |
| 1089 | *status = stream->UnpinStream(BufferedTupleStream::UNPIN_ALL_EXCEPT_CURRENT); |
| 1090 | if (!status->ok()) return false; |
| 1091 | return stream->AddRow(row, status); |
| 1092 | } |
| 1093 | |
| 1094 | Status PartitionedHashJoinNode::EvaluateNullProbe( |
| 1095 | RuntimeState* state, BufferedTupleStream* build) { |
nothing calls this directly
no test coverage detected