ksql
ksql copied to clipboard
Use KSQL types in UD(A)Fs instead of BigDecimal/List/Struct
In order to give more flexibility and type safety to implementations of UDFs, we should do the following:
- wrap
BigDecimalinKsqlDecimalwhich will provide both the schema and the value - wrap
ListinKsqlArraywhich will provide both the schema and the value - do not use
Structin udfs, but useKsqlStructinstead
And of course, move to using SqlType and removing use of Connect's Schema in UDFS
Removing out dependency on the Connect schema and types for our UDF framework (and serde framework!) will fix a whole family of bugs. See below for linked bugs as we find them.