edu.iu.dsc.tws.graphapi.sssp

Class SingleSourceShortestPathWorker

java.lang.Object

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

edu.iu.dsc.tws.graphapi.sssp.SingleSourceShortestPathWorker

All Implemented Interfaces:

IWorker

public class SingleSourceShortestPathWorker
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
SingleSourceShortestPathWorker()

Method Summary

Modifier and Type	Method and Description
static ComputeGraph	buildComputationSsspTG(int parallelismValue, Config conf)
static ComputeGraph	buildDataPointsTG(java.lang.String dataDirectory, int dsize, int parallelismValue, java.lang.String soruceVertex, Config conf)
static ComputeGraph	buildSsspInitialTG(java.lang.String dataDirectory, int dsize, int parallelismValue, java.lang.String soruceVertex, 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

SingleSourceShortestPathWorker

public SingleSourceShortestPathWorker()

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,
                                             java.lang.String soruceVertex,
                                             Config conf)

buildSsspInitialTG

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

buildComputationSsspTG

public static ComputeGraph buildComputationSsspTG(int parallelismValue,
                                                  Config conf)