Hi everyone, I have a Flink SQL use case where I need to ignore changes made to a particular column to reduce traffic. If there is a new changelog from an existing key, ignore it if all columns except

col1

are the same. If any other column has changed, send it downstream. My idea was to create an UDTF for that but it seems like there is no way to make it stateful. Is there any way to create stateful UD(T)Fs to use in Flink SQL?