blob: 2da4d2823f1f6eeaf86a4422829414312017854c [file]
import org.jetbrains.kotlinx.dataframe.*
import org.jetbrains.kotlinx.dataframe.annotations.*
import org.jetbrains.kotlinx.dataframe.api.*
import org.jetbrains.kotlinx.dataframe.io.*
fun box(): String {
val df = dataFrameOf("timestamps" to columnOf(listOf(100, 113, 140), listOf(400, 410, 453)))
val df1 = df.split { timestamps }.by { it.map { it.toString() } }.intoRows()
val timestamps: DataColumn<String> = df1.timestamps
timestamps.print()
val df2 = dataFrameOf("a", "b")(listOf(100, 113, 140), listOf(400, 410))
val df3 = df2.split { a and b }.by { it.map { it.toString() } }.intoRows()
// exploding multiple columns will introduce nulls
df3.print()
// plugin needs to play safe and make both selected columns nullable
df3.compileTimeSchema().columns.let {
assert(it["a"]!!.nullable)
assert(it["b"]!!.nullable)
}
// compile time schema is still compatible with runtime
df3.compareSchemas()
return "OK"
}