spdf/elektron
Archived
1
0
Fork 0
Code Issues 4 Pull requests 1 Projects Releases Packages Wiki Activity

fixed comments to be a little more meaningful.

Browse source
This commit is contained in:
Pradyumna Kaushik 2017-04-30 16:48:38 -04:00
parent 1b15bb14e7
commit e3569e95ce
1 changed files with 4 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

6
def/taskUtils.go
View file

@ -18,7 +18,9 @@ type TasksToClassify []Task
func (tc TasksToClassify) ClassifyTasks(numberOfClusters int, taskObservation func(task Task) []float64) []TaskCluster {
clusters := make(map[int][]Task)
observations := getObservations(tc, taskObservation)
// TODO: Make the number rounds configurable based on the size of the workload
// TODO: Make the max number of rounds configurable based on the size of the workload
// The max number of rounds (currently defaulted to 100) is the number of iterations performed to obtain
// distinct clusters. When the data size becomes very large, we would need more iterations for clustering.
if trained, centroids := gokmeans.Train(observations, numberOfClusters, 100); trained {
for i := 0; i < len(observations); i++ {
observation := observations[i]
@ -43,7 +45,7 @@ func getObservations(tasks []Task, taskObservation func(task Task) []float64) []
}
// Size tasks based on the power consumption
// TODO: Size the cluster in a better way just taking an aggregate of the watts resource requirement.
// TODO: Size the cluster in a better way other than just taking an aggregate of the watts resource requirement.
func clusterSize(tasks []Task, taskObservation func(task Task) []float64) float64 {
size := 0.0
for _, task := range tasks {