diff options
| author | Dante Niewenhuis <d.niewenhuis@hotmail.com> | 2024-08-27 13:48:46 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-08-27 13:48:46 +0200 |
| commit | 3363df4c72a064e590ca98f8e01832cfa4e15a3f (patch) | |
| tree | 9a938700fe08ce344ff5d0d475d0b64d7233d1fc /opendc-trace/opendc-trace-api/src/main/kotlin/org/opendc/trace | |
| parent | c21708013f2746807f5bdb3fc47c2b47ed15b7c8 (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.kt | 8 |
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) |
