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…
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 —…
