edu.isi.pegasus.planner.provisioner
Class Estimator

java.lang.Object
  edu.isi.pegasus.planner.provisioner.Estimator

public class Estimator
extends Object

This Estimator is used to find the near-optimal number of processors required to complete workflow within a given RFT(requested finish time). This estimator read workflow from a DAX file and user can select one estimation method among BTS, DSC, and IterHEFT. User also need to provide RFT and the precision of the predictied execution time.

Author:

Eunkyu Byun

Field Summary

private Node	bottomNode
private HashSet	edges
private String	fileName
private String	method
private HashMap	nodes
private int	prec
private long	RFT
private Node	topNode
private long	totalET

Constructor Summary

Estimator(String fileName, String methodID, long RFT, int prec)
Constructor

Method Summary

private int	BTS()
private void	calculateSlotSize()
private int	DSC()
int	estimate() Estimate the number of processors and return the value.
private long	HEFT(int size)
private int	IterHEFT()
static void	main(String[] args)
private void	readDAX()
private void	updateETs()

Methods inherited from class java.lang.Object

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

Field Detail

fileName

private String fileName

method

private String method

RFT

private long RFT

prec

private int prec

topNode

private Node topNode

bottomNode

private Node bottomNode

edges

private HashSet edges

nodes

private HashMap nodes

totalET

private long totalET

Constructor Detail

Estimator

public Estimator(String fileName,
                 String methodID,
                 long RFT,
                 int prec)

Constructor

Parameters:

fileName - DAX file describing the workflow

methodID - One of those; BTS, DSC, IterHEFT

RFT - requested finish time. i.e., deadline

prec - The precision of the predicted execution time

Method Detail

readDAX

private void readDAX()
              throws Exception

Throws:

Exception

calculateSlotSize

private void calculateSlotSize()

updateETs

private void updateETs()

BTS

private int BTS()

DSC

private int DSC()

IterHEFT

private int IterHEFT()

HEFT

private long HEFT(int size)

estimate

public int estimate()
             throws RuntimeException

Estimate the number of processors and return the value.

Returns:

Estimated number of processors

Throws:

RuntimeException

main

public static void main(String[] args)