Package com.alibaba.graphscope.context

Interface ParallelContextBase<OID_T,VID_T,VDATA_T,EDATA_T>

Type Parameters:

OID_T - original id type

VID_T - vertex id type

VDATA_T - vertex data type

EDATA_T - edge data type

All Superinterfaces:

ContextBase

All Known Implementing Classes:

BFSContext, GraphXParallelAdaptorContext, PageRankContext, SSSPContext, StringAppContext, TraverseContext, WCCContext

public interface ParallelContextBase<OID_T,VID_T,VDATA_T,EDATA_T>
extends ContextBase

ParallelContextBase is the base class for user-defined contexts for parallel apps. A context manages data through the whole computation. The data won't be cleared during supersteps.

Apart from data structures provided by java.lang, you can also use java wrappers for * grape data structures provided com.alibaba.graphscope.ds and com.alibaba.graphscope.stdcxx.

Method Summary

Modifier and Type	Method	Description
void	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	Output(IFragment<OID_T,VID_T,VDATA_T,EDATA_T> frag)	Output will be executed when the computations finalizes.

Method Detail

Init

void 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. You can initiating data structures need during super steps here.

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

void Output(IFragment<OID_T,VID_T,VDATA_T,EDATA_T> frag)

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

Parameters:

frag - The graph fragment contains the graph info.

See Also:

IFragment