Package com.alibaba.graphscope.example.pagerank

Class PageRankContext

java.lang.Object

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

com.alibaba.graphscope.example.pagerank.PageRankContext

All Implemented Interfaces:

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

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

Field Summary

Fields

Modifier and Type	Field	Description
double	alpha
MessageInBuffer.Factory	bufferFactory
int	chunkSize
double	danglingSum
int	danglingVNum
IntArrayWrapper	degree
ExecutorService	executor
int	maxIteration
DoubleArrayWrapper	nextResult
DoubleArrayWrapper	pagerank
double	sumDoubleTime
int	superStep
double	swapTime
int	thread_num

Constructor Summary

Constructors

Constructor	Description
PageRankContext()

Method Summary

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

alpha

public double alpha

maxIteration

public int maxIteration

superStep

public int superStep

danglingSum

public double danglingSum

pagerank

public DoubleArrayWrapper pagerank

nextResult

public DoubleArrayWrapper nextResult

degree

public IntArrayWrapper degree

thread_num

public int thread_num

executor

public ExecutorService executor

bufferFactory

public MessageInBuffer.Factory bufferFactory

chunkSize

public int chunkSize

sumDoubleTime

public double sumDoubleTime

swapTime

public double swapTime

danglingVNum

public int danglingVNum

Constructor Detail

PageRankContext

public PageRankContext()

Method Detail

Init

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

Parameters:

frag - The graph fragment providing accesses to graph data.

javaParallelMessageManager - The message manager which manages messages between fragments.

jsonObject - String args from cmdline.

See Also:

IFragment, ParallelMessageManager, JSONObject

Output

public void Output(IFragment<Long,Long,Long,Double> 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,Double>

Parameters:

frag - The graph fragment contains the graph info.

See Also:

IFragment

thread_num

public int thread_num()