One engine for everythingreal-time streaming.

RisingWave is the real-time compute engine for agentic AI. It ingests events from queues, CDC, webhooks, and lakes, processes them with PostgreSQL-compatible SQL, and serves fresh results for streaming, analytics, search, and decisions. Open source under Apache 2.0.
Products

What does RisingWave do?

RisingWave runs four real-time workloads on one engine, so the data you stream in is the same data you analyze, search, and decide on. Every product below shares the same Rust core, the same PostgreSQL-compatible SQL, and the same object storage.
Streaming
Sub-100ms stream processing on queues, CDC, webhooks, and lakes. Incremental materialized views keep results fresh for trading, monitoring, fraud, and risk.
Learn more→
Analytics
Second-level fresh OLAP on Apache Iceberg. Stream data straight into Iceberg tables and query them without running external compactors.
Learn more→
Search
Coming soon
Full-text and vector search over live data at high concurrency. Index events as they arrive and serve agents and applications from object storage.
Decisions
AI models that score and decide on every event as it arrives. Recurrence runs decision models directly on the stream, grounded in the latest data.
Visit Recurrence
The Engine

How is RisingWave built?

Every RisingWave product runs on the same engine. It is written in Rust, with compute decoupled from storage on S3-compatible object storage, so state scales independently of the machines that process it. The engine speaks the PostgreSQL wire protocol and integrates with a broad ecosystem of connectors, developer tools, and lakehouse formats.
design principles
How It Works

How does data move through RisingWave?

RisingWave ingests events through purpose-built connectors, processes them with incremental streaming SQL, serves results over the PostgreSQL protocol, and stores state on tiered object storage. Each stage is designed for low latency and fresh results, so one pipeline can feed dashboards, applications, and AI models at once.
Ingestion
Processing
Serving
Storage
Rich Set of Connectors↓
RisingWave offers purpose-built streaming connectors equipped with built-in intelligence to detect back pressure, enabling efficient data ingestion from numerous sources in a decentralized manner.
Unified Data Model in SQL↓
RisingWave adopts a standard relational model, enabling the creation of complex data pipelines using standard SQL. This allows data engineers to treat their streams as building blocks.
Automatic Schema Evolution↓
RisingWave provides automated schema evolution to guarantee data contracts between upstream and downstream systems on the structure and semantics of data that is in motion.
Incremental Processing for Ultra Low Latency↓
Live data has short shelf life. Incremental updates are triggered automatically in RisingWave to guarantee always fresh insights letting users get the most value of their data sets.
Materialized View Interface↓
Materialized views in RisingWave are continuously updated to ensure consistently fresh results. Even the most complex data pipelines can be constructed using cascading materialized views without sacrificing speed or freshness.
Composable Data Pipelines↓
RisingWave makes data pipelines composable, allowing tables and views generated by one query to be seamlessly used as inputs for downstream queries.
Dedicated Compute for User-facing Applications↓
RisingWave also supports disaggregated compute with dedicated serving nodes for ad hoc queries, ensuring efficient data access.
PG Wire protocol↓
RisingWave is compatible with Postgres wire protocol which means any tool in Postgres ecosystem is supported by RisingWave.
Multiple SDKs↓
RisingWave unifies development and usage patterns across Python, SQL, Java, and JavaScript through a common UDF framework. This enables the easy embedding of custom business logic within data pipelines.
Tiered Storage to Access Data↓
With RisingWave’s cloud-native architecture, data is stored across storage tiers based on recency, workload needs, etc. This smart allocation keeps the compute footprint small, matching users’ compute job needs.
Rich Support for Temporality of Data↓
RisingWave supports various time windowing strategies, such as tumbling, sliding, and session windows, along with watermarks and temporal filters to handle unbounded data streams effectively.
Native Data Lake Formats Support↓
Interoperability is a core design principle of RisingWave. As Iceberg and Delta increasingly become the de facto standards for data lakehouse table formats, RisingWave provides robust read and write support for both.
Rich Set of Connectors
RisingWave offers purpose-built streaming connectors equipped with built-in intelligence to detect back pressure, enabling efficient data ingestion from numerous sources in a decentralized manner.
Unified Data Model in SQL
RisingWave adopts a standard relational model, enabling the creation of complex data pipelines using standard SQL. This allows data engineers to treat their streams as building blocks.
Automatic Schema Evolution
RisingWave provides automated schema evolution to guarantee data contracts between upstream and downstream systems on the structure and semantics of data that is in motion.
Incremental Processing for Ultra Low Latency
Live data has short shelf life. Incremental updates are triggered automatically in RisingWave to guarantee always fresh insights letting users get the most value of their data sets.
Materialized View Interface
Materialized views in RisingWave are continuously updated to ensure consistently fresh results. Even the most complex data pipelines can be constructed using cascading materialized views without sacrificing speed or freshness.
Composable Data Pipelines
RisingWave makes data pipelines composable, allowing tables and views generated by one query to be seamlessly used as inputs for downstream queries.
Dedicated Compute for User-facing Applications
RisingWave also supports disaggregated compute with dedicated serving nodes for ad hoc queries, ensuring efficient data access.
PG Wire protocol
RisingWave is compatible with Postgres wire protocol which means any tool in Postgres ecosystem is supported by RisingWave.
Multiple SDKs
RisingWave unifies development and usage patterns across Python, SQL, Java, and JavaScript through a common UDF framework. This enables the easy embedding of custom business logic within data pipelines.
Tiered Storage to Access Data
With RisingWave’s cloud-native architecture, data is stored across storage tiers based on recency, workload needs, etc. This smart allocation keeps the compute footprint small, matching users’ compute job needs.
Rich Support for Temporality of Data
RisingWave supports various time windowing strategies, such as tumbling, sliding, and session windows, along with watermarks and temporal filters to handle unbounded data streams effectively.
Native Data Lake Formats Support
Interoperability is a core design principle of RisingWave. As Iceberg and Delta increasingly become the de facto standards for data lakehouse table formats, RisingWave provides robust read and write support for both.
Unique Features
What Makes RisingWave Different?
High-Performance Joins
RisingWave efficiently handles complex joins with a decoupled compute-storage architecture, enabling seamless stream joins.
Learn More >
Dynamic Scaling
RisingWave dynamically scales up or down within seconds, handling fluctuating workloads without manual intervention.
Learn More >
Instant Failure Recovery
RisingWave offers instant failure recovery, minimizing downtime and maintaining data consistency during disruptions.
Learn More >
Isolated Serving Nodes
RisingWave uses isolated serving nodes for query serving, separating it from data processing for better performance.
Learn More >
Got 5 minutes? Experience RisingWave Your Way!
RisingWave Cloud is the fastest way to get started. You can also self-host RisingWave with the commercial Premium edition or the free Apache-licensed edition.
RisingWave Cloud
RisingWave BYOC
RisingWave Premium
RisingWave Cloud
  • √ Fully-hosted and managed service
  • √ Zero operational overhead on customers
  • √ Elastic and cost-effective
  • √ OpenTelemetry integration for Centralized observability
  • √ SoC 2, GDPR and HIPAA compliant
  • √ Managed service
  • √ Hosted in Customer VPC
  • √ Kubernetes manageability Included
  • √ Built for data sovereignty
  • √ SoC2, GDPR and HIPAA compliant
  • √ Customer hosted and managed service
  • √ Curated binaries and premium support
  • √ Exclusive access to licensed Premium features
  • √ Management tooling to manage RisingWave service
  • √ Advanced configuration for sophisticated customer environments
The engine for real-time streaming data.
Analyze, search, and decide.
Start Free
SlackJoin our Slack
GitHubXLinkedInSlackYouTube
Sign up for our to stay updated.