Uses of Interface
com.alibaba.graphscope.parallel.ParallelMessageManager
-
-
Uses of ParallelMessageManager in com.alibaba.graphscope.app
Methods in com.alibaba.graphscope.app with parameters of type ParallelMessageManager Modifier and Type Method Description voidGraphXParallelAdaptor. IncEval(IFragment<Long,Long,VDATA_T,EDATA_T> graph, ParallelContextBase<Long,Long,VDATA_T,EDATA_T> context, ParallelMessageManager messageManager)voidParallelAppBase. IncEval(IFragment<OID_T,VID_T,VDATA_T,EDATA_T> graph, ParallelContextBase<OID_T,VID_T,VDATA_T,EDATA_T> context, ParallelMessageManager messageManager)Incremental Evaluation to implement.voidGraphXParallelAdaptor. PEval(IFragment<Long,Long,VDATA_T,EDATA_T> graph, ParallelContextBase<Long,Long,VDATA_T,EDATA_T> context, ParallelMessageManager messageManager)voidParallelAppBase. PEval(IFragment<OID_T,VID_T,VDATA_T,EDATA_T> graph, ParallelContextBase<OID_T,VID_T,VDATA_T,EDATA_T> context, ParallelMessageManager messageManager)Partial Evaluation to implement. -
Uses of ParallelMessageManager in com.alibaba.graphscope.context
Methods in com.alibaba.graphscope.context with parameters of type ParallelMessageManager Modifier and Type Method Description voidGraphXParallelAdaptorContext. Init(IFragment<Long,Long,VDATA_T,EDATA_T> frag, ParallelMessageManager messageManager, com.alibaba.fastjson.JSONObject jsonObject)Called by grape framework, before any PEval.voidParallelContextBase. Init(IFragment<OID_T,VID_T,VDATA_T,EDATA_T> frag, ParallelMessageManager messageManager, com.alibaba.fastjson.JSONObject jsonObject)Called by grape framework, before any PEval. -
Uses of ParallelMessageManager in com.alibaba.graphscope.example.bfs
Methods in com.alibaba.graphscope.example.bfs with parameters of type ParallelMessageManager Modifier and Type Method Description voidBFS. IncEval(IFragment<Long,Long,Double,Long> fragment, ParallelContextBase<Long,Long,Double,Long> context, ParallelMessageManager messageManager)voidBFSContext. Init(IFragment<Long,Long,Double,Long> frag, ParallelMessageManager messageManager, com.alibaba.fastjson.JSONObject jsonObject)voidBFS. PEval(IFragment<Long,Long,Double,Long> fragment, ParallelContextBase<Long,Long,Double,Long> context, ParallelMessageManager messageManager) -
Uses of ParallelMessageManager in com.alibaba.graphscope.example.pagerank
Methods in com.alibaba.graphscope.example.pagerank with parameters of type ParallelMessageManager Modifier and Type Method Description voidPageRank. IncEval(IFragment<Long,Long,Long,Double> fragment, ParallelContextBase<Long,Long,Long,Double> contextBase, ParallelMessageManager parallelMessageManager)voidPageRankContext. Init(IFragment<Long,Long,Long,Double> frag, ParallelMessageManager javaParallelMessageManager, com.alibaba.fastjson.JSONObject jsonObject)voidPageRank. PEval(IFragment<Long,Long,Long,Double> fragment, ParallelContextBase<Long,Long,Long,Double> contextBase, ParallelMessageManager parallelMessageManager) -
Uses of ParallelMessageManager in com.alibaba.graphscope.example.sssp
Methods in com.alibaba.graphscope.example.sssp with parameters of type ParallelMessageManager Modifier and Type Method Description voidSSSP. IncEval(IFragment<Long,Long,Long,Long> fragment, ParallelContextBase<Long,Long,Long,Long> contextBase, ParallelMessageManager messageManager)voidSSSPContext. Init(IFragment<Long,Long,Long,Long> frag, ParallelMessageManager mm, com.alibaba.fastjson.JSONObject jsonObject)voidSSSP. PEval(IFragment<Long,Long,Long,Long> fragment, ParallelContextBase<Long,Long,Long,Long> contextBase, ParallelMessageManager mm) -
Uses of ParallelMessageManager in com.alibaba.graphscope.example.stringApp
Methods in com.alibaba.graphscope.example.stringApp with parameters of type ParallelMessageManager Modifier and Type Method Description voidStringApp. IncEval(IFragment<Long,Long,StringView,StringView> graph, ParallelContextBase<Long,Long,StringView,StringView> context, ParallelMessageManager messageManager)Incremental Evaluation to implement.voidStringAppContext. Init(IFragment<Long,Long,StringView,StringView> frag, ParallelMessageManager messageManager, com.alibaba.fastjson.JSONObject jsonObject)Called by grape framework, before any PEval.voidStringApp. PEval(IFragment<Long,Long,StringView,StringView> graph, ParallelContextBase<Long,Long,StringView,StringView> context, ParallelMessageManager messageManager)Partial Evaluation to implement. -
Uses of ParallelMessageManager in com.alibaba.graphscope.example.traverse
Methods in com.alibaba.graphscope.example.traverse with parameters of type ParallelMessageManager Modifier and Type Method Description voidTraverse. IncEval(IFragment<Long,Long,Double,Long> fragment, ParallelContextBase<Long,Long,Double,Long> context, ParallelMessageManager messageManager)voidTraverseContext. Init(IFragment<Long,Long,Double,Long> frag, ParallelMessageManager messageManager, com.alibaba.fastjson.JSONObject jsonObject)voidTraverse. PEval(IFragment<Long,Long,Double,Long> fragment, ParallelContextBase<Long,Long,Double,Long> context, ParallelMessageManager messageManager) -
Uses of ParallelMessageManager in com.alibaba.graphscope.example.wcc
Methods in com.alibaba.graphscope.example.wcc with parameters of type ParallelMessageManager Modifier and Type Method Description voidWCC. IncEval(IFragment<Long,Long,Long,Double> frag, ParallelContextBase<Long,Long,Long,Double> context, ParallelMessageManager messageManager)voidWCCContext. Init(IFragment<Long,Long,Long,Double> frag, ParallelMessageManager messageManager, com.alibaba.fastjson.JSONObject jsonObject)voidWCC. PEval(IFragment<Long,Long,Long,Double> frag, ParallelContextBase<Long,Long,Long,Double> context, ParallelMessageManager messageManager) -
Uses of ParallelMessageManager in com.alibaba.graphscope.graphx
Methods in com.alibaba.graphscope.graphx with parameters of type ParallelMessageManager Modifier and Type Method Description voidGraphXParallelPIE. init(IFragment<Long,Long,VD,ED> fragment, ParallelMessageManager messageManager, int maxIterations, int parallelism, String workerIdToFid) -
Uses of ParallelMessageManager in com.alibaba.graphscope.parallel
Subinterfaces of ParallelMessageManager in com.alibaba.graphscope.parallel Modifier and Type Interface Description interfaceParallelMessageManagerGenClasses in com.alibaba.graphscope.parallel that implement ParallelMessageManager Modifier and Type Class Description classParallelMessageManagerGen_cxx_0x5a835738 -
Uses of ParallelMessageManager in com.alibaba.graphscope.utils
Methods in com.alibaba.graphscope.utils with parameters of type ParallelMessageManager Modifier and Type Method Description voidAbstractMessageStore. flushMessages(ThreadSafeBitSet nextSet, ParallelMessageManager messageManager, IFragment<Long,Long,?,?> fragment, int[] fid2WorkerId, ExecutorService executorService)voidMessageStore. flushMessages(ThreadSafeBitSet nextSet, ParallelMessageManager messageManager, IFragment<Long,Long,?,?> fragment, int[] fid2WorkerId, ExecutorService executorService)voidObjectMessageStore. flushMessages(ThreadSafeBitSet nextSet, ParallelMessageManager messageManager, IFragment<Long,Long,?,?> fragment, int[] fid2WorkerId, ExecutorService executorService)<MSG_T> voidAbstractMessageStore. sendMsgThroughIEdges(Vertex<Long> vertex, MSG_T msg, int threadId, ParallelMessageManager messageManager, IFragment<Long,Long,?,?> fragment)we assume this function is thread safe<MSG_T> voidMessageStore. sendMsgThroughIEdges(Vertex<Long> vertex, MSG_T msg, int threadId, ParallelMessageManager messageManager, IFragment<Long,Long,?,?> fragment)Send msg through iedges, use this function rather than message manager provided to speed up.
-