edu.iu.dsc.tws.graphapi.api

Class BasicComputation

java.lang.Object

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

edu.iu.dsc.tws.graphapi.api.BasicComputation

All Implemented Interfaces:

IWorker

Direct Known Subclasses:

TestForPagerank, TestForSSSP

public abstract class BasicComputation
extends TaskWorker

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	BasicComputation.ComputeTask
class	BasicComputation.GraphInitialization
class	BasicComputation.GraphPartiton
class	BasicComputation.ReductionFunction
class	BasicComputation.SourceTask

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	dataDirectory
static boolean	globaliterationStatus
static int	graphsize
static int	iterations
static int	parallelism
static java.lang.String	sourceVertexGlobal

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
BasicComputation()

Method Summary

Modifier and Type	Method and Description
protected ComputeGraph	buildComputationTG(int parallelismValue, Config conf, BasicComputation.SourceTask sourceTask, BasicComputation.ComputeTask computeTask, BasicComputation.ReductionFunction reductionFunction, PrimitiveMessageTypes messageType)
protected ComputeGraph	buildGraphInitialaizationTG(java.lang.String path, int dsize, int parallelismValue, Config conf, BasicComputation.GraphInitialization graphInitialization)
protected ComputeGraph	buildGraphPartitionTG(java.lang.String path, int dsize, int parallelismValue, Config conf, BasicComputation.GraphPartiton graphPartiton)
abstract ComputeGraph	computation()
void	execute() A user needs to implement this method to create the task graph and execute it
abstract ComputeGraph	graphInitialization()
abstract ComputeGraph	graphpartition()

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

Field Detail

graphsize

public static int graphsize

dataDirectory

public static java.lang.String dataDirectory

parallelism

public static int parallelism

sourceVertexGlobal

public static java.lang.String sourceVertexGlobal

globaliterationStatus

public static boolean globaliterationStatus

iterations

public static int iterations

Constructor Detail

BasicComputation

public BasicComputation()

Method Detail

computation

public abstract ComputeGraph computation()

graphInitialization

public abstract ComputeGraph graphInitialization()

graphpartition

public abstract ComputeGraph graphpartition()

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

buildGraphPartitionTG

protected ComputeGraph buildGraphPartitionTG(java.lang.String path,
                                             int dsize,
                                             int parallelismValue,
                                             Config conf,
                                             BasicComputation.GraphPartiton graphPartiton)

buildGraphInitialaizationTG

protected ComputeGraph buildGraphInitialaizationTG(java.lang.String path,
                                                   int dsize,
                                                   int parallelismValue,
                                                   Config conf,
                                                   BasicComputation.GraphInitialization graphInitialization)

buildComputationTG

protected ComputeGraph buildComputationTG(int parallelismValue,
                                          Config conf,
                                          BasicComputation.SourceTask sourceTask,
                                          BasicComputation.ComputeTask computeTask,
                                          BasicComputation.ReductionFunction reductionFunction,
                                          PrimitiveMessageTypes messageType)