summaryrefslogtreecommitdiff
path: root/opendc-trace/opendc-trace-api/src/main/kotlin/org/opendc/trace
diff options
context:
space:
mode:
authorDante Niewenhuis <d.niewenhuis@hotmail.com>2024-08-27 13:48:46 +0200
committerGitHub <noreply@github.com>2024-08-27 13:48:46 +0200
commit3363df4c72a064e590ca98f8e01832cfa4e15a3f (patch)
tree9a938700fe08ce344ff5d0d475d0b64d7233d1fc /opendc-trace/opendc-trace-api/src/main/kotlin/org/opendc/trace
parentc21708013f2746807f5bdb3fc47c2b47ed15b7c8 (diff)
Renamed input files and internally server is changed to task (#246)
* Updated SimTrace to use a single ArrayDeque instead of three separate lists for deadline, cpuUsage, and coreCount * Renamed input files to tasks.parquet and fragments.parquet. Renamed server to task. OpenDC nows exports tasks.parquet instead of server.parquet
Diffstat (limited to 'opendc-trace/opendc-trace-api/src/main/kotlin/org/opendc/trace')
-rw-r--r--opendc-trace/opendc-trace-api/src/main/kotlin/org/opendc/trace/formats/opendc/OdcVmTraceFormat.kt8
1 files changed, 4 insertions, 4 deletions
diff --git a/opendc-trace/opendc-trace-api/src/main/kotlin/org/opendc/trace/formats/opendc/OdcVmTraceFormat.kt b/opendc-trace/opendc-trace-api/src/main/kotlin/org/opendc/trace/formats/opendc/OdcVmTraceFormat.kt
index 7a7bc834..2e2617ef 100644
--- a/opendc-trace/opendc-trace-api/src/main/kotlin/org/opendc/trace/formats/opendc/OdcVmTraceFormat.kt
+++ b/opendc-trace/opendc-trace-api/src/main/kotlin/org/opendc/trace/formats/opendc/OdcVmTraceFormat.kt
@@ -131,11 +131,11 @@ public class OdcVmTraceFormat : TraceFormat {
): TableReader {
return when (table) {
TABLE_RESOURCES -> {
- val reader = LocalParquetReader(path.resolve("meta.parquet"), ResourceReadSupport(projection))
+ val reader = LocalParquetReader(path.resolve("tasks.parquet"), ResourceReadSupport(projection))
OdcVmResourceTableReader(reader)
}
TABLE_RESOURCE_STATES -> {
- val reader = LocalParquetReader(path.resolve("trace.parquet"), ResourceStateReadSupport(projection))
+ val reader = LocalParquetReader(path.resolve("fragments.parquet"), ResourceStateReadSupport(projection))
OdcVmResourceStateTableReader(reader)
}
TABLE_INTERFERENCE_GROUPS -> {
@@ -160,7 +160,7 @@ public class OdcVmTraceFormat : TraceFormat {
return when (table) {
TABLE_RESOURCES -> {
val writer =
- LocalParquetWriter.builder(path.resolve("meta.parquet"), ResourceWriteSupport())
+ LocalParquetWriter.builder(path.resolve("tasks.parquet"), ResourceWriteSupport())
.withCompressionCodec(CompressionCodecName.ZSTD)
.withPageWriteChecksumEnabled(true)
.withWriterVersion(ParquetProperties.WriterVersion.PARQUET_2_0)
@@ -170,7 +170,7 @@ public class OdcVmTraceFormat : TraceFormat {
}
TABLE_RESOURCE_STATES -> {
val writer =
- LocalParquetWriter.builder(path.resolve("trace.parquet"), ResourceStateWriteSupport())
+ LocalParquetWriter.builder(path.resolve("fragments.parquet"), ResourceStateWriteSupport())
.withCompressionCodec(CompressionCodecName.ZSTD)
.withDictionaryEncoding("id", true)
.withBloomFilterEnabled("id", true)