Package com.alibaba.graphscope.app

Class GraphXParallelAdaptor<VDATA_T,EDATA_T,MSG>

java.lang.Object

com.alibaba.graphscope.app.GraphXParallelAdaptor<VDATA_T,EDATA_T,MSG>

All Implemented Interfaces:

AppBase<Long,Long,VDATA_T,EDATA_T,GraphXParallelAdaptorContext<VDATA_T,EDATA_T,MSG>>, ParallelAppBase<Long,Long,VDATA_T,EDATA_T,GraphXParallelAdaptorContext<VDATA_T,EDATA_T,MSG>>

public class GraphXParallelAdaptor<VDATA_T,EDATA_T,MSG>
extends Object
implements ParallelAppBase<Long,Long,VDATA_T,EDATA_T,GraphXParallelAdaptorContext<VDATA_T,EDATA_T,MSG>>

Constructor Summary

Constructors

Constructor	Description
GraphXParallelAdaptor()

Method Summary

Modifier and Type	Method	Description
static <VD,ED,M> GraphXParallelAdaptor<VD,ED,M>	create(URLClassLoader classLoader, String serialPath)
static <VD,ED,M> GraphXParallelAdaptor<VD,ED,M>	createImpl(Class<? extends VD> vdClass, Class<? extends ED> edClass, Class<? extends M> msgClass)
void	IncEval(IFragment<Long,Long,VDATA_T,EDATA_T> graph, ParallelContextBase<Long,Long,VDATA_T,EDATA_T> context, ParallelMessageManager messageManager)	Incremental Evaluation to implement.
void	PEval(IFragment<Long,Long,VDATA_T,EDATA_T> graph, ParallelContextBase<Long,Long,VDATA_T,EDATA_T> context, ParallelMessageManager messageManager)	Partial Evaluation to implement.

Methods inherited from class java.lang.Object

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

Constructor Detail

GraphXParallelAdaptor

public GraphXParallelAdaptor()

Method Detail

createImpl

public static <VD,ED,M> GraphXParallelAdaptor<VD,ED,M> createImpl(Class<? extends VD> vdClass,
                                                                                          Class<? extends ED> edClass,
                                                                                          Class<? extends M> msgClass)

create

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

Throws:

ClassNotFoundException

PEval

public void PEval(IFragment<Long,Long,VDATA_T,EDATA_T> graph,
                  ParallelContextBase<Long,Long,VDATA_T,EDATA_T> context,
                  ParallelMessageManager messageManager)

Description copied from interface: ParallelAppBase

Partial Evaluation to implement.

Specified by:

PEval in interface ParallelAppBase<Long,Long,VDATA_T,EDATA_T,GraphXParallelAdaptorContext<VDATA_T,EDATA_T,MSG>>

Parameters:

graph - fragment. The graph fragment providing accesses to graph data.

context - context. User defined context which manages data during the whole computations.

messageManager - The message manger which manages messages between fragments.

See Also:

IFragment, ParallelContextBase, ParallelMessageManager

IncEval

public void IncEval(IFragment<Long,Long,VDATA_T,EDATA_T> graph,
                    ParallelContextBase<Long,Long,VDATA_T,EDATA_T> context,
                    ParallelMessageManager messageManager)

Description copied from interface: ParallelAppBase

Incremental Evaluation to implement.

Specified by:

IncEval in interface ParallelAppBase<Long,Long,VDATA_T,EDATA_T,GraphXParallelAdaptorContext<VDATA_T,EDATA_T,MSG>>

Parameters:

graph - fragment. The graph fragment providing accesses to graph data.

context - context. User defined context which manages data during the whole computations.

messageManager - The message manger which manages messages between fragments.

See Also:

IFragment, ParallelContextBase, ParallelMessageManager