Package com.alibaba.graphscope.context

Class GraphXParallelAdaptorContext<VDATA_T,EDATA_T,MSG>

java.lang.Object

com.alibaba.graphscope.context.VertexDataContext<IFragment<Long,Long,VDATA_T,EDATA_T>,VDATA_T>

com.alibaba.graphscope.context.GraphXParallelAdaptorContext<VDATA_T,EDATA_T,MSG>

All Implemented Interfaces:

ContextBase, ParallelContextBase<Long,Long,VDATA_T,EDATA_T>

public class GraphXParallelAdaptorContext<VDATA_T,EDATA_T,MSG>
extends VertexDataContext<IFragment<Long,Long,VDATA_T,EDATA_T>,VDATA_T>
implements ParallelContextBase<Long,Long,VDATA_T,EDATA_T>

Field Summary

Fields

Modifier and Type	Field	Description
static String	pathPrefix

Constructor Summary

Constructors

Constructor

Description

GraphXParallelAdaptorContext(Class<? extends VDATA_T> vdClass, Class<? extends EDATA_T> edClass, Class<? extends MSG> msgClass, scala.Function3<Long,VDATA_T,MSG,VDATA_T> vprog, scala.Function1<org.apache.spark.graphx.EdgeTriplet<VDATA_T,EDATA_T>,scala.collection.Iterator<scala.Tuple2<Long,MSG>>> sendMsg, scala.Function2<MSG,MSG,MSG> mergeMsg, MSG initialMsg, String appName, String vineyardSocket, org.apache.spark.graphx.EdgeDirection edgeDirection)

Method Summary

Modifier and Type	Method	Description
static <VD,ED,M> GraphXParallelAdaptorContext<VD,ED,M>	create(URLClassLoader classLoader, String serialPath)
static <VD,ED,M> GraphXParallelAdaptorContext<VD,ED,M>	createImpl(Class<? extends VD> vdClass, Class<? extends ED> edClass, Class<? extends M> msgClass, scala.Function3 vprog, scala.Function1 sendMsg, scala.Function2 mergeMsg, Object initMsg, String appName, String vineyardSocket, org.apache.spark.graphx.EdgeDirection direction)
String	getAppName()
GraphXConf	getConf()
GraphXParallelPIE<VDATA_T,EDATA_T,MSG>	getGraphXProxy()
void	Init(IFragment<Long,Long,VDATA_T,EDATA_T> frag, ParallelMessageManager messageManager, com.alibaba.fastjson.JSONObject jsonObject)	Called by grape framework, before any PEval.
void	Output(IFragment<Long,Long,VDATA_T,EDATA_T> frag)	Output will be executed when the computations finalizes.

Methods inherited from class com.alibaba.graphscope.context.VertexDataContext

createFFIContext, data, getDataClass

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

pathPrefix

public static final String pathPrefix

See Also:

Constant Field Values

Constructor Detail

GraphXParallelAdaptorContext

public GraphXParallelAdaptorContext(Class<? extends VDATA_T> vdClass,
                                    Class<? extends EDATA_T> edClass,
                                    Class<? extends MSG> msgClass,
                                    scala.Function3<Long,VDATA_T,MSG,VDATA_T> vprog,
                                    scala.Function1<org.apache.spark.graphx.EdgeTriplet<VDATA_T,EDATA_T>,scala.collection.Iterator<scala.Tuple2<Long,MSG>>> sendMsg,
                                    scala.Function2<MSG,MSG,MSG> mergeMsg,
                                    MSG initialMsg,
                                    String appName,
                                    String vineyardSocket,
                                    org.apache.spark.graphx.EdgeDirection edgeDirection)

Method Detail

createImpl

public static <VD,ED,M> GraphXParallelAdaptorContext<VD,ED,M> createImpl(Class<? extends VD> vdClass,
                                                                                                 Class<? extends ED> edClass,
                                                                                                 Class<? extends M> msgClass,
                                                                                                 scala.Function3 vprog,
                                                                                                 scala.Function1 sendMsg,
                                                                                                 scala.Function2 mergeMsg,
                                                                                                 Object initMsg,
                                                                                                 String appName,
                                                                                                 String vineyardSocket,
                                                                                                 org.apache.spark.graphx.EdgeDirection direction)

create

public static <VD,ED,M> GraphXParallelAdaptorContext<VD,ED,M> create(URLClassLoader classLoader,
                                                                                             String serialPath)
                                                                                      throws ClassNotFoundException

Throws:

ClassNotFoundException

getAppName

public String getAppName()

getConf

public GraphXConf getConf()

getGraphXProxy

public GraphXParallelPIE<VDATA_T,EDATA_T,MSG> getGraphXProxy()

Init

public void Init(IFragment<Long,Long,VDATA_T,EDATA_T> frag,
                 ParallelMessageManager messageManager,
                 com.alibaba.fastjson.JSONObject jsonObject)

Called by grape framework, before any PEval. You can initiating data structures need during super steps here.

Specified by:

Init in interface ParallelContextBase<Long,Long,VDATA_T,EDATA_T>

Parameters:

frag - The graph fragment providing accesses to graph data.

messageManager - The message manger which manages messages between fragments.

jsonObject - String args from cmdline.

See Also:

IFragment, ParallelMessageManager, JSONObject

Output

public void Output(IFragment<Long,Long,VDATA_T,EDATA_T> frag)

Output will be executed when the computations finalizes. Data maintained in this context shall be outputted here.

Specified by:

Output in interface ParallelContextBase<Long,Long,VDATA_T,EDATA_T>

Parameters:

frag - The graph fragment contains the graph info.

See Also:

IFragment