Chloe He
Chloe He
### What happened? When the start and end of window boundaries span across data types, ibis forces casting in the window boundaries: https://github.com/ibis-project/ibis/blob/17be43a1081c34582408d4c627191263ec948ada/ibis/expr/builders.py#L177-L182 and this is not executable in 5...
### Is your feature request related to a problem? While we have implemented support for the basic operators in the Flink backend, there are still some operators that are commonly...
## Description of changes This PR fixes the compilation of over aggregation query in Flink backend. I identified the following issues: 1. The interval time value is not compiled with...
## Description of changes Add a new blog post on stream-batch unification.
### Please describe the issue Existing tutorials and examples connect to a database table and expressions are written and executed directly on top of the database table. It would be...
## Description of changes 1. Implement support for `window_by` in pyspark backend. 2. Code cleanup/refactor. ## Issues closed #8847
### Is your feature request related to a problem? Windowing functions are not supported in Pyspark backend right now. ### Describe the solution you'd like I'd like to have support...
### Please describe the issue The streaming blogs that we have so far focus on manipulations of a single table. Joins are common in streaming applications, e.g., table-stream joins, stream-stream...
### Is your feature request related to a problem? No ### What is the motivation behind your request? In streaming engines, we need to connect to sources and sinks. Flink...