diff options
Diffstat (limited to 'simulator/opendc-experiments')
| -rw-r--r-- | simulator/opendc-experiments/opendc-experiments-capelin/src/main/kotlin/org/opendc/experiments/capelin/trace/Sc20RawParquetTraceReader.kt | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/simulator/opendc-experiments/opendc-experiments-capelin/src/main/kotlin/org/opendc/experiments/capelin/trace/Sc20RawParquetTraceReader.kt b/simulator/opendc-experiments/opendc-experiments-capelin/src/main/kotlin/org/opendc/experiments/capelin/trace/Sc20RawParquetTraceReader.kt index 7ea5efe5..ffbf46d4 100644 --- a/simulator/opendc-experiments/opendc-experiments-capelin/src/main/kotlin/org/opendc/experiments/capelin/trace/Sc20RawParquetTraceReader.kt +++ b/simulator/opendc-experiments/opendc-experiments-capelin/src/main/kotlin/org/opendc/experiments/capelin/trace/Sc20RawParquetTraceReader.kt @@ -145,4 +145,13 @@ public class Sc20RawParquetTraceReader(private val path: File) { * Read the entries in the trace. */ public fun read(): List<TraceEntry<SimWorkload>> = entries + + /** + * Create a [TraceReader] instance. + */ + public fun createReader(): TraceReader<SimWorkload> { + return object : TraceReader<SimWorkload>, Iterator<TraceEntry<SimWorkload>> by entries.iterator() { + override fun close() {} + } + } } |
