edu.iu.dsc.tws.task.cdfw

Class DataFlowGraph

java.lang.Object

edu.iu.dsc.tws.task.cdfw.DataFlowGraph

public final class DataFlowGraph
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
DataFlowGraph	addDataFlowJobConfig(DataFlowJobConfig jobConfig)
DataFlowGraph	addInput(java.lang.String g, java.lang.String input, java.lang.String taskname)
DataFlowGraph	addOutput(java.lang.String output, java.lang.String taskname)
CDFWJobAPI.SubGraph	build()
CDFWJobAPI.CDFWSchedulePlan	getCdfwSchedulePlans()
int	getCpu()
DataFlowJobConfig	getDataFlowJobConfig()
double	getDiskGigaBytes()
ComputeGraph	getGraph()
java.lang.String	getGraphName()
java.lang.String	getGraphType()
java.util.List<CDFWJobAPI.Input>	getInputs()
int	getIterationNumber()
int	getIterations()
java.util.List<CDFWJobAPI.Output>	getOutputs()
int	getRamMegaBytes()
int	getWorkers()
static DataFlowGraph	newSubGraphJob(java.lang.String name, ComputeGraph g)
DataFlowGraph	setCdfwSchedulePlans(CDFWJobAPI.CDFWSchedulePlan cdfwSchedulePlan)
DataFlowGraph	setCpu(int c)
DataFlowGraph	setDiskGigaBytes(double disk)
DataFlowGraph	setGraphType(java.lang.String graphtype)
DataFlowGraph	setIterationNumber(int iterationnumber)
DataFlowGraph	setIterations(int iter)
DataFlowGraph	setRamMegaBytes(int ram)
DataFlowGraph	setWorkers(int w)

Methods inherited from class java.lang.Object

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

Method Detail

newSubGraphJob

public static DataFlowGraph newSubGraphJob(java.lang.String name,
                                           ComputeGraph g)

getCdfwSchedulePlans

public CDFWJobAPI.CDFWSchedulePlan getCdfwSchedulePlans()

setCdfwSchedulePlans

public DataFlowGraph setCdfwSchedulePlans(CDFWJobAPI.CDFWSchedulePlan cdfwSchedulePlan)

setCpu

public DataFlowGraph setCpu(int c)

setRamMegaBytes

public DataFlowGraph setRamMegaBytes(int ram)

setDiskGigaBytes

public DataFlowGraph setDiskGigaBytes(double disk)

getGraph

public ComputeGraph getGraph()

getCpu

public int getCpu()

getRamMegaBytes

public int getRamMegaBytes()

getDiskGigaBytes

public double getDiskGigaBytes()

addDataFlowJobConfig

public DataFlowGraph addDataFlowJobConfig(DataFlowJobConfig jobConfig)

getDataFlowJobConfig

public DataFlowJobConfig getDataFlowJobConfig()

getWorkers

public int getWorkers()

setWorkers

public DataFlowGraph setWorkers(int w)

getInputs

public java.util.List<CDFWJobAPI.Input> getInputs()

getGraphName

public java.lang.String getGraphName()

setGraphType

public DataFlowGraph setGraphType(java.lang.String graphtype)

getGraphType

public java.lang.String getGraphType()

getIterations

public int getIterations()

setIterations

public DataFlowGraph setIterations(int iter)

getIterationNumber

public int getIterationNumber()

setIterationNumber

public DataFlowGraph setIterationNumber(int iterationnumber)

addInput

public DataFlowGraph addInput(java.lang.String g,
                              java.lang.String input,
                              java.lang.String taskname)

addOutput

public DataFlowGraph addOutput(java.lang.String output,
                               java.lang.String taskname)

getOutputs

public java.util.List<CDFWJobAPI.Output> getOutputs()

build

public CDFWJobAPI.SubGraph build()