| 137 | } |
| 138 | |
| 139 | void GDSUtils::runVertexCompute(ExecutionContext* context, GDSDensityState densityState, |
| 140 | Graph* graph, VertexCompute& vc, const std::vector<std::string>& propertiesToScan) { |
| 141 | auto maxThreads = context->clientContext->getMaxNumThreadForExec(); |
| 142 | auto sharedState = std::make_shared<VertexComputeTaskSharedState>(maxThreads); |
| 143 | for (const auto& nodeInfo : graph->getGraphEntry()->nodeInfos) { |
| 144 | auto entry = nodeInfo.entry; |
| 145 | if (!vc.beginOnTable(entry->getTableID())) { |
| 146 | continue; |
| 147 | } |
| 148 | auto info = VertexComputeTaskInfo(vc, graph, entry, propertiesToScan); |
| 149 | auto task = std::make_shared<VertexComputeTask>(maxThreads, info, sharedState); |
| 150 | runVertexComputeInternal(entry, densityState, graph, task, context); |
| 151 | } |
| 152 | } |
| 153 | |
| 154 | void GDSUtils::runVertexCompute(ExecutionContext* context, GDSDensityState densityState, |
| 155 | Graph* graph, VertexCompute& vc) { |
nothing calls this directly
no test coverage detected