From 9dba898ba5b1ff55824569ac397c757e7c882794 Mon Sep 17 00:00:00 2001 From: Fabian Mastenbroek Date: Tue, 5 May 2020 16:07:39 +0200 Subject: refactor: Make trace converter more reusable --- .../com/atlarge/opendc/experiments/sc20/TraceConverter.kt | 14 +++++++++----- 1 file changed, 9 insertions(+), 5 deletions(-) diff --git a/opendc/opendc-experiments-sc20/src/main/kotlin/com/atlarge/opendc/experiments/sc20/TraceConverter.kt b/opendc/opendc-experiments-sc20/src/main/kotlin/com/atlarge/opendc/experiments/sc20/TraceConverter.kt index d005a157..c62f59f9 100644 --- a/opendc/opendc-experiments-sc20/src/main/kotlin/com/atlarge/opendc/experiments/sc20/TraceConverter.kt +++ b/opendc/opendc-experiments-sc20/src/main/kotlin/com/atlarge/opendc/experiments/sc20/TraceConverter.kt @@ -36,10 +36,14 @@ import kotlin.math.max import kotlin.math.min /** - * - * @author Fabian Mastenbroek (f.s.mastenbroek@student.tudelft.nl) + * A script to convert a trace in text format into a Parquet trace. */ -fun main() { +fun main(args: Array) { + if (args.size < 2) { + println("error: expected ") + return + } + val metaSchema = SchemaBuilder .record("meta") .namespace("com.atlarge.opendc.format.sc20") @@ -69,8 +73,8 @@ fun main() { val provisionedMemoryCol = 20 val traceInterval = 5 * 60 * 1000L - val dest = File("../traces/solvinity/small-parquet") - val traceDirectory = File("../traces/solvinity/small") + val dest = File(args[0]) + val traceDirectory = File(args[1]) val vms = traceDirectory.walk() .filterNot { it.isDirectory } -- cgit v1.2.3