| 89 | } |
| 90 | |
| 91 | std::unique_ptr<RJOutputWriter> getOutputWriter(ExecutionContext* context, |
| 92 | const RJBindData& bindData, GDSComputeState& computeState, nodeID_t sourceNodeID, |
| 93 | RecursiveExtendSharedState* sharedState) override { |
| 94 | auto bfsGraph = computeState.auxiliaryState->ptrCast<PathAuxiliaryState>() |
| 95 | ->getBFSGraphManager() |
| 96 | ->getCurrentGraph(); |
| 97 | auto writerInfo = bindData.getPathWriterInfo(); |
| 98 | writerInfo.pathNodeMask = sharedState->getPathNodeMaskMap(); |
| 99 | return std::make_unique<SPPathsOutputWriter>(context->clientContext, |
| 100 | sharedState->getOutputNodeMaskMap(), sourceNodeID, writerInfo, *bfsGraph); |
| 101 | } |
| 102 | }; |
| 103 | |
| 104 | std::unique_ptr<RJAlgorithm> SingleSPPathsFunction::getAlgorithm() { |
nothing calls this directly
no test coverage detected