summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--opendc-experiments/opendc-experiments-capelin/src/main/kotlin/org/opendc/experiments/capelin/monitor/ParquetExperimentMonitor.kt4
-rw-r--r--opendc-experiments/opendc-experiments-energy21/src/main/resources/application.conf6
2 files changed, 8 insertions, 2 deletions
diff --git a/opendc-experiments/opendc-experiments-capelin/src/main/kotlin/org/opendc/experiments/capelin/monitor/ParquetExperimentMonitor.kt b/opendc-experiments/opendc-experiments-capelin/src/main/kotlin/org/opendc/experiments/capelin/monitor/ParquetExperimentMonitor.kt
index 983b4cff..bfdf5f3e 100644
--- a/opendc-experiments/opendc-experiments-capelin/src/main/kotlin/org/opendc/experiments/capelin/monitor/ParquetExperimentMonitor.kt
+++ b/opendc-experiments/opendc-experiments-capelin/src/main/kotlin/org/opendc/experiments/capelin/monitor/ParquetExperimentMonitor.kt
@@ -43,11 +43,11 @@ private val logger = KotlinLogging.logger {}
*/
public class ParquetExperimentMonitor(base: File, partition: String, bufferSize: Int) : ExperimentMonitor {
private val hostWriter = ParquetHostEventWriter(
- File(base, "host-metrics/$partition/data.parquet"),
+ File(base, "host-metrics/$partition/data.parquet").also { it.parentFile.mkdirs() },
bufferSize
)
private val provisionerWriter = ParquetProvisionerEventWriter(
- File(base, "provisioner-metrics/$partition/data.parquet"),
+ File(base, "provisioner-metrics/$partition/data.parquet").also { it.parentFile.mkdirs() },
bufferSize
)
diff --git a/opendc-experiments/opendc-experiments-energy21/src/main/resources/application.conf b/opendc-experiments/opendc-experiments-energy21/src/main/resources/application.conf
index 3e011862..263da0fe 100644
--- a/opendc-experiments/opendc-experiments-energy21/src/main/resources/application.conf
+++ b/opendc-experiments/opendc-experiments-energy21/src/main/resources/application.conf
@@ -6,3 +6,9 @@ opendc.experiments.energy21 {
# Path to the output directory to write the results to
output-path = output
}
+
+opendc.experiments.capelin {
+ env-path = input/environments/
+ trace-path = input/traces/
+ output-path = output
+}