Uses of Interface
com.alibaba.graphscope.fragment.IFragment
-
-
Uses of IFragment in com.alibaba.graphscope.app
Methods in com.alibaba.graphscope.app with parameters of type IFragment Modifier and Type Method Description voidDefaultAppBase. IncEval(IFragment<OID_T,VID_T,VDATA_T,EDATA_T> graph, DefaultContextBase<OID_T,VID_T,VDATA_T,EDATA_T> context, DefaultMessageManager messageManager)Incremental Evaluation to implement.voidGiraphComputationAdaptor. IncEval(IFragment<OID_T,VID_T,VDATA_T,EDATA_T> graph, DefaultContextBase<OID_T,VID_T,VDATA_T,EDATA_T> context, DefaultMessageManager messageManager)Incremental Evaluation to implement.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.voidDefaultAppBase. PEval(IFragment<OID_T,VID_T,VDATA_T,EDATA_T> graph, DefaultContextBase<OID_T,VID_T,VDATA_T,EDATA_T> context, DefaultMessageManager messageManager)Partial Evaluation to implement.voidGiraphComputationAdaptor. PEval(IFragment<OID_T,VID_T,VDATA_T,EDATA_T> graph, DefaultContextBase<OID_T,VID_T,VDATA_T,EDATA_T> context, DefaultMessageManager messageManager)Partial 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 IFragment in com.alibaba.graphscope.context
Classes in com.alibaba.graphscope.context with type parameters of type IFragment Modifier and Type Class Description classVertexDataContext<FRAG_T extends IFragment,DATA_T>classVertexPropertyContext<FRAG_T extends IFragment>VertexPropertyContext only compatible with simple graph, i.e.Methods in com.alibaba.graphscope.context with parameters of type IFragment Modifier and Type Method Description voidDefaultContextBase. Init(IFragment<OID_T,VID_T,VDATA_T,EDATA_T> frag, DefaultMessageManager messageManager, com.alibaba.fastjson.JSONObject jsonObject)Called by grape framework, before any PEval.voidGiraphComputationAdaptorContext. Init(IFragment<OID_T,VID_T,VDATA_T,EDATA_T> frag, DefaultMessageManager messageManager, com.alibaba.fastjson.JSONObject jsonObject)CAUTION: THIS METHOD SHALL BE CALLED in JNI after initCommunicator..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.voidDefaultContextBase. Output(IFragment<OID_T,VID_T,VDATA_T,EDATA_T> frag)Output will be executed when the computations finalizes.voidGiraphComputationAdaptorContext. Output(IFragment<OID_T,VID_T,VDATA_T,EDATA_T> frag)For giraph applications, we need to run postApplication method after all computation.voidGraphXParallelAdaptorContext. Output(IFragment<Long,Long,VDATA_T,EDATA_T> frag)Output will be executed when the computations finalizes.voidParallelContextBase. Output(IFragment<OID_T,VID_T,VDATA_T,EDATA_T> frag)Output will be executed when the computations finalizes. -
Uses of IFragment in com.alibaba.graphscope.example.bfs
Methods in com.alibaba.graphscope.example.bfs with parameters of type IFragment 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)voidBFSContext. Output(IFragment<Long,Long,Double,Long> frag)voidBFS. PEval(IFragment<Long,Long,Double,Long> fragment, ParallelContextBase<Long,Long,Double,Long> context, ParallelMessageManager messageManager) -
Uses of IFragment in com.alibaba.graphscope.example.pagerank
Methods in com.alibaba.graphscope.example.pagerank with parameters of type IFragment 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)voidPageRankContext. Output(IFragment<Long,Long,Long,Double> frag)voidPageRank. PEval(IFragment<Long,Long,Long,Double> fragment, ParallelContextBase<Long,Long,Long,Double> contextBase, ParallelMessageManager parallelMessageManager) -
Uses of IFragment in com.alibaba.graphscope.example.sssp
Methods in com.alibaba.graphscope.example.sssp with parameters of type IFragment 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)voidSSSPContext. Output(IFragment<Long,Long,Long,Long> frag)voidSSSP. PEval(IFragment<Long,Long,Long,Long> fragment, ParallelContextBase<Long,Long,Long,Long> contextBase, ParallelMessageManager mm) -
Uses of IFragment in com.alibaba.graphscope.example.stringApp
Methods in com.alibaba.graphscope.example.stringApp with parameters of type IFragment 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.voidStringAppContext. Output(IFragment<Long,Long,StringView,StringView> frag)Output will be executed when the computations finalizes.voidStringApp. PEval(IFragment<Long,Long,StringView,StringView> graph, ParallelContextBase<Long,Long,StringView,StringView> context, ParallelMessageManager messageManager)Partial Evaluation to implement. -
Uses of IFragment in com.alibaba.graphscope.example.traverse
Methods in com.alibaba.graphscope.example.traverse with parameters of type IFragment 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)voidTraverseContext. Output(IFragment<Long,Long,Double,Long> frag)voidTraverse. PEval(IFragment<Long,Long,Double,Long> fragment, ParallelContextBase<Long,Long,Double,Long> context, ParallelMessageManager messageManager) -
Uses of IFragment in com.alibaba.graphscope.example.wcc
Methods in com.alibaba.graphscope.example.wcc with parameters of type IFragment 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)voidWCCContext. Output(IFragment<Long,Long,Long,Double> frag)voidWCC. PEval(IFragment<Long,Long,Long,Double> frag, ParallelContextBase<Long,Long,Long,Double> context, ParallelMessageManager messageManager) -
Uses of IFragment in com.alibaba.graphscope.factory
Methods in com.alibaba.graphscope.factory with parameters of type IFragment Modifier and Type Method Description static <VDATA_T extends org.apache.hadoop.io.Writable,GRAPE_OID_T,GRAPE_VID_T,GRAPE_VDATA_T,GRAPE_EDATA_T>
VertexDataManager<VDATA_T>GiraphComputationFactory. createDefaultVertexDataManager(ImmutableClassesGiraphConfiguration conf, IFragment<GRAPE_OID_T,GRAPE_VID_T,GRAPE_VDATA_T,GRAPE_EDATA_T> frag, long innerVerticesNum)static <OID_T extends org.apache.hadoop.io.WritableComparable,GRAPE_OID_T,GRAPE_VID_T,GRAPE_VDATA_T,GRAPE_EDATA_T>
GiraphVertexIdManager<GRAPE_VID_T,OID_T>GiraphComputationFactory. createDefaultVertexIdManager(ImmutableClassesGiraphConfiguration conf, IFragment<GRAPE_OID_T,GRAPE_VID_T,GRAPE_VDATA_T,GRAPE_EDATA_T> frag, long fragVerticesNum)static <OID_T extends org.apache.hadoop.io.WritableComparable,EDATA_T extends org.apache.hadoop.io.Writable,GRAPE_OID_T,GRAPE_VID_T,GRAPE_VDATA_T,GRAPE_EDATA_T>
GiraphEdgeManager<OID_T,EDATA_T>GiraphComputationFactory. createImmutableEdgeManager(ImmutableClassesGiraphConfiguration conf, IFragment<GRAPE_OID_T,GRAPE_VID_T,GRAPE_VDATA_T,GRAPE_EDATA_T> fragment, GiraphVertexIdManager<GRAPE_VID_T,OID_T> vertexIdManager) -
Uses of IFragment in com.alibaba.graphscope.fragment.adaptor
Classes in com.alibaba.graphscope.fragment.adaptor that implement IFragment Modifier and Type Class Description classAbstractArrowProjectedAdaptor<OID_T,VID_T,VDATA_T,EDATA_T>classArrowProjectedAdaptor<OID_T,VID_T,VDATA_T,EDATA_T>classImmutableEdgecutFragmentAdaptor<OID_T,VID_T,VDATA_T,EDATA_T> -
Uses of IFragment in com.alibaba.graphscope.graph
Methods in com.alibaba.graphscope.graph with parameters of type IFragment Modifier and Type Method Description voidAbstractEdgeManager. init(IFragment<GRAPE_OID_T,VID_T,?,GRAPE_ED_T> fragment, VertexIdManager<VID_T,BIZ_OID_T> vertexIdManager, Class<? extends BIZ_OID_T> bizOidClass, Class<? extends VID_T> vidClass, Class<? extends GRAPE_ED_T> grapeEdataClass, Class<? extends BIZ_EDATA_T> bizEdataClass, BiConsumer<FFIByteVectorInputStream,PrimitiveArray<BIZ_EDATA_T>> consumer)voidAbstractEdgeManager. init(IFragment<GRAPE_OID_T,VID_T,?,GRAPE_ED_T> fragment, VertexIdManager<VID_T,BIZ_OID_T> vertexIdManager, Class<? extends BIZ_OID_T> bizOidClass, Class<? extends VID_T> vidClass, Class<? extends GRAPE_ED_T> grapeEdataClass, Class<? extends BIZ_EDATA_T> bizEdataClass, BiConsumer<FFIByteVectorInputStream,PrimitiveArray<BIZ_EDATA_T>> consumer, int numCores) -
Uses of IFragment in com.alibaba.graphscope.graph.impl
Constructors in com.alibaba.graphscope.graph.impl with parameters of type IFragment Constructor Description DefaultImmutableEdgeManager(IFragment<GRAPE_OID_T,GRAPE_VID_T,GRAPE_VDATA_T,GRAPE_EDATA_T> fragment, GiraphVertexIdManager<GRAPE_VID_T,? extends GIRAPH_OID_T> idManager, ImmutableClassesGiraphConfiguration<?,?,?> configuration)GiraphVertexIdManagerImpl(IFragment<GRAPE_OID_T,GRAPE_VID_T,GRAPE_VDATA_T,GRAPE_EDATA_T> fragment, long vertexNum, ImmutableClassesGiraphConfiguration<OID_T,?,?> conf)To provide giraph users with all oids, we need to get all oids out of c++ memory, then let java read the stream.VertexDataManagerImpl(IFragment<GRAPE_OID_T,GRAPE_VID_T,GRAPE_VDATA_T,GRAPE_EDATA_T> fragment, long vertexNum, ImmutableClassesGiraphConfiguration<?,VDATA_T,?> configuration) -
Uses of IFragment in com.alibaba.graphscope.graphx
Fields in com.alibaba.graphscope.graphx declared as IFragment Modifier and Type Field Description protected IFragment<Long,Long,VD,ED>GraphXParallelPIE. iFragmentMethods in com.alibaba.graphscope.graphx with parameters of type IFragment Modifier and Type Method Description voidGraphXParallelPIE. init(IFragment<Long,Long,VD,ED> fragment, ParallelMessageManager messageManager, int maxIterations, int parallelism, String workerIdToFid) -
Uses of IFragment in com.alibaba.graphscope.parallel
Methods in com.alibaba.graphscope.parallel with type parameters of type IFragment Modifier and Type Method Description default <FRAG_T extends IFragment,MSG_T,SKIP_T>
booleanDefaultMessageManager. getMessage(FRAG_T frag, Vertex<Long> vertex, MSG_T msg, SKIP_T skip)default <FRAG_T extends IFragment,MSG_T,UNUSED_T>
voidParallelPropertyMessageManager. parallelProcess(FRAG_T frag, int vertexLabelId, int threadNum, ExecutorService executor, Supplier<MSG_T> msgSupplier, TriConsumer<Vertex<Long>,MSG_T,Integer> consumer)default <FRAG_T extends IFragment,MSG_T>
booleanDefaultMessageManager. sendMsgThroughEdges(FRAG_T frag, Vertex<Long> vertex, MSG_T msg)default <FRAG_T extends IFragment,MSG_T>
booleanDefaultMessageManager. sendMsgThroughIEdges(FRAG_T frag, Vertex<Long> vertex, MSG_T msg)default <FRAG_T extends IFragment,MSG_T>
booleanDefaultMessageManager. sendMsgThroughOEdges(FRAG_T frag, Vertex<Long> vertex, MSG_T msg)default <FRAG_T extends IFragment,MSG_T>
booleanDefaultMessageManager. syncStateOnOuterVertex(FRAG_T frag, Vertex<Long> vertex, MSG_T msg)Methods in com.alibaba.graphscope.parallel with parameters of type IFragment Modifier and Type Method Description default <OID_T,VID_T,VDATA_T,EDATA_T,MSG_T,UNUSED_T>
booleanMessageInBuffer. getMessage(IFragment<OID_T,VID_T,VDATA_T,EDATA_T> frag, Vertex<VID_T> vertex, MSG_T msg)default <OID_T,VID_T,VDATA_T,EDATA_T,MSG_T>
voidParallelMessageManager. parallelProcess(IFragment<OID_T,VID_T,VDATA_T,EDATA_T> frag, int threadNum, ExecutorService executor, Supplier<MSG_T> msgSupplier, BiConsumer<Vertex<VID_T>,MSG_T> consumer)Parallel processing the messages received from last super step.default <OID_T,VID_T,VDATA_T,EDATA_T,MSG_T>
booleanParallelMessageManager. sendMsgThroughEdges(IFragment<OID_T,VID_T,VDATA_T,EDATA_T> frag, Vertex<VID_T> vertex, MSG_T msg, int channelId)default <OID_T,VID_T,VDATA_T,EDATA_T,MSG_T>
booleanParallelMessageManager. sendMsgThroughIEdges(IFragment<OID_T,VID_T,VDATA_T,EDATA_T> frag, Vertex<VID_T> vertex, MSG_T msg, int channelId)default <OID_T,VID_T,VDATA_T,EDATA_T,MSG_T>
booleanParallelMessageManager. sendMsgThroughOEdges(IFragment<OID_T,VID_T,VDATA_T,EDATA_T> frag, Vertex<VID_T> vertex, MSG_T msg, int channelId)default <OID_T,VID_T,VDATA_T,EDATA_T,MSG_T>
booleanParallelMessageManager. syncStateOnOuterVertex(IFragment<OID_T,VID_T,VDATA_T,EDATA_T> frag, Vertex<VID_T> vertex, MSG_T msg, int channelId)default <OID_T,VID_T,VDATA_T,EDATA_T>
booleanParallelMessageManager. syncStateOnOuterVertexNoMsg(IFragment<OID_T,VID_T,VDATA_T,EDATA_T> frag, Vertex<VID_T> vertex, int channelId) -
Uses of IFragment in com.alibaba.graphscope.parallel.message
Methods in com.alibaba.graphscope.parallel.message with parameters of type IFragment Modifier and Type Method Description voidDefaultMessageStoreFactory. initialize(IFragment fragment, ImmutableClassesGiraphConfiguration<I,?,?> conf)Implementation class should use this method of initialization of any required internal state.voidMessageStoreFactory. initialize(IFragment fragment, ImmutableClassesGiraphConfiguration<I,?,?> conf)Implementation class should use this method of initialization of any required internal state.Constructors in com.alibaba.graphscope.parallel.message with parameters of type IFragment Constructor Description DefaultMessageStore(IFragment<?,GS_VID_T,?,?> fragment, ImmutableClassesGiraphConfiguration<OID_T,?,?> conf) -
Uses of IFragment in com.alibaba.graphscope.parallel.mm
Methods in com.alibaba.graphscope.parallel.mm with parameters of type IFragment Modifier and Type Method Description static GiraphMessageManagerGiraphMessageManagerFactory. create(String mmType, IFragment fragment, DefaultMessageManager grapeMessager, NetworkMap networkMap, ImmutableClassesGiraphConfiguration conf, FFICommunicator communicator, GiraphVertexIdManager idManager) -
Uses of IFragment in com.alibaba.graphscope.parallel.mm.impl
Fields in com.alibaba.graphscope.parallel.mm.impl declared as IFragment Modifier and Type Field Description protected IFragment<GS_OID_T,GS_VID_T,?,?>AbstractMessageManager. fragmentMethods in com.alibaba.graphscope.parallel.mm.impl that return IFragment Modifier and Type Method Description IFragment<GS_OID_T,GS_VID_T,?,?>AbstractMessageManager. getFragment()Constructors in com.alibaba.graphscope.parallel.mm.impl with parameters of type IFragment Constructor Description AbstractMessageManager(IFragment<GS_OID_T,GS_VID_T,?,?> fragment, DefaultMessageManager mm, ImmutableClassesGiraphConfiguration<OID_T,VDATA_T,EDATA_T> conf, FFICommunicator communicator)GiraphMpiMessageManager(IFragment fragment, DefaultMessageManager defaultMessageManager, ImmutableClassesGiraphConfiguration configuration, FFICommunicator communicator, GiraphVertexIdManager<GS_VID_T,OID_T> idManager)GiraphNettyMessageManager(IFragment fragment, NetworkMap networkMap, DefaultMessageManager mm, ImmutableClassesGiraphConfiguration<OID_T,VDATA_T,EDATA_T> conf, FFICommunicator communicator)The constructor is the preApplication. -
Uses of IFragment in com.alibaba.graphscope.parallel.netty
Constructors in com.alibaba.graphscope.parallel.netty with parameters of type IFragment Constructor Description NettyServer(ImmutableClassesGiraphConfiguration conf, IFragment fragment, NetworkMap networkMap, MessageStore<OID_T,org.apache.hadoop.io.Writable,GS_VID_T> nextIncomingMessages, Thread.UncaughtExceptionHandler exceptionHandler) -
Uses of IFragment in com.alibaba.graphscope.parallel.netty.handler
Constructors in com.alibaba.graphscope.parallel.netty.handler with parameters of type IFragment Constructor Description NettyServerHandler(IFragment<?,GS_VID_T,?,?> fragment, MessageStore<OID_T,org.apache.hadoop.io.Writable,GS_VID_T> nextIncomingMessages) -
Uses of IFragment in com.alibaba.graphscope.runtime
Methods in com.alibaba.graphscope.runtime that return IFragment Modifier and Type Method Description static IFragmentIFragmentHelper. adapt2SimpleFragment(Object fragmentImpl) -
Uses of IFragment in com.alibaba.graphscope.utils
Methods in com.alibaba.graphscope.utils with parameters of type IFragment Modifier and Type Method Description voidAbstractMessageStore. addMessages(scala.collection.Iterator<scala.Tuple2<Long,T>> msgs, int threadId, com.alibaba.graphscope.graphx.graph.GSEdgeTripletImpl edgeTriplet, IFragment<Long,Long,?,?> fragment, int srcLid, int dstLid)voidMessageStore. addMessages(scala.collection.Iterator<scala.Tuple2<Long,T>> msgs, int threadId, com.alibaba.graphscope.graphx.graph.GSEdgeTripletImpl triplet, IFragment<Long,Long,?,?> fragment, int srcLid, int dstLid)longDoubleMessageStore. digest(IFragment<Long,Long,?,?> fragment, MessageInBuffer messageInBuffer, ThreadSafeBitSet curSet, int threadId)voidDoubleMessageStore. digest(IFragment<Long,Long,?,?> fragment, FFIByteVector vector, ThreadSafeBitSet curSet, int threadId)longIntMessageStore. digest(IFragment<Long,Long,?,?> fragment, MessageInBuffer messageInBuffer, ThreadSafeBitSet curSet, int threadId)voidIntMessageStore. digest(IFragment<Long,Long,?,?> fragment, FFIByteVector vector, ThreadSafeBitSet curSet, int threadId)longLongMessageStore. digest(IFragment<Long,Long,?,?> fragment, MessageInBuffer messageInBuffer, ThreadSafeBitSet curSet, int threadId)voidLongMessageStore. digest(IFragment<Long,Long,?,?> fragment, FFIByteVector vector, ThreadSafeBitSet curSet, int threadId)longMessageStore. digest(IFragment<Long,Long,?,?> fragment, MessageInBuffer messageInBuffer, ThreadSafeBitSet curSet, int threadId)to digest message send along edges, which should be resolved via GetMessages.voidMessageStore. digest(IFragment<Long,Long,?,?> fragment, FFIByteVector vector, ThreadSafeBitSet curSet, int threadId)longObjectMessageStore. digest(IFragment<Long,Long,?,?> fragment, MessageInBuffer messageInBuffer, ThreadSafeBitSet curSet, int threadId)voidObjectMessageStore. digest(IFragment<Long,Long,?,?> fragment, FFIByteVector vector, ThreadSafeBitSet curSet, int threadId)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)booleanGrapeTypes. parseFromSimpleFragment(IFragment fragment)static voidConfigurationUtils. parseJavaFragment(GiraphConfiguration giraphConfiguration, IFragment fragment)For input IFragment, we check parse the type arguments, and set to giraphConfiguration.<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.Constructors in com.alibaba.graphscope.utils with parameters of type IFragment Constructor Description GrapeTypes(IFragment fragment) -
Uses of IFragment in org.apache.giraph.conf
Constructors in org.apache.giraph.conf with parameters of type IFragment Constructor Description ImmutableClassesGiraphConfiguration(org.apache.hadoop.conf.Configuration configuration, IFragment fragment) -
Uses of IFragment in org.apache.giraph.graph
Methods in org.apache.giraph.graph with parameters of type IFragment Modifier and Type Method Description voidAbstractComputation. setFragment(IFragment fragment) -
Uses of IFragment in org.apache.giraph.master
Methods in org.apache.giraph.master with parameters of type IFragment Modifier and Type Method Description voidMasterCompute. setFragment(IFragment fragment) -
Uses of IFragment in org.apache.giraph.worker
Methods in org.apache.giraph.worker with parameters of type IFragment Modifier and Type Method Description voidWorkerContext. setFragment(IFragment fragment)
-