I’d like to implement a ksqlDB UDF accepting as argument a Struct instance matching any schema. The plan is to use introspection in the UDF implementation in order to check the schema and then use that info in order to build another Struct matching the same schema that will be the result of the UDF.
Of course this is not the real use case, but you can think for example in a toy UDF accepting any Struct and returning another Struct with the same schema but where values in all integer fields have been duplicated. I’m still a ksqlDB newbie, but AFAIK it looks like this kind of dynamism is not an option at the moment. Am I correct? Any suggestions?
Thanks!