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 void
DefaultAppBase. 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.void
GiraphComputationAdaptor. 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.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
DefaultAppBase. 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.void
GiraphComputationAdaptor. 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.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 IFragment in com.alibaba.graphscope.context
Classes in com.alibaba.graphscope.context with type parameters of type IFragment Modifier and Type Class Description class
VertexDataContext<FRAG_T extends IFragment,DATA_T>
class
VertexPropertyContext<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 void
DefaultContextBase. 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.void
GiraphComputationAdaptorContext. 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..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.void
DefaultContextBase. Output(IFragment<OID_T,VID_T,VDATA_T,EDATA_T> frag)
Output will be executed when the computations finalizes.void
GiraphComputationAdaptorContext. Output(IFragment<OID_T,VID_T,VDATA_T,EDATA_T> frag)
For giraph applications, we need to run postApplication method after all computation.void
GraphXParallelAdaptorContext. Output(IFragment<Long,Long,VDATA_T,EDATA_T> frag)
Output will be executed when the computations finalizes.void
ParallelContextBase. 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 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
BFSContext. Output(IFragment<Long,Long,Double,Long> frag)
void
BFS. 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 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
PageRankContext. Output(IFragment<Long,Long,Long,Double> frag)
void
PageRank. 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 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
SSSPContext. Output(IFragment<Long,Long,Long,Long> frag)
void
SSSP. 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 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
StringAppContext. Output(IFragment<Long,Long,StringView,StringView> frag)
Output will be executed when the computations finalizes.void
StringApp. 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 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
TraverseContext. Output(IFragment<Long,Long,Double,Long> frag)
void
Traverse. 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 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
WCCContext. Output(IFragment<Long,Long,Long,Double> frag)
void
WCC. 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 class
AbstractArrowProjectedAdaptor<OID_T,VID_T,VDATA_T,EDATA_T>
class
ArrowProjectedAdaptor<OID_T,VID_T,VDATA_T,EDATA_T>
class
ImmutableEdgecutFragmentAdaptor<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 void
AbstractEdgeManager. 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)
void
AbstractEdgeManager. 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. iFragment
Methods in com.alibaba.graphscope.graphx with parameters of type IFragment Modifier and Type Method Description void
GraphXParallelPIE. 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 void
DefaultMessageStoreFactory. initialize(IFragment fragment, ImmutableClassesGiraphConfiguration<I,?,?> conf)
Implementation class should use this method of initialization of any required internal state.void
MessageStoreFactory. 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 GiraphMessageManager
GiraphMessageManagerFactory. 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. fragment
Methods 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 IFragment
IFragmentHelper. 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 void
AbstractMessageStore. 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)
void
MessageStore. 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)
long
DoubleMessageStore. digest(IFragment<Long,Long,?,?> fragment, MessageInBuffer messageInBuffer, ThreadSafeBitSet curSet, int threadId)
void
DoubleMessageStore. digest(IFragment<Long,Long,?,?> fragment, FFIByteVector vector, ThreadSafeBitSet curSet, int threadId)
long
IntMessageStore. digest(IFragment<Long,Long,?,?> fragment, MessageInBuffer messageInBuffer, ThreadSafeBitSet curSet, int threadId)
void
IntMessageStore. digest(IFragment<Long,Long,?,?> fragment, FFIByteVector vector, ThreadSafeBitSet curSet, int threadId)
long
LongMessageStore. digest(IFragment<Long,Long,?,?> fragment, MessageInBuffer messageInBuffer, ThreadSafeBitSet curSet, int threadId)
void
LongMessageStore. digest(IFragment<Long,Long,?,?> fragment, FFIByteVector vector, ThreadSafeBitSet curSet, int threadId)
long
MessageStore. digest(IFragment<Long,Long,?,?> fragment, MessageInBuffer messageInBuffer, ThreadSafeBitSet curSet, int threadId)
to digest message send along edges, which should be resolved via GetMessages.void
MessageStore. digest(IFragment<Long,Long,?,?> fragment, FFIByteVector vector, ThreadSafeBitSet curSet, int threadId)
long
ObjectMessageStore. digest(IFragment<Long,Long,?,?> fragment, MessageInBuffer messageInBuffer, ThreadSafeBitSet curSet, int threadId)
void
ObjectMessageStore. digest(IFragment<Long,Long,?,?> fragment, FFIByteVector vector, ThreadSafeBitSet curSet, int threadId)
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)
boolean
GrapeTypes. parseFromSimpleFragment(IFragment fragment)
static void
ConfigurationUtils. parseJavaFragment(GiraphConfiguration giraphConfiguration, IFragment fragment)
For input IFragment, we check parse the type arguments, and set to giraphConfiguration.<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.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 void
AbstractComputation. 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 void
MasterCompute. 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 void
WorkerContext. setFragment(IFragment fragment)
-