The FusionVault transform executor on Apache DataFusion: inline row steps and relational reshapes (join, aggregate, window, union) over Arrow, with the value…
Stateful streaming operators for FusionVault Streams: event-time tumbling and sliding windows with keyed incremental aggregation, session windows, stream…
The FusionVault Streams engine: runs a stream pipeline continuously over Kafka with N independent consumer threads, stateful operators from fv-streams-ops,…
The FusionVault Streams internal exchange: Arrow-IPC-carrying frames over kernel TCP on tokio, with N flows per worker pair, one owner task per socket…
Credential verification and query scope derivation, shared by the control plane's forensics authorization funnel and the standalone Query plane, with no…
The SQL front door for FusionVault Streams: a streaming SQL statement parses to a small typed logical plan and lowers to the same topology the TOML frontend…
The FusionVault Streams standalone runner: run a stream pipeline defined in one TOML file against Kafka or Redpanda with no control plane, including the…
The contract of FusionVault Streams: the control-plane seam, the task-facing source/sink/operator contract, the decode policy and meta columns, the settings…
The checkpoint state of FusionVault Streams: epochs, manifests and the epoch store — in memory, or an object store (local directory, S3) — the durable half of…
The file formats of FusionVault Streams: Arrow IPC, Parquet, CSV and JSON lines as one writer/reader shape over the arrow-rs codecs — the format axis of the…
The connectors of FusionVault Streams — Kafka, files and object stores, Iceberg, database lookup tables, Arrow Flight, the Nexmark generator, the blackhole —…