| 4 | namespace processor { |
| 5 | |
| 6 | void PatternCreationInfo::updateID(common::executor_id_t executorID, |
| 7 | common::executor_info executorInfo, bool storeInsertedPatternIDs, |
| 8 | common::nodeID_t nodeID) const { |
| 9 | if (storeInsertedPatternIDs) { |
| 10 | *(common::nodeID_t*)(tuple + executorID * sizeof(common::nodeID_t)) = nodeID; |
| 11 | return; |
| 12 | } |
| 13 | if (!executorInfo.contains(executorID)) { |
| 14 | return; |
| 15 | } |
| 16 | auto ftColIndex = executorInfo.at(executorID); |
| 17 | *(common::nodeID_t*)(tuple + ftColIndex * sizeof(common::nodeID_t)) = nodeID; |
| 18 | } |
| 19 | |
| 20 | PatternCreationInfoTable::PatternCreationInfoTable(storage::MemoryManager& memoryManager, |
| 21 | std::vector<common::LogicalType> keyTypes, FactorizedTableSchema tableSchema) |
no test coverage detected