diff options
| -rw-r--r-- | opendc/opendc-experiments-sc20/src/main/kotlin/com/atlarge/opendc/experiments/sc20/trace/Sc20TraceConverter.kt | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/opendc/opendc-experiments-sc20/src/main/kotlin/com/atlarge/opendc/experiments/sc20/trace/Sc20TraceConverter.kt b/opendc/opendc-experiments-sc20/src/main/kotlin/com/atlarge/opendc/experiments/sc20/trace/Sc20TraceConverter.kt index e10baa61..9664bc5f 100644 --- a/opendc/opendc-experiments-sc20/src/main/kotlin/com/atlarge/opendc/experiments/sc20/trace/Sc20TraceConverter.kt +++ b/opendc/opendc-experiments-sc20/src/main/kotlin/com/atlarge/opendc/experiments/sc20/trace/Sc20TraceConverter.kt @@ -24,6 +24,7 @@ package com.atlarge.opendc.experiments.sc20.trace +import me.tongfei.progressbar.ProgressBar import org.apache.avro.Schema import org.apache.avro.SchemaBuilder import org.apache.avro.generic.GenericData @@ -307,7 +308,7 @@ fun readAzureTrace( val vmIdToLastFragment = mutableMapOf<String, Fragment?>() val allFragments = mutableListOf<Fragment>() - for (i in 1..195) { + for (i in ProgressBar.wrap((1..195).toList(), "Reading Trace")) { val readingsFile = File(File(traceDirectory, "readings"), "readings-$i.csv") var timestamp: Long var cpuUsage: Double |