Batch SQL
Run DataFusion-backed SQL and DataFrame plans over registered Arrow and Parquet-style sources.
- Finite inputs
- Arrow results
- SQL + DataFrame
Krishiv Engine
A Rust-native compute framework for batch SQL and stateful streaming, with experimental incremental view maintenance on one Arrow data model.
Pre-release and not for production use. Pin a commit when evaluating.
import krishiv as ks
session = ks.Session()
result = session.sql(
"SELECT 42 AS answer"
).collect()
print(result.pretty())Workload model
Shared primitives reduce the seams between finite queries, long-lived pipelines, and maintained results.
Run DataFusion-backed SQL and DataFrame plans over registered Arrow and Parquet-style sources.
Build event-time windows, watermarks, stateful operators, checkpoints, and continuous joins.
Propagate weighted inserts and retractions to maintain changing results, with visible fallback paths.
Architecture
SQL, Rust, Python, Flight SQL, and MCP enter through public session and runtime seams. Placement remains explicit at every topology.
Read the architectureBuilt for ownership
Run it inside an application, on one host, or against an explicit remote coordinator. Platform is not required and never gets a private engine path.
Developer preview
No fictional package commands and no hidden production claims.