An intelligent system is a continuous loop. Events arrive, application state changes, a model makes a decision, and the result becomes another event.
AlgoX2 keeps the data path for that loop on one real-time plane. Producers append facts once, applications derive model-facing state continuously, and every consumer reads the same ordered history at the pace its workload requires.
Build real-time AI on one data plane
Stateful stream processing applies application code to new events and materializes keyed features, entity profiles, sequence tails, or decision messages. Online models read the current materialization, while training jobs replay retained history at recorded cuts.
Streams, state, and computation
| Primitive | Role |
|---|---|
| Ordered event history | Captures fresh events once and retains their permanent stream positions for replay. |
| Stateful stream processing | Runs application transforms continuously and writes their results back as new streams. |
| Keyed materialized views | Resolve an entity key directly to current features, profiles, or bounded sequence tails. Ordered streams retain the complete event history behind each view. |
| Cuts and checkpoints | Save application state with the last included position in each input stream, so a restart resumes with the following messages. |
Messages keep the same stream positions across memory, local storage, and object storage. X2 serves cache hits from memory and refills an uncached settled range from the storage tier that still retains it. Live arrivals and historical refills use separate cache shares, so a deep replay does not evict the live working set.
What teams build on AlgoX2
Real-Time Feature Store A stream application maintains counters, embeddings, scores, profiles, and latest values as events arrive. The online path reads the current keyed state without waiting for a batch refresh.
Sequence Store A sequence view preserves individual event identity and order instead of reducing history to a summary. Models read the latest bounded tail for inference or reconstruct the corresponding tail at an earlier training cutoff.
Risk, Fraud, and Decision Audit A decision combines current features with recent behavior, then records its input cut, model version, and output on a stream. Investigation and backtesting can reconstruct what the system knew when the decision was made.
Entity Profiles and Personalization Applications fold interactions into continuously changing customer, account, device, or product state. Recommendation and ranking systems combine that state with the entity’s latest sequence.
Agent Context An agent can assemble session history, durable entity facts, behavioral state, and semantic references from applications sharing the same data plane. The application owns retrieval and prompt policy while AlgoX2 keeps the underlying facts ordered and replayable.
One source for serving and training
Serving and training need different physical access paths. Serving reads one current entity under a latency budget, while training reconstructs billions of earlier contexts at high throughput.
They do not need separate definitions of the data. A versioned application view defines membership, ordering, corrections, and cutoff eligibility once. Online serving and historical training both derive their inputs from that definition and the same retained source.
This structure removes an entire class of training-serving skew. A recorded cut identifies the facts that were available, while the transformation and model versions identify how those facts became an input and a decision.
Built for the request path
AlgoX2 is streaming-first. It is designed for fresh events, predictable latency, high ingestion throughput, independent consumers, and application code running close to the stream.
Model development and execution remain outside the data plane. Training and serving systems manage model code, weights, runtimes, accelerators, and scaling. AlgoX2 stores and delivers the continuously changing events, state, and history that those systems depend on.