[hashhar]

The article talks about the reverse direction however. i.e. Data from Kafka being ingested via Flink for Trino to query as Iceberg tables - everything with a single consistent schema.

To be pedantic though Flink also operates on a flush interval so not "real time" by that definition.

[bitsondatadev]

Ah this makes sense. This is similar to what Elasticsearch shards do.