| 553 | } |
| 554 | |
| 555 | Status HashJoinDictBuildMulti::PostDecode( |
| 556 | const SchemaProjectionMaps<HashJoinProjection>& proj_map, |
| 557 | ExecBatch* decoded_key_batch, ExecContext* ctx) { |
| 558 | // Post process build side keys that use dictionary |
| 559 | int num_keys = proj_map.num_cols(HashJoinProjection::KEY); |
| 560 | for (int i = 0; i < num_keys; ++i) { |
| 561 | if (needs_remap_[i]) { |
| 562 | ARROW_ASSIGN_OR_RAISE( |
| 563 | decoded_key_batch->values[i], |
| 564 | remap_imp_[i].RemapOutput(*decoded_key_batch->values[i].array(), ctx)); |
| 565 | } |
| 566 | } |
| 567 | return Status::OK(); |
| 568 | } |
| 569 | |
| 570 | void HashJoinDictProbeMulti::Init(size_t num_threads) { |
| 571 | local_states_.resize(num_threads); |
no test coverage detected