Hi Ingo, Thank you for the reply, we actually need more fine-grained control on the states in UDF. Per investigation, we found that the states can be simply created/accessed via implementing `CheckpointedFunction` interface, please advise if there is any side-effect by doing that.
On Wed, Jun 30, 2021 at 10:33 PM Ingo Bürk <i...@ververica.com> wrote: > 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* >> > -- *Best wishes,* *- Kai*
