Package com.alibaba.graphscope.app

Class GiraphComputationAdaptor<OID_T,VID_T,VDATA_T,EDATA_T>

java.lang.Object

com.alibaba.graphscope.communication.Communicator

com.alibaba.graphscope.app.GiraphComputationAdaptor<OID_T,VID_T,VDATA_T,EDATA_T>

Type Parameters:

OID_T - grape oid.

VID_T - grape vid.

VDATA_T - grape vdata.

EDATA_T - grape edata.

All Implemented Interfaces:

AppBase<OID_T,VID_T,VDATA_T,EDATA_T,GiraphComputationAdaptorContext<OID_T,VID_T,VDATA_T,EDATA_T>>, DefaultAppBase<OID_T,VID_T,VDATA_T,EDATA_T,GiraphComputationAdaptorContext<OID_T,VID_T,VDATA_T,EDATA_T>>

public class GiraphComputationAdaptor<OID_T,VID_T,VDATA_T,EDATA_T>
extends Communicator
implements DefaultAppBase<OID_T,VID_T,VDATA_T,EDATA_T,GiraphComputationAdaptorContext<OID_T,VID_T,VDATA_T,EDATA_T>>

This adaptor bridges c++ driver app and Giraph Computation.

Using raw types since we are not aware of Computation type parameters at this time.

Constructor Summary

Constructors

Constructor	Description
GiraphComputationAdaptor()

Method Summary

Modifier and Type	Method	Description
void	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	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.

Methods inherited from class com.alibaba.graphscope.communication.Communicator

getFFICommunicator, max, min, sum

Methods inherited from class java.lang.Object

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

Constructor Detail

GiraphComputationAdaptor

public GiraphComputationAdaptor()

Method Detail

PEval

public void 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.

Specified by:

PEval in interface DefaultAppBase<OID_T,VID_T,VDATA_T,EDATA_T,GiraphComputationAdaptorContext<OID_T,VID_T,VDATA_T,EDATA_T>>

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, DefaultContextBase, DefaultMessageManager

IncEval

public void 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.

Specified by:

IncEval in interface DefaultAppBase<OID_T,VID_T,VDATA_T,EDATA_T,GiraphComputationAdaptorContext<OID_T,VID_T,VDATA_T,EDATA_T>>

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, DefaultContextBase, DefaultMessageManager