New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Allow UDAF to be a processor/transformer #2438

Open

orchesio opened this issue Feb 13, 2019 · 1 comment

orchesio commented Feb 13, 2019

Current UDAF is very limited to certain operations, and input types. It will be very useful to allow UDAF be a processor/transformer.

To be able to achieve that, several things need to happen

Add annotations to UDAF to allow state store creation. @UDFFactory @StateStore
UDAF function interface changes as mentioned in here
Allow physical planner to attach transformer/process to DSL.
Associate schema/serde with schema registry

There must be other things needed here but want to get your input on how to or whether it's feasible to support this.

vkabanorv commented Dec 2, 2020

I think the implementation of this feature would be really great for KSQL. Is there anything I can do to facilitate this?

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment