منصوبے کے بارے میں

RisingWave ایک ایونٹ اسٹریمنگ پلیٹ فارم ہے جو روایتی پیچیدہ اسٹیکس (جیسے Debezium، Kafka، اور Flink) کی جگہ لیتا ہے، جس میں ڈیٹا کی وصولی (ingestion)، انکریمنٹل پروسیسنگ، اور کم لیٹنسی سرونگ کو یکجا کیا گیا ہے۔ اسے ریئل ٹائم ایپلی کیشنز اور AI ایجنٹس کے لیے تازہ اور قابلِ استفسار (queryable) ڈیٹا فراہم کرنے کے لیے ڈیزائن کیا گیا ہے۔ اہم صلاحیتوں میں شامل ہیں: - **ملٹی سورس انجسٹن**: یہ webhooks، ڈیٹا بیسز (PostgreSQL، MySQL) سے نیٹو CDC، ایونٹ اسٹریمز (Kafka، Pulsar، Kinesis)، اور S3 سے تاریخی بیچ ڈیٹا کی حمایت کرتا ہے۔ - **انکریمنٹل پروسیسنگ**: مسلسل کمپیوٹیشن کے لیے materialized views کا استعمال کرتا ہے، جس سے 100ms سے کم وقت میں اینڈ ٹو اینڈ ڈیٹا کی تازگی یقینی بنتی ہے۔ - **لو لیٹنسی سرونگ**: SQL کوئریز کو 10-20 ms p99 لیٹنسی کے ساتھ فراہم کرنے کے لیے نتائج کو ایک اندرونی row store میں برقرار رکھتا ہے۔ - **اوپن اسٹوریج انٹیگریشن**: طویل مدتی حفظ اور تجزیاتی رسائی کے لیے Apache Iceberg ٹیبلز میں لکھتا ہے، اور vectorized query execution کے لیے Apache DataFusion کا استعمال کرتا ہے۔ - **لاگت مؤثر آرکیٹیکچر**: اخراجات کم کرنے اور لچکدار اسکیلنگ کے لیے اندرونی حالت اور materialized views کو آبجیکٹ اسٹوریج (S3) میں محفوظ کرتا ہے، جس میں کارکردگی کے لیے اختیاری ڈسک کیش موجود ہے۔ - **مطابقت**: یہ PostgreSQL وائر پروٹوکول کے ذریعے منسلک ہوتا ہے اور AI ایجنٹ انٹیگریشن کے لیے MCP سرور، CLI، اور Skills فراہم کرتا ہے۔ عام استعمال کے کیسز میں ریئل ٹائم مانیٹرنگ اور الرٹنگ، ML کے لیے فیچر اسٹورز، لائیو ڈیش بورڈز، ریئل ٹائم ڈیٹا ان enrichment، اور اسٹریمنگ لیک ہاؤسز شامل ہیں۔