edu.iu.dsc.tws.graphapi.pagerank

Class PageRankWorker

java.lang.Object

edu.iu.dsc.tws.task.impl.TaskWorker

edu.iu.dsc.tws.graphapi.pagerank.PageRankWorker

All Implemented Interfaces:

IWorker

public class PageRankWorker
extends TaskWorker

Field Summary

Fields inherited from class edu.iu.dsc.tws.task.impl.TaskWorker

computeEnvironment, config, persistentVolume, taskExecutor, volatileVolume, workerController, workerEnvironment, workerId

Constructor Summary

Constructors

Constructor and Description
PageRankWorker()

Method Summary

Modifier and Type	Method and Description
static ComputeGraph	buildComputationTG(int parallelismValue, Config conf)
static ComputeGraph	buildDataPointsTG(java.lang.String dataDirectory, int dsize, int parallelismValue, Config conf)
static ComputeGraph	buildGraphInitialValueTG(java.lang.String dataDirectory, int dsize, int parallelismValue, Config conf)
void	execute() A user needs to implement this method to create the task graph and execute it

Methods inherited from class edu.iu.dsc.tws.task.impl.TaskWorker

execute

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PageRankWorker

public PageRankWorker()

Method Detail

execute

public void execute()

Description copied from class: TaskWorker

A user needs to implement this method to create the task graph and execute it

Specified by:

execute in class TaskWorker

buildDataPointsTG

public static ComputeGraph buildDataPointsTG(java.lang.String dataDirectory,
                                             int dsize,
                                             int parallelismValue,
                                             Config conf)

buildGraphInitialValueTG

public static ComputeGraph buildGraphInitialValueTG(java.lang.String dataDirectory,
                                                    int dsize,
                                                    int parallelismValue,
                                                    Config conf)

buildComputationTG

public static ComputeGraph buildComputationTG(int parallelismValue,
                                              Config conf)