| 612 | } |
| 613 | |
| 614 | bolt::memory::MemoryPool* Task::addConnectorPoolLocked( |
| 615 | const core::PlanNodeId& planNodeId, |
| 616 | int pipelineId, |
| 617 | uint32_t driverId, |
| 618 | const std::string& operatorType, |
| 619 | const std::string& connectorId) { |
| 620 | auto* nodePool = getOrAddNodePool(planNodeId); |
| 621 | childPools_.push_back(nodePool->addAggregateChild(fmt::format( |
| 622 | "op.{}.{}.{}.{}.{}", |
| 623 | planNodeId, |
| 624 | pipelineId, |
| 625 | driverId, |
| 626 | operatorType, |
| 627 | connectorId))); |
| 628 | return childPools_.back().get(); |
| 629 | } |
| 630 | |
| 631 | bolt::memory::MemoryPool* Task::addMergeSourcePool( |
| 632 | const core::PlanNodeId& planNodeId, |
no test coverage detected