merge: Add support for trace writing

This pull request extends the trace API to support writing new traces.

- Unify columns of different tables 
- Support column lookup via index
- Use index lookup in trace loader 
- Add property for describing partition keys
- Simplify TraceFormat SPI interface
- Add support for writing traces

**Breaking API Changes**

- `TraceFormat` SPI interface has been redesigned.

1 files changed, 10 insertions, 47 deletions

diff --git a/opendc-trace/opendc-trace-wtf/src/test/kotlin/org/opendc/trace/wtf/WtfTraceFormatTest.kt b/opendc-trace/opendc-trace-wtf/src/test/kotlin/org/opendc/trace/wtf/WtfTraceFormatTest.kt
index b155f265..09c3703a 100644
--- a/opendc-trace/opendc-trace-wtf/src/test/kotlin/org/opendc/trace/wtf/WtfTraceFormatTest.kt
+++ b/opendc-trace/opendc-trace-wtf/src/test/kotlin/org/opendc/trace/wtf/WtfTraceFormatTest.kt
@@ -26,8 +26,7 @@ import org.junit.jupiter.api.Assertions.*
 import org.junit.jupiter.api.Test
 import org.junit.jupiter.api.assertThrows
 import org.opendc.trace.*
-import java.io.File
-import java.net.URL
+import java.nio.file.Paths
 import java.time.Duration
 import java.time.Instant
 
@@ -35,51 +34,25 @@ import java.time.Instant
  * Test suite for the [WtfTraceFormat] class.
  */
 class WtfTraceFormatTest {
-    @Test
-    fun testTraceExists() {
-        val input = File("src/test/resources/wtf-trace").toURI().toURL()
-        val format = WtfTraceFormat()
-        org.junit.jupiter.api.assertDoesNotThrow {
-            format.open(input)
-        }
-    }
-
-    @Test
-    fun testTraceDoesNotExists() {
-        val input = File("src/test/resources/wtf-trace").toURI().toURL()
-        val format = WtfTraceFormat()
-        assertThrows<IllegalArgumentException> {
-            format.open(URL(input.toString() + "help"))
-        }
-    }
+    private val format = WtfTraceFormat()
 
     @Test
     fun testTables() {
-        val input = File("src/test/resources/wtf-trace").toURI().toURL()
-        val format = WtfTraceFormat()
-        val trace = format.open(input)
-
-        assertEquals(listOf(TABLE_TASKS), trace.tables)
+        val path = Paths.get("src/test/resources/wtf-trace")
+        assertEquals(listOf(TABLE_TASKS), format.getTables(path))
     }
 
     @Test
     fun testTableExists() {
-        val input = File("src/test/resources/wtf-trace").toURI().toURL()
-        val format = WtfTraceFormat()
-        val table = format.open(input).getTable(TABLE_TASKS)
-
-        assertNotNull(table)
-        org.junit.jupiter.api.assertDoesNotThrow { table!!.newReader() }
+        val path = Paths.get("src/test/resources/wtf-trace")
+        assertDoesNotThrow { format.getDetails(path, TABLE_TASKS) }
     }
 
     @Test
     fun testTableDoesNotExist() {
-        val input = File("src/test/resources/wtf-trace").toURI().toURL()
-        val format = WtfTraceFormat()
-        val trace = format.open(input)
+        val path = Paths.get("src/test/resources/wtf-trace")
 
-        assertFalse(trace.containsTable("test"))
-        assertNull(trace.getTable("test"))
+        assertThrows<IllegalArgumentException> { format.getDetails(path, "test") }
     }
 
     /**
@@ -87,9 +60,8 @@ class WtfTraceFormatTest {
      */
     @Test
     fun testTableReader() {
-        val input = File("src/test/resources/wtf-trace")
-        val trace = WtfTraceFormat().open(input.toURI().toURL())
-        val reader = trace.getTable(TABLE_TASKS)!!.newReader()
+        val path = Paths.get("src/test/resources/wtf-trace")
+        val reader = format.newReader(path, TABLE_TASKS)
 
         assertAll(
             { assertTrue(reader.nextRow()) },
@@ -111,13 +83,4 @@ class WtfTraceFormatTest {
 
         reader.close()
     }
-
-    @Test
-    fun testTableReaderPartition() {
-        val input = File("src/test/resources/wtf-trace").toURI().toURL()
-        val format = WtfTraceFormat()
-        val table = format.open(input).getTable(TABLE_TASKS)!!
-
-        assertThrows<IllegalArgumentException> { table.newReader("test") }
-    }
 }