diff options
Diffstat (limited to 'opendc-trace/opendc-trace-wtf/src')
| -rw-r--r-- | opendc-trace/opendc-trace-wtf/src/main/kotlin/org/opendc/trace/wtf/WtfTraceFormat.kt | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/opendc-trace/opendc-trace-wtf/src/main/kotlin/org/opendc/trace/wtf/WtfTraceFormat.kt b/opendc-trace/opendc-trace-wtf/src/main/kotlin/org/opendc/trace/wtf/WtfTraceFormat.kt index aae71c58..d6e42c8c 100644 --- a/opendc-trace/opendc-trace-wtf/src/main/kotlin/org/opendc/trace/wtf/WtfTraceFormat.kt +++ b/opendc-trace/opendc-trace-wtf/src/main/kotlin/org/opendc/trace/wtf/WtfTraceFormat.kt @@ -66,8 +66,7 @@ public class WtfTraceFormat : TraceFormat { override fun newReader(path: Path, table: String): TableReader { return when (table) { TABLE_TASKS -> { - val factory = LocalParquetReader.custom(TaskReadSupport()) - val reader = LocalParquetReader(path.resolve("tasks/schema-1.0"), factory) + val reader = LocalParquetReader(path.resolve("tasks/schema-1.0"), TaskReadSupport()) WtfTaskTableReader(reader) } else -> throw IllegalArgumentException("Table $table not supported") |