Phase 4.2
Real-time streaming with DAG topologies, windows, joins, CEP, and live tails
Define named streams, wire DAG processors, simulate RocksDB-backed state, and monitor live event flow with backpressure awareness across connectors and sinks.
Control Loop
1. Register streams and windows.
2. Compose join, CEP, and sink topologies.
3. Run the topology and inspect state, backpressure, and live tails.
Loading streaming surfaces...