summaryrefslogtreecommitdiff
path: root/opendc-trace/opendc-trace-bitbrains/src
diff options
context:
space:
mode:
authorFabian Mastenbroek <mail.fabianm@gmail.com>2021-09-20 11:48:18 +0200
committerFabian Mastenbroek <mail.fabianm@gmail.com>2021-09-20 11:48:18 +0200
commit55a4c8208cc44ac626f7b8c61a19d5ec725ec936 (patch)
treef023a3f714eaf2c5707ad9203558dabe535396e6 /opendc-trace/opendc-trace-bitbrains/src
parent453c25c4b453fa0af26bebbd8863abfb79218119 (diff)
refactor(trace): Unify columns of different tables
This change unifies columns of different tables used by trace formats. This concretely means that instead of having columns specific per table (e.g., RESOURCE_ID and RESOURCE_STATE_ID), with this changes these columns are shared between the tables with a single definition (RESOURCE_ID).
Diffstat (limited to 'opendc-trace/opendc-trace-bitbrains/src')
-rw-r--r--opendc-trace/opendc-trace-bitbrains/src/main/kotlin/org/opendc/trace/bitbrains/BitbrainsExResourceStateTable.kt10
-rw-r--r--opendc-trace/opendc-trace-bitbrains/src/main/kotlin/org/opendc/trace/bitbrains/BitbrainsExResourceStateTableReader.kt26
-rw-r--r--opendc-trace/opendc-trace-bitbrains/src/main/kotlin/org/opendc/trace/bitbrains/BitbrainsResourceStateTable.kt8
-rw-r--r--opendc-trace/opendc-trace-bitbrains/src/main/kotlin/org/opendc/trace/bitbrains/BitbrainsResourceStateTableReader.kt22
-rw-r--r--opendc-trace/opendc-trace-bitbrains/src/main/kotlin/org/opendc/trace/bitbrains/BitbrainsResourceTableReader.kt2
5 files changed, 34 insertions, 34 deletions
diff --git a/opendc-trace/opendc-trace-bitbrains/src/main/kotlin/org/opendc/trace/bitbrains/BitbrainsExResourceStateTable.kt b/opendc-trace/opendc-trace-bitbrains/src/main/kotlin/org/opendc/trace/bitbrains/BitbrainsExResourceStateTable.kt
index 4a60dff3..44a6c26e 100644
--- a/opendc-trace/opendc-trace-bitbrains/src/main/kotlin/org/opendc/trace/bitbrains/BitbrainsExResourceStateTable.kt
+++ b/opendc-trace/opendc-trace-bitbrains/src/main/kotlin/org/opendc/trace/bitbrains/BitbrainsExResourceStateTable.kt
@@ -47,16 +47,16 @@ internal class BitbrainsExResourceStateTable(path: Path) : Table {
override val isSynthetic: Boolean = false
override val columns: List<TableColumn<*>> = listOf(
- RESOURCE_STATE_ID,
- RESOURCE_STATE_CLUSTER_ID,
+ RESOURCE_ID,
+ RESOURCE_CLUSTER_ID,
RESOURCE_STATE_TIMESTAMP,
- RESOURCE_STATE_CPU_COUNT,
- RESOURCE_STATE_CPU_CAPACITY,
+ RESOURCE_CPU_COUNT,
+ RESOURCE_CPU_CAPACITY,
RESOURCE_STATE_CPU_USAGE,
RESOURCE_STATE_CPU_USAGE_PCT,
RESOURCE_STATE_CPU_DEMAND,
RESOURCE_STATE_CPU_READY_PCT,
- RESOURCE_STATE_MEM_CAPACITY,
+ RESOURCE_MEM_CAPACITY,
RESOURCE_STATE_DISK_READ,
RESOURCE_STATE_DISK_WRITE,
)
diff --git a/opendc-trace/opendc-trace-bitbrains/src/main/kotlin/org/opendc/trace/bitbrains/BitbrainsExResourceStateTableReader.kt b/opendc-trace/opendc-trace-bitbrains/src/main/kotlin/org/opendc/trace/bitbrains/BitbrainsExResourceStateTableReader.kt
index f1cf7307..5619e839 100644
--- a/opendc-trace/opendc-trace-bitbrains/src/main/kotlin/org/opendc/trace/bitbrains/BitbrainsExResourceStateTableReader.kt
+++ b/opendc-trace/opendc-trace-bitbrains/src/main/kotlin/org/opendc/trace/bitbrains/BitbrainsExResourceStateTableReader.kt
@@ -90,16 +90,16 @@ internal class BitbrainsExResourceStateTableReader(private val reader: BufferedR
override fun hasColumn(column: TableColumn<*>): Boolean {
return when (column) {
- RESOURCE_STATE_ID -> true
- RESOURCE_STATE_CLUSTER_ID -> true
+ RESOURCE_ID -> true
+ RESOURCE_CLUSTER_ID -> true
RESOURCE_STATE_TIMESTAMP -> true
- RESOURCE_STATE_CPU_COUNT -> true
- RESOURCE_STATE_CPU_CAPACITY -> true
+ RESOURCE_CPU_COUNT -> true
+ RESOURCE_CPU_CAPACITY -> true
RESOURCE_STATE_CPU_USAGE -> true
RESOURCE_STATE_CPU_USAGE_PCT -> true
RESOURCE_STATE_CPU_DEMAND -> true
RESOURCE_STATE_CPU_READY_PCT -> true
- RESOURCE_STATE_MEM_CAPACITY -> true
+ RESOURCE_MEM_CAPACITY -> true
RESOURCE_STATE_DISK_READ -> true
RESOURCE_STATE_DISK_WRITE -> true
else -> false
@@ -108,14 +108,14 @@ internal class BitbrainsExResourceStateTableReader(private val reader: BufferedR
override fun <T> get(column: TableColumn<T>): T {
val res: Any? = when (column) {
- RESOURCE_STATE_ID -> id
- RESOURCE_STATE_CLUSTER_ID -> cluster
+ RESOURCE_ID -> id
+ RESOURCE_CLUSTER_ID -> cluster
RESOURCE_STATE_TIMESTAMP -> timestamp
- RESOURCE_STATE_CPU_COUNT -> getInt(RESOURCE_STATE_CPU_COUNT)
- RESOURCE_STATE_CPU_CAPACITY -> getDouble(RESOURCE_STATE_CPU_CAPACITY)
+ RESOURCE_CPU_COUNT -> getInt(RESOURCE_CPU_COUNT)
+ RESOURCE_CPU_CAPACITY -> getDouble(RESOURCE_CPU_CAPACITY)
RESOURCE_STATE_CPU_USAGE -> getDouble(RESOURCE_STATE_CPU_USAGE)
RESOURCE_STATE_CPU_USAGE_PCT -> getDouble(RESOURCE_STATE_CPU_USAGE_PCT)
- RESOURCE_STATE_MEM_CAPACITY -> getDouble(RESOURCE_STATE_MEM_CAPACITY)
+ RESOURCE_MEM_CAPACITY -> getDouble(RESOURCE_MEM_CAPACITY)
RESOURCE_STATE_DISK_READ -> getDouble(RESOURCE_STATE_DISK_READ)
RESOURCE_STATE_DISK_WRITE -> getDouble(RESOURCE_STATE_DISK_WRITE)
else -> throw IllegalArgumentException("Invalid column")
@@ -134,7 +134,7 @@ internal class BitbrainsExResourceStateTableReader(private val reader: BufferedR
override fun getInt(column: TableColumn<Int>): Int {
return when (column) {
- RESOURCE_STATE_CPU_COUNT -> cpuCores
+ RESOURCE_CPU_COUNT -> cpuCores
else -> throw IllegalArgumentException("Invalid column")
}
}
@@ -145,11 +145,11 @@ internal class BitbrainsExResourceStateTableReader(private val reader: BufferedR
override fun getDouble(column: TableColumn<Double>): Double {
return when (column) {
- RESOURCE_STATE_CPU_CAPACITY -> cpuCapacity
+ RESOURCE_CPU_CAPACITY -> cpuCapacity
RESOURCE_STATE_CPU_USAGE -> cpuUsage
RESOURCE_STATE_CPU_USAGE_PCT -> cpuUsage / cpuCapacity
RESOURCE_STATE_CPU_DEMAND -> cpuDemand
- RESOURCE_STATE_MEM_CAPACITY -> memCapacity
+ RESOURCE_MEM_CAPACITY -> memCapacity
RESOURCE_STATE_DISK_READ -> diskRead
RESOURCE_STATE_DISK_WRITE -> diskWrite
else -> throw IllegalArgumentException("Invalid column")
diff --git a/opendc-trace/opendc-trace-bitbrains/src/main/kotlin/org/opendc/trace/bitbrains/BitbrainsResourceStateTable.kt b/opendc-trace/opendc-trace-bitbrains/src/main/kotlin/org/opendc/trace/bitbrains/BitbrainsResourceStateTable.kt
index 7241b18b..f68e61dc 100644
--- a/opendc-trace/opendc-trace-bitbrains/src/main/kotlin/org/opendc/trace/bitbrains/BitbrainsResourceStateTable.kt
+++ b/opendc-trace/opendc-trace-bitbrains/src/main/kotlin/org/opendc/trace/bitbrains/BitbrainsResourceStateTable.kt
@@ -48,13 +48,13 @@ internal class BitbrainsResourceStateTable(private val factory: CsvFactory, path
override val isSynthetic: Boolean = false
override val columns: List<TableColumn<*>> = listOf(
- RESOURCE_STATE_ID,
+ RESOURCE_ID,
RESOURCE_STATE_TIMESTAMP,
- RESOURCE_STATE_CPU_COUNT,
- RESOURCE_STATE_CPU_CAPACITY,
+ RESOURCE_CPU_COUNT,
+ RESOURCE_CPU_CAPACITY,
RESOURCE_STATE_CPU_USAGE,
RESOURCE_STATE_CPU_USAGE_PCT,
- RESOURCE_STATE_MEM_CAPACITY,
+ RESOURCE_MEM_CAPACITY,
RESOURCE_STATE_MEM_USAGE,
RESOURCE_STATE_DISK_READ,
RESOURCE_STATE_DISK_WRITE,
diff --git a/opendc-trace/opendc-trace-bitbrains/src/main/kotlin/org/opendc/trace/bitbrains/BitbrainsResourceStateTableReader.kt b/opendc-trace/opendc-trace-bitbrains/src/main/kotlin/org/opendc/trace/bitbrains/BitbrainsResourceStateTableReader.kt
index 56e66f5c..54be5dea 100644
--- a/opendc-trace/opendc-trace-bitbrains/src/main/kotlin/org/opendc/trace/bitbrains/BitbrainsResourceStateTableReader.kt
+++ b/opendc-trace/opendc-trace-bitbrains/src/main/kotlin/org/opendc/trace/bitbrains/BitbrainsResourceStateTableReader.kt
@@ -113,13 +113,13 @@ internal class BitbrainsResourceStateTableReader(private val partition: String,
override fun hasColumn(column: TableColumn<*>): Boolean {
return when (column) {
- RESOURCE_STATE_ID -> true
+ RESOURCE_ID -> true
RESOURCE_STATE_TIMESTAMP -> true
- RESOURCE_STATE_CPU_COUNT -> true
- RESOURCE_STATE_CPU_CAPACITY -> true
+ RESOURCE_CPU_COUNT -> true
+ RESOURCE_CPU_CAPACITY -> true
RESOURCE_STATE_CPU_USAGE -> true
RESOURCE_STATE_CPU_USAGE_PCT -> true
- RESOURCE_STATE_MEM_CAPACITY -> true
+ RESOURCE_MEM_CAPACITY -> true
RESOURCE_STATE_MEM_USAGE -> true
RESOURCE_STATE_DISK_READ -> true
RESOURCE_STATE_DISK_WRITE -> true
@@ -131,13 +131,13 @@ internal class BitbrainsResourceStateTableReader(private val partition: String,
override fun <T> get(column: TableColumn<T>): T {
val res: Any? = when (column) {
- RESOURCE_STATE_ID -> partition
+ RESOURCE_ID -> partition
RESOURCE_STATE_TIMESTAMP -> timestamp
- RESOURCE_STATE_CPU_COUNT -> cpuCores
- RESOURCE_STATE_CPU_CAPACITY -> cpuCapacity
+ RESOURCE_CPU_COUNT -> cpuCores
+ RESOURCE_CPU_CAPACITY -> cpuCapacity
RESOURCE_STATE_CPU_USAGE -> cpuUsage
RESOURCE_STATE_CPU_USAGE_PCT -> cpuUsagePct
- RESOURCE_STATE_MEM_CAPACITY -> memCapacity
+ RESOURCE_MEM_CAPACITY -> memCapacity
RESOURCE_STATE_MEM_USAGE -> memUsage
RESOURCE_STATE_DISK_READ -> diskRead
RESOURCE_STATE_DISK_WRITE -> diskWrite
@@ -156,7 +156,7 @@ internal class BitbrainsResourceStateTableReader(private val partition: String,
override fun getInt(column: TableColumn<Int>): Int {
return when (column) {
- RESOURCE_STATE_CPU_COUNT -> cpuCores
+ RESOURCE_CPU_COUNT -> cpuCores
else -> throw IllegalArgumentException("Invalid column")
}
}
@@ -167,10 +167,10 @@ internal class BitbrainsResourceStateTableReader(private val partition: String,
override fun getDouble(column: TableColumn<Double>): Double {
return when (column) {
- RESOURCE_STATE_CPU_CAPACITY -> cpuCapacity
+ RESOURCE_CPU_CAPACITY -> cpuCapacity
RESOURCE_STATE_CPU_USAGE -> cpuUsage
RESOURCE_STATE_CPU_USAGE_PCT -> cpuUsagePct
- RESOURCE_STATE_MEM_CAPACITY -> memCapacity
+ RESOURCE_MEM_CAPACITY -> memCapacity
RESOURCE_STATE_MEM_USAGE -> memUsage
RESOURCE_STATE_DISK_READ -> diskRead
RESOURCE_STATE_DISK_WRITE -> diskWrite
diff --git a/opendc-trace/opendc-trace-bitbrains/src/main/kotlin/org/opendc/trace/bitbrains/BitbrainsResourceTableReader.kt b/opendc-trace/opendc-trace-bitbrains/src/main/kotlin/org/opendc/trace/bitbrains/BitbrainsResourceTableReader.kt
index c02dc5ae..146c04f0 100644
--- a/opendc-trace/opendc-trace-bitbrains/src/main/kotlin/org/opendc/trace/bitbrains/BitbrainsResourceTableReader.kt
+++ b/opendc-trace/opendc-trace-bitbrains/src/main/kotlin/org/opendc/trace/bitbrains/BitbrainsResourceTableReader.kt
@@ -49,7 +49,7 @@ internal class BitbrainsResourceTableReader(private val factory: CsvFactory, vms
continue
}
- id = reader.get(RESOURCE_STATE_ID)
+ id = reader.get(RESOURCE_ID)
return true
} finally {
reader.close()