diff options
| author | Fabian Mastenbroek <mail.fabianm@gmail.com> | 2021-06-08 23:46:07 +0200 |
|---|---|---|
| committer | Fabian Mastenbroek <mail.fabianm@gmail.com> | 2021-06-09 12:39:05 +0200 |
| commit | 1b52a443e508bc4130071e67a1a8e17a6714c6b8 (patch) | |
| tree | 573071cbee5abe0a232cf1a61bfb60a23f5c72cb /opendc-format/src/test/kotlin | |
| parent | 9097811e0ac6872de3e4ff5f521d8859870b1000 (diff) | |
format: Use LocalInputFile for Parquet reader
This change updates the format implementations that use Parquet by
switching to our InputFile implementation for local files, which
eliminates the need for Hadoop's filesystem support.
Diffstat (limited to 'opendc-format/src/test/kotlin')
| -rw-r--r-- | opendc-format/src/test/kotlin/org/opendc/format/trace/wtf/WtfTraceReaderTest.kt | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/opendc-format/src/test/kotlin/org/opendc/format/trace/wtf/WtfTraceReaderTest.kt b/opendc-format/src/test/kotlin/org/opendc/format/trace/wtf/WtfTraceReaderTest.kt index bcfa7553..31ae03e0 100644 --- a/opendc-format/src/test/kotlin/org/opendc/format/trace/wtf/WtfTraceReaderTest.kt +++ b/opendc-format/src/test/kotlin/org/opendc/format/trace/wtf/WtfTraceReaderTest.kt @@ -24,6 +24,7 @@ package org.opendc.format.trace.wtf import org.junit.jupiter.api.Assertions.* import org.junit.jupiter.api.Test +import java.io.File /** * Test suite for the [WtfTraceReader] class. @@ -34,7 +35,7 @@ class WtfTraceReaderTest { */ @Test fun testParseWtf() { - val reader = WtfTraceReader("src/test/resources/wtf-trace") + val reader = WtfTraceReader(File("src/test/resources/wtf-trace")) var entry = reader.next() assertEquals(0, entry.start) assertEquals(23, entry.workload.tasks.size) |