ibis
ibis copied to clipboard
ibis-project
the portable Python dataframe library
### 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...
**Acceptance criteria**: Ibis releases and launches its first two streaming backends, Apache Flink and RisingWave, in collaboration with Claypot AI and RisingWave respectively. Stretch goal: Apache Sedona backend for streaming...
Right now we're letting types that we know (and can know) are invalid for a given backend. Unsigned integers are a good example of this. We should ensure that these...
### Is your feature request related to a problem? Temporal join against Iceberg tables would be a "killer feature" [@zhenzhongxu] for training dataset generation using Ibis. Iceberg tables support [time...
### Is your feature request related to a problem? Pattern recognition in Flink enables searching for a set of event patterns in data streams. Flink comes with a [complex event...
### What happened? ```py In [20]: import ibis ...: ...: t = ibis.examples.penguins.fetch() ...: ix = ibis.row_number().name("ix") ...: expr = t.mutate(ix=ix) ...: expr = expr.filter(ix == 5) In [21]: expr...
## 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 The goal of this PR is to make `schema` argument optional for `read_parquet()` for Flink backend. When `schema` is not provided, it will be read from...
### Please describe the issue I was following the advise of https://ibis-project.org/how-to/extending/sql#backend.raw_sql, and closing the returned cursor. But the actual SQL I was running was an `EXPLAIN SELECT ...` query....
This is a work in progress, not working yet we have an issue with the records size. I was trying to run the `.github/workflows/upload-algolia.py` locally and run into this kind...
