Features
True streaming data processing engine in Rust
Same code for streaming and batch workloads
Incremental joins, filters, group-by, reduce
Temporal joins, windows, ranges
Custom stateful reducers and pointer-based data structures
User Defined Functions and async API/LLM calls
Built-in vector indexing (HNSW), BM24, hybrid search
LLM extension pack for RAG pipelines
Time-series libraries, clustering, classification
Connectors for Kafka, PostgreSQL, Redpanda, S3, Google PubSub, Slack, Logstash
Data persistence with S3 and schema validation at compile time
REST API endpoint for serving features with sub-millisecond latency
Python and SQL programming APIs
Monitoring and traces with OpenTelemetry and Grafana
Visual Explorer with live dashboards and geospatial viz
AI screenplay analysis with structural feedback
Box office performance prediction
PitchTrailer integration for pitch deck generation
Beat sheet generation for pacing analysis
Visual heatmap of dialogue and pacing
Comparative market data against top-grossing films
Collaborative workspace (up to 5 users)
Advanced analytics dashboard
Dedicated account manager
