The analytics module is a multi-surface runtime for analytical workloads. It combines OLAP execution, streaming/CEP processing, forecasting, anomaly detection, and model-serving integrations behind shared analytics interfaces.
- OLAP and aggregation plane
- group-by and analytical aggregation execution
- columnar and export-related execution paths
- Streaming and CEP plane
- windowed streaming computation
- pattern detection and rule-driven CEP processing
- stream join coordination
- Predictive and ML integration plane
- forecasting and anomaly scoring
- in-process and external model-serving integration
- Distributed orchestration plane
- shard fan-out execution
- partial-result aggregation and coordination
| Contract | Behavior |
|---|---|
| analytics execution APIs | perform analytical computations and result shaping |
| streaming/CEP APIs | evaluate windows and event patterns |
| forecasting/anomaly APIs | provide predictive and outlier analysis flows |
| model serving APIs | connect analytics requests to model inference paths |
| distributed analytics APIs | coordinate multi-shard execution and result merge |
- optional-backend paths fail with structured errors when capabilities are unavailable.
- runtime execution paths preserve fail-closed behavior on invalid inputs or unsupported operations.
- distributed analytics paths can return partial outcomes according to module policy.
- Verified implementation files:
- src/analytics/olap.cpp
- src/analytics/streaming_window.cpp
- src/analytics/streaming_join.cpp
- src/analytics/cep_engine.cpp
- src/analytics/forecasting.cpp
- src/analytics/model_serving.cpp
- src/analytics/distributed_analytics.cpp
- Verified architecture claims:
- multi-plane analytics runtime composition
- optional dependency and capability-sensitive execution paths
- distributed coordination present in dedicated implementation file