| 130 | return fmt::format("Operator: {}", op->toString()); |
| 131 | } |
| 132 | |
| 133 | } // namespace |
| 134 | |
| 135 | DriverCtx::DriverCtx( |
| 136 | std::shared_ptr<Task> _task, |
| 137 | int _driverId, |
| 138 | int _pipelineId, |
| 139 | uint32_t _splitGroupId, |
| 140 | uint32_t _partitionId) |
| 141 | : driverId(_driverId), |
| 142 | pipelineId(_pipelineId), |
| 143 | splitGroupId(_splitGroupId), |
| 144 | partitionId(_partitionId), |
| 145 | task(_task), |
| 146 | threadDebugInfo({task->queryCtx()->queryId(), task->taskId(), nullptr}), |
| 147 | isAbtestControlGroup(folly::Random::oneIn(2)) {} |