risingwavelabs/risingwave

해결하는 문제

RisingWave는 전통적인 이벤트 스트리밍 스택의 복잡성을 제거하도록 설계되었습니다. 데이터 인제스트, 처리, 서빙에 Debezium, Kafka, Flink와 같은 여러 도구를 연결하는 대신, AI 에이전트와 실시간 애플리케이션을 위한 항상 최신 상태이며 낮은 지연 시간으로 쿼리 가능한 단일 시스템을 제공합니다.

작동 방식

RisingWave는 웹훅, 데이터베이스 변경(CDC), 이벤트 스트림(Kafka, Pulsar, Kinesis), 그리고 S3에서의 이력 배치 데이터를 지속적으로 인제스트합니다. 상류 데이터가 변경될 때만 인크리멘탈 계산을 사용하여 결과를 업데이트하며, 엔드투엔드 최신성은 100ms 미만을 유지합니다.

결과는 내부 행 스토어를 통해 저지연(10~20ms) SQL 쿼리를 제공하며, 장기 저장 및 분석 접근은 시스템이 자동으로 관리하는 Apache Iceberg 테이블과의 네이티브 통합을 통해 처리됩니다.

대상 사용자

스트리밍 데이터, 피처 스토어, 실시간 대시보드를 위한 통합 파이프라인을 필요로 하는 에이전트형 AI 및 실시간 애플리케이션을 개발하는 개발자들을 위한 것입니다.

주요 특징

• 통합 SQL 인터페이스: PostgreSQL 와이어 프로토콜을 통해 표준 SQL로 스트림과 테이블을 조인.
• 인크리멘탈 계산: 전체 재계산 없이 마테리얼라이즈드 뷰를 업데이트하여 높은 최신성 보장.
• 비용 효율적 스토리지: RAM보다 비용을 절감하기 위해 내부 상태와 테이블을 객체 스토리지(S3)에 저장.
• 에이전트 준비 완료: AI 에이전트가 시스템을 직접 쿼리하고 조작할 수 있도록 MCP 서버, CLI, 스킬을 포함.
• 오픈 포맷 통합: 지속 가능하고 오픈 포맷 스토리지용으로 Apache Iceberg 테이블을 네이티브로 관리.