| 1486 | } |
| 1487 | |
| 1488 | void Task::addRemoteSplit( |
| 1489 | const core::PlanNodeId& planNodeId, |
| 1490 | const exec::Split& split) { |
| 1491 | if (split.hasConnectorSplit()) { |
| 1492 | if (exchangeClientByPlanNode_.count(planNodeId)) { |
| 1493 | auto remoteSplit = |
| 1494 | std::dynamic_pointer_cast<RemoteConnectorSplit>(split.connectorSplit); |
| 1495 | BOLT_CHECK(remoteSplit, "Wrong type of split"); |
| 1496 | exchangeClientByPlanNode_[planNodeId]->addRemoteTaskId( |
| 1497 | remoteSplit->taskId); |
| 1498 | } |
| 1499 | } |
| 1500 | } |
| 1501 | |
| 1502 | std::unique_ptr<ContinuePromise> Task::addSplitLocked( |
| 1503 | SplitsState& splitsState, |
nothing calls this directly
no test coverage detected