Marton Bod

Iceberg split generation rate limit

44

## Description Hive, Hudi and DeltaLake connectors already use the same approach implemented in this PR, whereby they first asynchronously load (stream) splits into an `AsyncQueue` (which can be configured...

[Feature] Support dynamic refresh of watched namespaces

3

### Search before asking - [X] I had searched in the [issues](https://github.com/ray-project/kuberay/issues) and found no similar feature requirement. ### Description Currently we use the `--watch-namespace=foo,bar` flag to specify the list...

Implement incremental refresh for single-table, predicate-only MVs

4

## Description In the Iceberg connector, currently we do a full refresh of MVs in all cases, meaning we drop all the existing data from the MV storage table and...

Add new table handle interface to expose common datalake-type info

4

Proposal is to have a new interface, `DataLakeTableHandle`, which extends `ConnectorTableHandle` and will be implemented by the Iceberg/Delta/Hudi/Hive table handles. This new table handle interface would expose some common shared...

Add event-listener plugin with Kafka sink

2

Currently open source Trino has only MySQL and http event listener plugins. These are not always scalable, especially when several larger Trino clusters are sending hundreds of thousands of events...