risingwavelabs/risingwave

何を解決するか

RisingWaveは、従来のイベントストリーミングスタックの複雑さを排除するように設計されています。データのインジェスト、処理、配信にDebezium、Kafka、Flinkなどの複数のツールを連携させるのではなく、AIエージェントやリアルタイムアプリケーション向けに常に最新でクエリ可能な低遅延のデータを提供する単一のシステムを提供します。

動作方法

RisingWaveは、Webhook、データベースの変更（CDC）、イベントストリーム（Kafka、Pulsar、Kinesis）、およびS3からの履歴バッチデータを継続的にインジェストします。上流データが変更されたときのみ、インクリメンタル計算を使用して結果を更新し、100ms未満のエンドツーエンドの最新性を維持します。

結果は内部の行ストアを介して低遅延（10〜20ms）のSQLクエリで提供され、長期保存および分析アクセスは、システムが自動的に管理するApache Icebergテーブルとのネイティブ統合によって処理されます。

対象ユーザー

ストリーミングデータ、特徴ストア、ライブダッシュボードの統合パイプラインを必要とする、エージェント型AIおよびリアルタイムアプリケーションを開発する開発者向けに構築されています。

主な特徴

• 統合SQLインターフェース: PostgreSQLのワイヤプロトコルを介して標準SQLでストリームとテーブルを結合。
• インクリメンタル計算: 完全再計算なしでマテリアライズドビューを更新し、高い最新性を確保。
• コスト効率の高いストレージ: RAMよりもコストを削減するため、内部状態とテーブルをオブジェクトストレージ（S3）に保存。
• エージェント対応: AIエージェントがシステムを直接クエリおよび操作できるように、MCPサーバー、CLI、スキルを備えています。
• オープンフォーマット統合: 永続的でオープンフォーマットのストレージを実現するApache Icebergテーブルをネイティブで管理。