Package com.alibaba.graphscope.example.sssp

Class SSSPContext

java.lang.Object

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

com.alibaba.graphscope.example.sssp.SSSPContext

All Implemented Interfaces:

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

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

Field Summary

Fields

Modifier and Type	Field	Description
int	chunkSize
VertexSet	curModified
double	execTime
ExecutorService	executor
VertexSet	nextModified
AtomicLongArrayWrapper	partialResults
double	receiveMessageTime
double	sendMessageTime
Long	sourceOid
int	threadNum

Constructor Summary

Constructors

Constructor	Description
SSSPContext()

Method Summary

Modifier and Type	Method	Description
Long	getSourceOid()
void	Init(IFragment<Long,Long,Long,Long> frag, ParallelMessageManager mm, com.alibaba.fastjson.JSONObject jsonObject)	Called by grape framework, before any PEval.
void	Output(IFragment<Long,Long,Long,Long> frag)	Output will be executed when the computations finalizes.
int	thread_num()

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

executor

public ExecutorService executor

partialResults

public AtomicLongArrayWrapper partialResults

curModified

public VertexSet curModified

nextModified

public VertexSet nextModified

execTime

public double execTime

sendMessageTime

public double sendMessageTime

receiveMessageTime

public double receiveMessageTime

sourceOid

public Long sourceOid

threadNum

public int threadNum

chunkSize

public int chunkSize

Constructor Detail

SSSPContext

public SSSPContext()

Method Detail

getSourceOid

public Long getSourceOid()

Init

public void Init(IFragment<Long,Long,Long,Long> frag,
                 ParallelMessageManager mm,
                 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,Long,Long>

Parameters:

frag - The graph fragment providing accesses to graph data.

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

Parameters:

frag - The graph fragment contains the graph info.

See Also:

IFragment

thread_num

public int thread_num()