| 62 | pool_(driverCtx_->addOperatorPool(planNodeId, operatorType)) {} |
| 63 | |
| 64 | core::ExecCtx* OperatorCtx::execCtx() const { |
| 65 | if (!execCtx_) { |
| 66 | execCtx_ = std::make_unique<core::ExecCtx>( |
| 67 | pool_, driverCtx_->task->queryCtx().get()); |
| 68 | } |
| 69 | return execCtx_.get(); |
| 70 | } |
| 71 | |
| 72 | std::shared_ptr<connector::ConnectorQueryCtx> |
| 73 | OperatorCtx::createConnectorQueryCtx( |
no test coverage detected