Mehmet Fatih Aktas
Mehmet Fatih Aktas
## Description of changes Explorative PR towards addressing https://github.com/ibis-project/ibis/issues/7712. This draft PR - Aims to bring more clarity to the concerns raised in https://github.com/ibis-project/ibis/issues/7712#issuecomment-1850331739. - Implements `ibis.read_iceberg()` by - Fetching...
### Is your feature request related to a problem? Event-time temporal join in Flink enables joining a table against a **versioned** table. Tables in Flink are temporal/dynamic, i.e., row values...
### 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...
## 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...
### Is your feature request related to a problem? Flink supports specifying a point in time and querying the corresponding data in a given table, aka `time travel`. As a...
### Is your feature request related to a problem? This meta-issue is for the `Spark Streaming` epic by which we plan to add spark streaming support in Ibis. This issue...
## Description of changes Aims to close https://github.com/ibis-project/ibis/issues/8710. Notes to reviewers: * Adds `AntiWindowJoin` and `SemiWindowJoin` sqlglot expressions. Would there be a way to avoid these? I could not find...
## Description of changes Aims to address https://github.com/ibis-project/ibis/issues/8888.
### Is your feature request related to a problem? As described in the meta-issue https://github.com/ibis-project/ibis/issues/8868, our initial understanding is that Spark SQL has the same syntax for both batch and...