hi Adam I have checked the code and indeed this feature is not available in the latest version of Flink code.
This feature was originally implemented in the old planner: <https://github.com/apache/flink/pull/8550/files> https://github.com/apache/flink/pull/8550/files However, this logic was not implemented in the new planner , the Blink planner. With the removal of the old planner in version 1.14 https://github.com/apache/flink/pull/16080 , this code was also removed. Best Feng On Sat, Apr 8, 2023 at 4:17 AM Adam Augusta <[email protected]> wrote: > The TableAggregateFunction javadocs indicate that either "emitValue" or > "emitUpdateWithRetract" is required. > > But if I implement my TableAggregateFunction with "emitUpdateWithRetract", > I get a validation error. If I implement both methods it works, but > emitUpdateWithRetract is not used. > > Peering into the Flink source code, I see that > ImperativeAggCodeGen validates the presence of emitValue, but is agnostic > to emitUpdateWithRetract. > More curiously, Flink's source code doesn't have a single test with a > TableAggregateFunction that uses emitUpdateWithRetract. > > Is this a ghost feature? > > Thanks, > Adam >
