| 179 | } |
| 180 | |
| 181 | void PartitionedHashJoinPlanNode::Codegen(FragmentState* state) { |
| 182 | DCHECK(state->ShouldCodegen()); |
| 183 | // Codegen the children nodes. |
| 184 | PlanNode::Codegen(state); |
| 185 | if (IsNodeCodegenDisabled()) return; |
| 186 | |
| 187 | LlvmCodeGen* codegen = state->codegen(); |
| 188 | DCHECK(codegen != nullptr); |
| 189 | |
| 190 | // Codegen the build side (if integrated into this join node). |
| 191 | if (!UseSeparateBuild(state->query_options())) { |
| 192 | DCHECK(phj_builder_config_ != nullptr); |
| 193 | phj_builder_config_->Codegen(state); |
| 194 | } |
| 195 | |
| 196 | TPrefetchMode::type prefetch_mode = state->query_options().prefetch_mode; |
| 197 | AddCodegenStatus(CodegenProcessProbeBatch(codegen, prefetch_mode), "Probe Side"); |
| 198 | } |
| 199 | |
| 200 | Status PartitionedHashJoinNode::Open(RuntimeState* state) { |
| 201 | SCOPED_TIMER(runtime_profile_->total_time_counter()); |
nothing calls this directly
no test coverage detected