summaryrefslogtreecommitdiff
path: root/opendc-trace/opendc-trace-azure/src/main
diff options
context:
space:
mode:
authorFabian Mastenbroek <mail.fabianm@gmail.com>2021-09-20 15:40:13 +0200
committerFabian Mastenbroek <mail.fabianm@gmail.com>2021-09-20 15:40:13 +0200
commit140aafdaa711b0fdeacf99b9c7e70b706b8490f4 (patch)
treec814e3a92eddfc123d8754b299257058d4763710 /opendc-trace/opendc-trace-azure/src/main
parente765316cfc089dd50602759ea7afbcc7a3cd4c00 (diff)
feat(trace): Add property for describing partition keys
Diffstat (limited to 'opendc-trace/opendc-trace-azure/src/main')
-rw-r--r--opendc-trace/opendc-trace-azure/src/main/kotlin/org/opendc/trace/azure/AzureResourceStateTable.kt2
-rw-r--r--opendc-trace/opendc-trace-azure/src/main/kotlin/org/opendc/trace/azure/AzureResourceTable.kt2
2 files changed, 4 insertions, 0 deletions
diff --git a/opendc-trace/opendc-trace-azure/src/main/kotlin/org/opendc/trace/azure/AzureResourceStateTable.kt b/opendc-trace/opendc-trace-azure/src/main/kotlin/org/opendc/trace/azure/AzureResourceStateTable.kt
index 8f2f5cc9..285e7216 100644
--- a/opendc-trace/opendc-trace-azure/src/main/kotlin/org/opendc/trace/azure/AzureResourceStateTable.kt
+++ b/opendc-trace/opendc-trace-azure/src/main/kotlin/org/opendc/trace/azure/AzureResourceStateTable.kt
@@ -53,6 +53,8 @@ internal class AzureResourceStateTable(private val factory: CsvFactory, path: Pa
RESOURCE_STATE_CPU_USAGE_PCT
)
+ override val partitionKeys: List<TableColumn<*>> = listOf(RESOURCE_STATE_TIMESTAMP)
+
override fun newReader(): TableReader {
val it = partitions.iterator()
diff --git a/opendc-trace/opendc-trace-azure/src/main/kotlin/org/opendc/trace/azure/AzureResourceTable.kt b/opendc-trace/opendc-trace-azure/src/main/kotlin/org/opendc/trace/azure/AzureResourceTable.kt
index 96ee3158..ff7af172 100644
--- a/opendc-trace/opendc-trace-azure/src/main/kotlin/org/opendc/trace/azure/AzureResourceTable.kt
+++ b/opendc-trace/opendc-trace-azure/src/main/kotlin/org/opendc/trace/azure/AzureResourceTable.kt
@@ -42,6 +42,8 @@ internal class AzureResourceTable(private val factory: CsvFactory, private val p
RESOURCE_MEM_CAPACITY
)
+ override val partitionKeys: List<TableColumn<*>> = emptyList()
+
override fun newReader(): TableReader {
return AzureResourceTableReader(factory.createParser(path.resolve("vmtable/vmtable.csv").toFile()))
}