diff options
| author | Fabian Mastenbroek <mail.fabianm@gmail.com> | 2020-10-01 10:42:36 +0200 |
|---|---|---|
| committer | Fabian Mastenbroek <mail.fabianm@gmail.com> | 2020-10-01 10:47:44 +0200 |
| commit | ebd375d524714708d7b38c0117a77d50d23043a3 (patch) | |
| tree | bb246d18f86e551dd01f92658c6ef2b14a608fc6 /simulator/opendc-format/src/main | |
| parent | afee4c550515dc2f6021be33f58823d279980246 (diff) | |
Add test case for WTA trace parser
Diffstat (limited to 'simulator/opendc-format/src/main')
| -rw-r--r-- | simulator/opendc-format/src/main/kotlin/org/opendc/format/trace/wtf/WtfTraceReader.kt | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/simulator/opendc-format/src/main/kotlin/org/opendc/format/trace/wtf/WtfTraceReader.kt b/simulator/opendc-format/src/main/kotlin/org/opendc/format/trace/wtf/WtfTraceReader.kt index b8f3e771..12a60aec 100644 --- a/simulator/opendc-format/src/main/kotlin/org/opendc/format/trace/wtf/WtfTraceReader.kt +++ b/simulator/opendc-format/src/main/kotlin/org/opendc/format/trace/wtf/WtfTraceReader.kt @@ -55,7 +55,7 @@ class WtfTraceReader(path: String) : TraceReader<Job> { val tasks = mutableMapOf<Long, Task>() val taskDependencies = mutableMapOf<Task, List<Long>>() - val reader = AvroParquetReader.builder<GenericRecord>(Path(path)).build() + val reader = AvroParquetReader.builder<GenericRecord>(Path(path, "tasks/schema-1.0")).build() while (true) { val nextRecord = reader.read() ?: break |