Self-adaptive processing graph with operator fission for elastic stream processing

امروزه اطلاعات تولید شده توسط تعاملات اینترنتی به طور نمادین در حال رشد است، و موجب جریان گسترده و مداوم وقایع از منابع متنوع می شود. این تعاملات حاوی اطلاعات ارزشمندی برای دامنه هایی مانند دولت، تجارت، و بانک ها، از جمله دیگران است. استخراج اطلاعات در نزدیکی زمان واقعی از چنین اطلاعاتی نیاز به ابزارهای پردازش قدرتمند برای مقابله با سرعت بالا و جریان حجم بالا رویدادها دارد. موتورهای پردازش توزیع شده ویژه طراحی یک توپولوژی مبتنی بر گراف از تعداد زیادی از اپراتورهای پردازش را ایجاد تنگناها و مشکلات تعادل بار هنگام پردازش جریان های پویا از وقایع. در این کار ما یک گراف پردازش خود سازگار را ارائه می دهیم که الاستیسیته و مقیاس پذیری را بوسیله افزایش یا کاهش تعداد اپراتورهای پردازش برای بهبود عملکرد و بهره برداری از منابع سیستم ارائه می دهد. راه حل ما با استفاده از یک مدل است که نظارت، تجزیه و تحلیل و تغییر توپولوژی گراف با یک الگوریتم کنترل است که هر دو واکنشی و پیشگیرانه به جریان رویدادها است. ما راه حل ما را با سه برنامه پردازش جریان ارزیابی کرده ایم و نتایج نشان می دهد که مدل ما می تواند توپولوژی گراف را در هنگام دریافت وقایع با نرخ بالا با سرعت های ناگهانی، تولید هزینه های بسیار کم حافظه و استفاده از پردازنده را تطبیق دهد.