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 void
GraphXParallelAdaptor. IncEval(IFragment<Long,Long,VDATA_T,EDATA_T> graph, ParallelContextBase<Long,Long,VDATA_T,EDATA_T> context, ParallelMessageManager messageManager)
void
ParallelAppBase. 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.void
GraphXParallelAdaptor. PEval(IFragment<Long,Long,VDATA_T,EDATA_T> graph, ParallelContextBase<Long,Long,VDATA_T,EDATA_T> context, ParallelMessageManager messageManager)
void
ParallelAppBase. 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 void
GraphXParallelAdaptorContext. Init(IFragment<Long,Long,VDATA_T,EDATA_T> frag, ParallelMessageManager messageManager, com.alibaba.fastjson.JSONObject jsonObject)
Called by grape framework, before any PEval.void
ParallelContextBase. 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 void
BFS. IncEval(IFragment<Long,Long,Double,Long> fragment, ParallelContextBase<Long,Long,Double,Long> context, ParallelMessageManager messageManager)
void
BFSContext. Init(IFragment<Long,Long,Double,Long> frag, ParallelMessageManager messageManager, com.alibaba.fastjson.JSONObject jsonObject)
void
BFS. 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 void
PageRank. IncEval(IFragment<Long,Long,Long,Double> fragment, ParallelContextBase<Long,Long,Long,Double> contextBase, ParallelMessageManager parallelMessageManager)
void
PageRankContext. Init(IFragment<Long,Long,Long,Double> frag, ParallelMessageManager javaParallelMessageManager, com.alibaba.fastjson.JSONObject jsonObject)
void
PageRank. 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 void
SSSP. IncEval(IFragment<Long,Long,Long,Long> fragment, ParallelContextBase<Long,Long,Long,Long> contextBase, ParallelMessageManager messageManager)
void
SSSPContext. Init(IFragment<Long,Long,Long,Long> frag, ParallelMessageManager mm, com.alibaba.fastjson.JSONObject jsonObject)
void
SSSP. 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 void
StringApp. IncEval(IFragment<Long,Long,StringView,StringView> graph, ParallelContextBase<Long,Long,StringView,StringView> context, ParallelMessageManager messageManager)
Incremental Evaluation to implement.void
StringAppContext. Init(IFragment<Long,Long,StringView,StringView> frag, ParallelMessageManager messageManager, com.alibaba.fastjson.JSONObject jsonObject)
Called by grape framework, before any PEval.void
StringApp. 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 void
Traverse. IncEval(IFragment<Long,Long,Double,Long> fragment, ParallelContextBase<Long,Long,Double,Long> context, ParallelMessageManager messageManager)
void
TraverseContext. Init(IFragment<Long,Long,Double,Long> frag, ParallelMessageManager messageManager, com.alibaba.fastjson.JSONObject jsonObject)
void
Traverse. 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 void
WCC. IncEval(IFragment<Long,Long,Long,Double> frag, ParallelContextBase<Long,Long,Long,Double> context, ParallelMessageManager messageManager)
void
WCCContext. Init(IFragment<Long,Long,Long,Double> frag, ParallelMessageManager messageManager, com.alibaba.fastjson.JSONObject jsonObject)
void
WCC. 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 void
GraphXParallelPIE. 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 interface
ParallelMessageManagerGen
Classes in com.alibaba.graphscope.parallel that implement ParallelMessageManager Modifier and Type Class Description class
ParallelMessageManagerGen_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 void
AbstractMessageStore. flushMessages(ThreadSafeBitSet nextSet, ParallelMessageManager messageManager, IFragment<Long,Long,?,?> fragment, int[] fid2WorkerId, ExecutorService executorService)
void
MessageStore. flushMessages(ThreadSafeBitSet nextSet, ParallelMessageManager messageManager, IFragment<Long,Long,?,?> fragment, int[] fid2WorkerId, ExecutorService executorService)
void
ObjectMessageStore. flushMessages(ThreadSafeBitSet nextSet, ParallelMessageManager messageManager, IFragment<Long,Long,?,?> fragment, int[] fid2WorkerId, ExecutorService executorService)
<MSG_T> void
AbstractMessageStore. sendMsgThroughIEdges(Vertex<Long> vertex, MSG_T msg, int threadId, ParallelMessageManager messageManager, IFragment<Long,Long,?,?> fragment)
we assume this function is thread safe<MSG_T> void
MessageStore. 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.
-