Yogeshvu
08/13/2024, 9:44 PMisinstance
of a given dataschema type to detect which schema decoder object to retreive dynamically when dealing with dataframe csv?Nikita Klimenko [JB]
08/14/2024, 1:25 PM@DataSchema
interface MySchema {
val a: Int
}
fun main() {
val targetSchema = DataFrame.emptyOf<MySchema>().compileTimeSchema()
val df = dataFrameOf("a")(123)
val res = if (targetSchema.compare(df.schema()).isSuperOrEqual()) {
df.cast<MySchema>()
} else {
null
}
}
DataFrame<T>.compileTimeSchema
(new function) creates a DataFrameSchema object based on reflective introspection of MySchema interface.
DataFrame<T>.schema
based on runtime data.
Is this what do you mean by schema decoder object and retrieving it dynamically?Yogeshvu
08/14/2024, 2:34 PMNikita Klimenko [JB]
08/14/2024, 2:56 PMimplementation("org.jetbrains.kotlinx:dataframe:0.14.0-dev-3829")
and
plugins {
id("org.jetbrains.kotlinx.dataframe") version "0.14.0-dev-3829"
}
Yes, we plan to include it in the next releaseYogeshvu
08/14/2024, 4:54 PM