Hi Timo,
Thanks for getting back and filing the jira. I'll try to see if there's a way
we can rework things to take advantage of the aggregate functions.
-- Piyush
On 9/23/20, 3:55 AM, "Timo Walther" wrote:
Hi Piyush,
unfortunately, UDFs have no direct access to Flink's
Hi Piyush,
unfortunately, UDFs have no direct access to Flink's state. Aggregate
functions are the only type of functions that can be stateful at the
moment. Aggregate functions store their state in an accumulator that is
serialized/deserialized on access, but an accumulator field can be
Hi folks,
We were looking to cache some data using Flink’s MapState in one of our UDFs
that are called by Flink SQL queries. I was trying to see if there’s a way to
set up these state objects via the basic FunctionContext [1] we’re provided in
the Table / SQL UserDefinedFunction class [2] but
