Live table ingestion

Ingest rows into a live table that is queryable from SQL.

Live tables are append-only tables backed by an in-memory change feed. They are immediately queryable from SQL — no batch refresh required.

Experimental: Live tables are functional but the API and storage backend may change. Not certified for production use.

import krishiv as ks
import pyarrow as pa

session = ks.Session.embedded()
session.sql("CREATE LIVE TABLE sensor_readings")

lt = session.live_table("sensor_readings")
lt.ingest_row({"sensor_id": "s1", "value": 23.4, "ts": 1700000000})
lt.ingest_row({"sensor_id": "s2", "value": 22.1, "ts": 1700000001})
lt.refresh()

session.sql("SELECT * FROM sensor_readings ORDER BY ts").show()

Reading the change feed

for record in lt.change_feed():
    print(record)

See Live Tables (SQL) for the DDL form and Python Lakehouse for the full API.