Revamped the trace system. All TraceFormat files are now in the api m… (#216)

* Revamped the trace system. All TraceFormat files are now in the api module. This fixes some problems with not being able to use types of traces

* applied spotless

6 files changed, 0 insertions, 367 deletions

diff --git a/opendc-trace/opendc-trace-opendc/src/test/kotlin/org/opendc/trace/opendc/OdcVmTraceFormatTest.kt b/opendc-trace/opendc-trace-opendc/src/test/kotlin/org/opendc/trace/opendc/OdcVmTraceFormatTest.kt
deleted file mode 100644
index c9fa21c3..00000000
--- a/opendc-trace/opendc-trace-opendc/src/test/kotlin/org/opendc/trace/opendc/OdcVmTraceFormatTest.kt
+++ /dev/null
@@ -1,347 +0,0 @@
-/*
- * Copyright (c) 2021 AtLarge Research
- *
- * Permission is hereby granted, free of charge, to any person obtaining a copy
- * of this software and associated documentation files (the "Software"), to deal
- * in the Software without restriction, including without limitation the rights
- * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
- * copies of the Software, and to permit persons to whom the Software is
- * furnished to do so, subject to the following conditions:
- *
- * The above copyright notice and this permission notice shall be included in all
- * copies or substantial portions of the Software.
- *
- * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
- * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
- * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
- * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
- * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
- * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
- * SOFTWARE.
- */
-
-package org.opendc.trace.opendc
-
-import org.junit.jupiter.api.Assertions.assertAll
-import org.junit.jupiter.api.Assertions.assertEquals
-import org.junit.jupiter.api.Assertions.assertFalse
-import org.junit.jupiter.api.Assertions.assertTrue
-import org.junit.jupiter.api.BeforeEach
-import org.junit.jupiter.api.DisplayName
-import org.junit.jupiter.api.Nested
-import org.junit.jupiter.api.Test
-import org.junit.jupiter.api.assertDoesNotThrow
-import org.junit.jupiter.api.assertThrows
-import org.junit.jupiter.params.ParameterizedTest
-import org.junit.jupiter.params.provider.ValueSource
-import org.opendc.trace.TableColumn
-import org.opendc.trace.TableReader
-import org.opendc.trace.TableWriter
-import org.opendc.trace.conv.INTERFERENCE_GROUP_MEMBERS
-import org.opendc.trace.conv.INTERFERENCE_GROUP_SCORE
-import org.opendc.trace.conv.INTERFERENCE_GROUP_TARGET
-import org.opendc.trace.conv.TABLE_INTERFERENCE_GROUPS
-import org.opendc.trace.conv.TABLE_RESOURCES
-import org.opendc.trace.conv.TABLE_RESOURCE_STATES
-import org.opendc.trace.conv.resourceCpuCapacity
-import org.opendc.trace.conv.resourceCpuCount
-import org.opendc.trace.conv.resourceID
-import org.opendc.trace.conv.resourceMemCapacity
-import org.opendc.trace.conv.resourceStartTime
-import org.opendc.trace.conv.resourceStateCpuUsage
-import org.opendc.trace.conv.resourceStateTimestamp
-import org.opendc.trace.conv.resourceStopTime
-import org.opendc.trace.testkit.TableReaderTestKit
-import org.opendc.trace.testkit.TableWriterTestKit
-import java.nio.file.Files
-import java.nio.file.Paths
-import java.time.Instant
-
-/**
- * Test suite for the [OdcVmTraceFormat] implementation.
- */
-@DisplayName("OdcVmTraceFormat")
-internal class OdcVmTraceFormatTest {
-    private val format = OdcVmTraceFormat()
-
-    @Test
-    fun testTables() {
-        val path = Paths.get("src/test/resources/trace-v2.1")
-
-        assertEquals(listOf(TABLE_RESOURCES, TABLE_RESOURCE_STATES, TABLE_INTERFERENCE_GROUPS), format.getTables(path))
-    }
-
-    @Test
-    fun testTableExists() {
-        val path = Paths.get("src/test/resources/trace-v2.1")
-
-        assertDoesNotThrow { format.getDetails(path, TABLE_RESOURCE_STATES) }
-    }
-
-    @Test
-    fun testTableDoesNotExist() {
-        val path = Paths.get("src/test/resources/trace-v2.1")
-        assertThrows<IllegalArgumentException> { format.getDetails(path, "test") }
-    }
-
-    @ParameterizedTest
-    @ValueSource(strings = ["trace-v2.0", "trace-v2.1"])
-    fun testResources(name: String) {
-        val path = Paths.get("src/test/resources/$name")
-        val reader = format.newReader(path, TABLE_RESOURCES, listOf(resourceID, resourceStartTime))
-
-        assertAll(
-            { assertTrue(reader.nextRow()) },
-            { assertEquals("1019", reader.getString(resourceID)) },
-            { assertEquals(Instant.ofEpochMilli(1376314846000), reader.getInstant(resourceStartTime)) },
-            { assertTrue(reader.nextRow()) },
-            { assertEquals("1023", reader.getString(resourceID)) },
-            { assertTrue(reader.nextRow()) },
-            { assertEquals("1052", reader.getString(resourceID)) },
-            { assertTrue(reader.nextRow()) },
-            { assertEquals("1073", reader.getString(resourceID)) },
-            { assertFalse(reader.nextRow()) },
-        )
-
-        reader.close()
-    }
-
-    @Test
-    fun testResourcesWrite() {
-        val path = Files.createTempDirectory("opendc")
-        val writer = format.newWriter(path, TABLE_RESOURCES)
-
-        writer.startRow()
-        writer.setString(resourceID, "1019")
-        writer.setInstant(resourceStartTime, Instant.EPOCH)
-        writer.setInstant(resourceStopTime, Instant.EPOCH)
-        writer.setInt(resourceCpuCount, 1)
-        writer.setDouble(resourceCpuCapacity, 1024.0)
-        writer.setDouble(resourceMemCapacity, 1024.0)
-        writer.endRow()
-        writer.close()
-
-        val reader = format.newReader(path, TABLE_RESOURCES, null)
-
-        assertAll(
-            { assertTrue(reader.nextRow()) },
-            { assertEquals("1019", reader.getString(resourceID)) },
-            { assertEquals(Instant.EPOCH, reader.getInstant(resourceStartTime)) },
-            { assertEquals(Instant.EPOCH, reader.getInstant(resourceStopTime)) },
-            { assertEquals(1, reader.getInt(resourceCpuCount)) },
-            { assertEquals(1024.0, reader.getDouble(resourceCpuCapacity)) },
-            { assertEquals(1024.0, reader.getDouble(resourceMemCapacity)) },
-            { assertFalse(reader.nextRow()) },
-        )
-
-        reader.close()
-    }
-
-    @ParameterizedTest
-    @ValueSource(strings = ["trace-v2.0", "trace-v2.1"])
-    fun testSmoke(name: String) {
-        val path = Paths.get("src/test/resources/$name")
-        val reader =
-            format.newReader(
-                path,
-                TABLE_RESOURCE_STATES,
-                listOf(resourceID, resourceStateTimestamp, resourceStateCpuUsage),
-            )
-
-        assertAll(
-            { assertTrue(reader.nextRow()) },
-            { assertEquals("1019", reader.getString(resourceID)) },
-            { assertEquals(1376314846, reader.getInstant(resourceStateTimestamp)?.epochSecond) },
-            { assertEquals(0.0, reader.getDouble(resourceStateCpuUsage), 0.01) },
-        )
-
-        reader.close()
-    }
-
-    @Test
-    fun testResourceStatesWrite() {
-        val path = Files.createTempDirectory("opendc")
-        val writer = format.newWriter(path, TABLE_RESOURCE_STATES)
-
-        writer.startRow()
-        writer.setString(resourceID, "1019")
-        writer.setInstant(resourceStateTimestamp, Instant.EPOCH)
-        writer.setDouble(resourceStateCpuUsage, 23.0)
-        writer.setInt(resourceCpuCount, 1)
-        writer.endRow()
-        writer.close()
-
-        val reader = format.newReader(path, TABLE_RESOURCE_STATES, null)
-
-        assertAll(
-            { assertTrue(reader.nextRow()) },
-            { assertEquals("1019", reader.getString(resourceID)) },
-            { assertEquals(Instant.EPOCH, reader.getInstant(resourceStateTimestamp)) },
-            { assertEquals(1, reader.getInt(resourceCpuCount)) },
-            { assertEquals(23.0, reader.getDouble(resourceStateCpuUsage)) },
-            { assertFalse(reader.nextRow()) },
-        )
-
-        reader.close()
-    }
-
-    @Test
-    fun testInterferenceGroups() {
-        val path = Paths.get("src/test/resources/trace-v2.1")
-        val reader =
-            format.newReader(
-                path,
-                TABLE_INTERFERENCE_GROUPS,
-                listOf(INTERFERENCE_GROUP_MEMBERS, INTERFERENCE_GROUP_TARGET, INTERFERENCE_GROUP_SCORE),
-            )
-
-        assertAll(
-            { assertTrue(reader.nextRow()) },
-            { assertEquals(setOf("1019", "1023", "1052"), reader.getSet(INTERFERENCE_GROUP_MEMBERS, String::class.java)) },
-            { assertEquals(0.0, reader.getDouble(INTERFERENCE_GROUP_TARGET)) },
-            { assertEquals(0.8830158730158756, reader.getDouble(INTERFERENCE_GROUP_SCORE)) },
-            { assertTrue(reader.nextRow()) },
-            { assertEquals(setOf("1023", "1052", "1073"), reader.getSet(INTERFERENCE_GROUP_MEMBERS, String::class.java)) },
-            { assertEquals(0.0, reader.getDouble(INTERFERENCE_GROUP_TARGET)) },
-            { assertEquals(0.7133055555552751, reader.getDouble(INTERFERENCE_GROUP_SCORE)) },
-            { assertFalse(reader.nextRow()) },
-        )
-
-        reader.close()
-    }
-
-    @Test
-    fun testInterferenceGroupsEmpty() {
-        val path = Paths.get("src/test/resources/trace-v2.0")
-        val reader = format.newReader(path, TABLE_INTERFERENCE_GROUPS, listOf(INTERFERENCE_GROUP_MEMBERS))
-
-        assertFalse(reader.nextRow())
-        reader.close()
-    }
-
-    @Test
-    fun testInterferenceGroupsWrite() {
-        val path = Files.createTempDirectory("opendc")
-        val writer = format.newWriter(path, TABLE_INTERFERENCE_GROUPS)
-
-        writer.startRow()
-        writer.setSet(INTERFERENCE_GROUP_MEMBERS, setOf("a", "b", "c"))
-        writer.setDouble(INTERFERENCE_GROUP_TARGET, 0.5)
-        writer.setDouble(INTERFERENCE_GROUP_SCORE, 0.8)
-        writer.endRow()
-        writer.flush()
-
-        writer.startRow()
-        writer.setSet(INTERFERENCE_GROUP_MEMBERS, setOf("a", "b", "d"))
-        writer.setDouble(INTERFERENCE_GROUP_TARGET, 0.5)
-        writer.setDouble(INTERFERENCE_GROUP_SCORE, 0.9)
-        writer.endRow()
-        writer.close()
-
-        val reader = format.newReader(path, TABLE_INTERFERENCE_GROUPS, null)
-
-        assertAll(
-            { assertTrue(reader.nextRow()) },
-            { assertEquals(setOf("a", "b", "c"), reader.getSet(INTERFERENCE_GROUP_MEMBERS, String::class.java)) },
-            { assertEquals(0.5, reader.getDouble(INTERFERENCE_GROUP_TARGET)) },
-            { assertEquals(0.8, reader.getDouble(INTERFERENCE_GROUP_SCORE)) },
-            { assertTrue(reader.nextRow()) },
-            { assertEquals(setOf("a", "b", "d"), reader.getSet(INTERFERENCE_GROUP_MEMBERS, String::class.java)) },
-            { assertEquals(0.5, reader.getDouble(INTERFERENCE_GROUP_TARGET)) },
-            { assertEquals(0.9, reader.getDouble(INTERFERENCE_GROUP_SCORE)) },
-            { assertFalse(reader.nextRow()) },
-        )
-
-        reader.close()
-    }
-
-    @DisplayName("TableReader for Resources")
-    @Nested
-    inner class ResourcesTableReaderTest : TableReaderTestKit() {
-        override lateinit var reader: TableReader
-        override lateinit var columns: List<TableColumn>
-
-        @BeforeEach
-        fun setUp() {
-            val path = Paths.get("src/test/resources/trace-v2.1")
-
-            columns = format.getDetails(path, TABLE_RESOURCES).columns
-            reader = format.newReader(path, TABLE_RESOURCES, null)
-        }
-    }
-
-    @DisplayName("TableWriter for Resources")
-    @Nested
-    inner class ResourcesTableWriterTest : TableWriterTestKit() {
-        override lateinit var writer: TableWriter
-        override lateinit var columns: List<TableColumn>
-
-        @BeforeEach
-        fun setUp() {
-            val path = Files.createTempDirectory("opendc")
-
-            columns = format.getDetails(Paths.get("src/test/resources/trace-v2.1"), TABLE_RESOURCES).columns
-            writer = format.newWriter(path, TABLE_RESOURCES)
-        }
-    }
-
-    @DisplayName("TableReader for Resource States")
-    @Nested
-    inner class ResourceStatesTableReaderTest : TableReaderTestKit() {
-        override lateinit var reader: TableReader
-        override lateinit var columns: List<TableColumn>
-
-        @BeforeEach
-        fun setUp() {
-            val path = Paths.get("src/test/resources/trace-v2.1")
-
-            columns = format.getDetails(path, TABLE_RESOURCE_STATES).columns
-            reader = format.newReader(path, TABLE_RESOURCE_STATES, null)
-        }
-    }
-
-    @DisplayName("TableWriter for Resource States")
-    @Nested
-    inner class ResourceStatesTableWriterTest : TableWriterTestKit() {
-        override lateinit var writer: TableWriter
-        override lateinit var columns: List<TableColumn>
-
-        @BeforeEach
-        fun setUp() {
-            val path = Files.createTempDirectory("opendc")
-
-            columns = format.getDetails(Paths.get("src/test/resources/trace-v2.1"), TABLE_RESOURCE_STATES).columns
-            writer = format.newWriter(path, TABLE_RESOURCE_STATES)
-        }
-    }
-
-    @DisplayName("TableReader for Interference Groups")
-    @Nested
-    inner class InterferenceGroupsTableReaderTest : TableReaderTestKit() {
-        override lateinit var reader: TableReader
-        override lateinit var columns: List<TableColumn>
-
-        @BeforeEach
-        fun setUp() {
-            val path = Paths.get("src/test/resources/trace-v2.1")
-
-            columns = format.getDetails(path, TABLE_INTERFERENCE_GROUPS).columns
-            reader = format.newReader(path, TABLE_INTERFERENCE_GROUPS, null)
-        }
-    }
-
-    @DisplayName("TableWriter for Interference Groups")
-    @Nested
-    inner class InterferenceGroupsTableWriterTest : TableWriterTestKit() {
-        override lateinit var writer: TableWriter
-        override lateinit var columns: List<TableColumn>
-
-        @BeforeEach
-        fun setUp() {
-            val path = Files.createTempDirectory("opendc")
-
-            columns = format.getDetails(Paths.get("src/test/resources/trace-v2.1"), TABLE_INTERFERENCE_GROUPS).columns
-            writer = format.newWriter(path, TABLE_INTERFERENCE_GROUPS)
-        }
-    }
-}
diff --git a/opendc-trace/opendc-trace-opendc/src/test/resources/trace-v2.0/meta.parquet b/opendc-trace/opendc-trace-opendc/src/test/resources/trace-v2.0/meta.parquet
deleted file mode 100644
index d6ff09d8..00000000
--- a/opendc-trace/opendc-trace-opendc/src/test/resources/trace-v2.0/meta.parquet
+++ /dev/null
diff --git a/opendc-trace/opendc-trace-opendc/src/test/resources/trace-v2.0/trace.parquet b/opendc-trace/opendc-trace-opendc/src/test/resources/trace-v2.0/trace.parquet
deleted file mode 100644
index 5b6fa6b7..00000000
--- a/opendc-trace/opendc-trace-opendc/src/test/resources/trace-v2.0/trace.parquet
+++ /dev/null
diff --git a/opendc-trace/opendc-trace-opendc/src/test/resources/trace-v2.1/interference-model.json b/opendc-trace/opendc-trace-opendc/src/test/resources/trace-v2.1/interference-model.json
deleted file mode 100644
index 6a0616d9..00000000
--- a/opendc-trace/opendc-trace-opendc/src/test/resources/trace-v2.1/interference-model.json
+++ /dev/null
@@ -1,20 +0,0 @@
-[
-    {
-        "vms": [
-            "1019",
-            "1023",
-            "1052"
-        ],
-        "minServerLoad": 0.0,
-        "performanceScore": 0.8830158730158756
-    },
-    {
-        "vms": [
-            "1023",
-            "1052",
-            "1073"
-        ],
-        "minServerLoad": 0.0,
-        "performanceScore": 0.7133055555552751
-    }
-]
diff --git a/opendc-trace/opendc-trace-opendc/src/test/resources/trace-v2.1/meta.parquet b/opendc-trace/opendc-trace-opendc/src/test/resources/trace-v2.1/meta.parquet
deleted file mode 100644
index d8184945..00000000
--- a/opendc-trace/opendc-trace-opendc/src/test/resources/trace-v2.1/meta.parquet
+++ /dev/null
diff --git a/opendc-trace/opendc-trace-opendc/src/test/resources/trace-v2.1/trace.parquet b/opendc-trace/opendc-trace-opendc/src/test/resources/trace-v2.1/trace.parquet
deleted file mode 100644
index 00ab5835..00000000
--- a/opendc-trace/opendc-trace-opendc/src/test/resources/trace-v2.1/trace.parquet
+++ /dev/null