Skip to content

Support sliding windows in AggregateUDF / User Defined Window Functions #6611

@alamb

Description

@alamb

Is your feature request related to a problem or challenge?

When implementing an user defined aggregator via AggregateUDF, it is not possible to use the retract_batch API to incrementally update aggregate functions used as window functions

Describe the solution you'd like

I would like to extend somehow so user defined aggregate functions can take advantage of retract_batch

Ideally:

  1. Implement the code
  2. Update / add an end to end example showing how to use this API -- the existing example is https://github.com/apache/arrow-datafusion/blob/main/datafusion-examples/examples/simple_udaf.rs

Describe alternatives you've considered

No response

Additional context

@stuartcarnie found this gap while working on functionality for IOx

Metadata

Metadata

Assignees

Labels

enhancementNew feature or request

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions