Package com.alibaba.graphscope.example.bfs

Class BFSContext

java.lang.Object

com.alibaba.graphscope.context.VertexDataContext<IFragment<Long,Long,Double,Long>,Long>

com.alibaba.graphscope.example.bfs.BFSContext

All Implemented Interfaces:

ContextBase, ParallelContextBase<Long,Long,Double,Long>

public class BFSContext
extends VertexDataContext<IFragment<Long,Long,Double,Long>,Long>
implements ParallelContextBase<Long,Long,Double,Long>

Field Summary

Fields

Modifier and Type	Field	Description
int	currentDepth
VertexSet	currentInnerUpdated
ExecutorService	executor
VertexSet	nextInnerUpdated
IntArrayWrapper	partialResults
long	sourceOid
int	threadNum

Constructor Summary

Constructors

Constructor	Description
BFSContext()

Method Summary

Modifier and Type	Method	Description
void	Init(IFragment<Long,Long,Double,Long> frag, ParallelMessageManager messageManager, com.alibaba.fastjson.JSONObject jsonObject)	Called by grape framework, before any PEval.
void	Output(IFragment<Long,Long,Double,Long> 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

sourceOid

public long sourceOid

partialResults

public IntArrayWrapper partialResults

currentInnerUpdated

public VertexSet currentInnerUpdated

nextInnerUpdated

public VertexSet nextInnerUpdated

currentDepth

public int currentDepth

threadNum

public int threadNum

executor

public ExecutorService executor

Constructor Detail

BFSContext

public BFSContext()

Method Detail

Init

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

Description copied from interface: ParallelContextBase

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,Double,Long>

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,Double,Long> frag)

Description copied from interface: ParallelContextBase

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,Double,Long>

Parameters:

frag - The graph fragment contains the graph info.

See Also:

IFragment