| 125 | } |
| 126 | |
| 127 | void ScanRelTable::initGlobalStateInternal(ExecutionContext* context) { |
| 128 | if (!sourceNodeScanMode) { |
| 129 | return; |
| 130 | } |
| 131 | DASSERT(sourceNodeTableInfos.size() == sourceNodeSharedStates.size()); |
| 132 | for (auto i = 0u; i < sourceNodeTableInfos.size(); ++i) { |
| 133 | sourceNodeSharedStates[i]->initialize( |
| 134 | transaction::Transaction::Get(*context->clientContext), |
| 135 | sourceNodeTableInfos[i].table->ptrCast<NodeTable>(), *sourceNodeProgressSharedState); |
| 136 | } |
| 137 | } |
| 138 | |
| 139 | static void initSourceNodeScanState(ScanNodeTableInfo& sourceInfo, |
| 140 | std::unique_ptr<TableScanState>& sourceScanState, ValueVector* boundNodeIDVector, |
nothing calls this directly
no test coverage detected