Hi Kai, AggregateFunction and TableAggregateFunction are both stateful UDF interfaces. This should cover most scenarios given where they would be used. If you need more fine-grained control you can also always drop down into the DataStream API (using #toDataStream) and work there. Table API / SQL in general are higher-level abstractions where you cannot directly interact with operators.
If this doesn't answer your question it would also be great if you could explain your use case more so we can understand it. Thanks! Best Ingo On Wed, Jun 30, 2021 at 3:37 PM Kai Fu <zzfu...@gmail.com> wrote: > Hi team, > > We've a use case that needs to create/access state in UDF, while per the > documentation > <https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/table/functions/udfs/#runtime-integration> > and UDF interface > <https://github.com/apache/flink/blob/master/flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/UserDefinedFunction.java>. > It does not provide such a way for that. We want to know if it is by design > and is there any other approach for it. > > -- > *Best wishes,* > *- Kai* >
