public class TestForPagerank extends BasicComputation
BasicComputation.ComputeTask, BasicComputation.GraphInitialization, BasicComputation.GraphPartiton, BasicComputation.ReductionFunction, BasicComputation.SourceTask
dataDirectory, globaliterationStatus, graphsize, iterations, parallelism, sourceVertexGlobal
computeEnvironment, config, persistentVolume, taskExecutor, volatileVolume, workerController, workerEnvironment, workerId
Constructor and Description |
---|
TestForPagerank() |
Modifier and Type | Method and Description |
---|---|
ComputeGraph |
computation() |
ComputeGraph |
graphInitialization() |
ComputeGraph |
graphpartition() |
buildComputationTG, buildGraphInitialaizationTG, buildGraphPartitionTG, execute
execute
public ComputeGraph computation()
computation
in class BasicComputation
public ComputeGraph graphInitialization()
graphInitialization
in class BasicComputation
public ComputeGraph graphpartition()
graphpartition
in class BasicComputation