| 95 | } |
| 96 | |
| 97 | std::unique_ptr<RJOutputWriter> getOutputWriter(ExecutionContext* context, |
| 98 | const RJBindData& bindData, GDSComputeState& computeState, nodeID_t sourceNodeID, |
| 99 | RecursiveExtendSharedState* sharedState) override { |
| 100 | auto bfsGraph = computeState.auxiliaryState->ptrCast<PathAuxiliaryState>() |
| 101 | ->getBFSGraphManager() |
| 102 | ->getCurrentGraph(); |
| 103 | auto writerInfo = bindData.getPathWriterInfo(); |
| 104 | writerInfo.pathNodeMask = sharedState->getPathNodeMaskMap(); |
| 105 | return std::make_unique<SPPathsOutputWriter>(context->clientContext, |
| 106 | sharedState->getOutputNodeMaskMap(), sourceNodeID, writerInfo, *bfsGraph); |
| 107 | } |
| 108 | }; |
| 109 | |
| 110 | std::unique_ptr<RJAlgorithm> AllSPPathsFunction::getAlgorithm() { |
no test coverage detected