Is your feature request related to a problem?
I recently began experimenting with the RisingWave backend and its streaming capabilities but found that the tumble and hop function from the Ibis for streaming example was not working with RisingWave with the following error:
OperationNotDefinedError: Compilation rule for 'WindowAggregate' operation is not defined
Since RisingWave is one of the first streaming engines supported by Ibis, it is logical for examples in the documentation to work on RisingWave backend, too.
Although writing a tumble/hop function in the raw ibis.sql() clause and combining it with other operations works, direct support for .tumble() is more elegant and user-friendly, in my opinion.
What is the motivation behind your request?
No response
Describe the solution you'd like
Implement the visit_WindowAggregate function as it is done in Flink.
What version of ibis are you running?
12.0.0
What backend(s) are you using, if any?
RisingWave
Code of Conduct
Is your feature request related to a problem?
I recently began experimenting with the RisingWave backend and its streaming capabilities but found that the tumble and hop function from the Ibis for streaming example was not working with RisingWave with the following error:
Since RisingWave is one of the first streaming engines supported by Ibis, it is logical for examples in the documentation to work on RisingWave backend, too.
Although writing a tumble/hop function in the raw
ibis.sql()clause and combining it with other operations works, direct support for.tumble()is more elegant and user-friendly, in my opinion.What is the motivation behind your request?
No response
Describe the solution you'd like
Implement the
visit_WindowAggregatefunction as it is done in Flink.What version of ibis are you running?
12.0.0
What backend(s) are you using, if any?
RisingWave
Code of Conduct