RisingWave Labs ORG

Event streaming platform for agentic AI. Continuously ingest, transform, and serve event streams in real time, at scale.

A streaming database that processes live data continuously and keeps query results up to date in real time, replacing the multiple separate tools usually needed for stream processing.

A collection of demos showcasing how stream processing can be used to solve real-world problems.

Generate accurate and informative tree dumps of asynchronous tasks.

RisingWave Kubernetes Operator

Open-Source Platform for Subagents and Agent Teams. Long-running, collaborative, proactive.

Use dbt to manage real-time data transformations in RisingWave.

A binary representation of json value, optimized for parsing and querying.

Helm Charts for RisingWave

A memcomparable serialization format.

Python stream processing with RisingWave

DataTalks Workshop Materials

RFC (request for comments) for changes to RisingWave

Useful extension utilities for thiserror.

demo program for POC

Nexmark event generator in Rust.

The reactive backend for agents and apps.

RisingWave MCP Server.

Extensible SQL Lexer and Parser for Rust

SQL/JSON path engine in Rust.

No description.

Lightweight HTTP API layer for ingesting data into RisingWave.

The legacy documentation of RisingWave (up to v2.0). The latest documentation is managed at https://github.com/risingwavelabs/risingwave-docs

Agent Skills for RisingWave.

No description.

Dump metrics to files

No description.

Homebrew tap for RisingWave

A simple in-memory implementation of the OpenTelemetry trace collector with a Web UI for visualizing the traces that can be embedded into other Rust applications.

ChaGPT Plugin for RisingWave Documentation

Toolset for diagnosing Risingwave clusters.

An implementation of a LRU cache

The official RisingWave documentation repository

Apache Iceberg

RisingWave official tutorial

A Kafka-based NEXMark generator for risingwave.

No description.

Risingwave nightly builds' commits history. Useful to diagnose regressions

No description.

Scriptable database and system performance benchmark (forked from akopytov/sysbench)

This repo contains Dockerfiles for building Docker images from Apache Flink

Set of helpers for RisingWave BYOC operations.

No description.

Build a Real Lakehouse on Your Laptop!

RisingWave Java UDF template

SQL CLI for Apache Flink® via docker-compose

No description.

Library that expedites the development of Kubernetes controllers

Database migrations. CLI and Golang library.

A high-performance observability data pipeline.

Rust allocator using jemalloc as a backend

No description.

Reference Terraform code to bootstrap a RisingWave BYOK (Bring Your Own Kubernetes) environment

Madsim fork of sqlx. Branches with names of the form madsim-vX.Y.Z will correspond to sqlx vX.Y.Z. To produce a new patched version, first checkout a new branch from the latest patch, then rebase it on the version's tagged commit. To fix Cargo.lock conflicts, simply checkout the tagged version's Cargo.lock, and run cargo update tokio.

No description.

TDS 7.2+ (Microsoft SQL Server) driver for Rust

Anclax is a framework for building serverless and reliable applications in speed of light with confidence

Terraform module to create Amazon Elastic Kubernetes (EKS) resources 🇺🇦

Github Action to cherry-pick commit and create PR on Release Branch

Magical Deterministic Simulator for distributed systems in Rust.

RisingWave org profile

No description.

Ready-to-run examples for Wavelet — the reactive backend for agents and apps

Encoding and decoding support for BSON in Rust

Efficient data transformation and modeling framework that is backwards compatible with dbt.

No description.

Rust SDK for Apache Avro - a data serialization system.

Apache Avro is a data serialization system.

PROST! a Protocol Buffers implementation for the Rust Language

A client-side gRPC channel implementation for tonic

Pure Rust Iceberg Implementation

clippy code copied from rust repo

for patch `rdkafka-sys`

Streaming ELT made easy.

No description.

Public docs for AWS service ready of RisingWave

Streaming ETL/ELT to Apache Iceberg, Delta Lake, and more.

No description.

A typed client for ClickHouse

Rust language bindings for Faiss

A library for efficient similarity search and clustering of dense vectors.

Check if tables and items in a .toml file are lexically sorted

No description.

🌿 SQL schema definition and discovery

Terraform CLI commands via Go.

Apache Iceberg

End-to-end HTTP and REST API testing for Go.

A cross-platform `addr2line` clone written in Rust, using `gimli`

GCP BigQuery Client (Rust)

No description.

A modern runtime for JavaScript and TypeScript.

Strongly typed JSON library for Rust

GORM PostgreSQL driver for RisingWave

The core engine at the heart of Deno

A runtime for writing reliable asynchronous applications with Rust. Provides I/O, networking, scheduling, timers, ...

A really basic thread-safe progress bar for Golang applications

A native Rust library for Delta Lake, with bindings into Python

A Rust native datatype for Postgres' Numeric type, to be used with Rust's "Postgres" library.

axum_embed is a library that provides a service for serving embedded files using the axum web framework.

No description.

No description.

Fast and flexible GitHub action to backport merged pull requests to selected branches

Generate random test cases for databases

The flexibility of Python with the scale and performance of modern SQL.

A Grafana plugin to visualize metrics in a diagram using flow charts, gantt charts, sequence diagrams, or class diagrams

An etcd v3 API client

Prometheus instrumentation library for Rust applications

Extremely fast tracing library for Rust

OpenID Connect Library for Rust

MySQL random data loader

Release repo of the RisingWave Connector

Benchmarks for queries over continuous data streams.

A toolbox to benchmark TPC workloads in Go

Rust FFI bindings for macOS libproc