| 19 | } |
| 20 | |
| 21 | void Merge::initLocalStateInternal(ResultSet* resultSet_, ExecutionContext* context) { |
| 22 | for (auto& executor : nodeInsertExecutors) { |
| 23 | executor.init(resultSet, context); |
| 24 | } |
| 25 | for (auto& executor : relInsertExecutors) { |
| 26 | executor.init(resultSet, context); |
| 27 | } |
| 28 | for (auto& executor : onCreateNodeSetExecutors) { |
| 29 | executor->init(resultSet, context); |
| 30 | } |
| 31 | for (auto& executor : onCreateRelSetExecutors) { |
| 32 | executor->init(resultSet, context); |
| 33 | } |
| 34 | for (auto& executor : onMatchNodeSetExecutors) { |
| 35 | executor->init(resultSet, context); |
| 36 | } |
| 37 | for (auto& executor : onMatchRelSetExecutors) { |
| 38 | executor->init(resultSet, context); |
| 39 | } |
| 40 | for (auto& evaluator : info.keyEvaluators) { |
| 41 | evaluator->init(*resultSet_, context->clientContext); |
| 42 | } |
| 43 | localState.init(*resultSet, context->clientContext, info); |
| 44 | } |
| 45 | |
| 46 | void MergeLocalState::init(ResultSet& resultSet, main::ClientContext* context, MergeInfo& info) { |
| 47 | std::vector<common::LogicalType> types; |